def METHOD_NAME(self, partition_context, event):
    if event:
        if self.args.processing_delay:
            delay_in_seconds = self.args.processing_delay / 1000
            if self.args.processing_delay_strategy == 'sleep':
                time.sleep(delay_in_seconds)
            elif self.args.processing_delay_strategy == 'spin':
                starttime = time.time()
                while (time.time() - starttime) < delay_in_seconds:
                    pass
        # Consume properties: this will load all the AMQP message application properties into
        # a decoded dictionary.
        _ = event.properties
        # Consume body: this will load the full message body content.
        _ = event.body
        if self.args.checkpoint_interval:
            self._partition_event_count[partition_context.partition_id] += 1
            if self._partition_event_count[partition_context.partition_id] >= self.args.checkpoint_interval:
                partition_context.update_checkpoint(event)
                self._partition_event_count[partition_context.partition_id] = 0
        try:
            self.event_raised_sync()
        except Exception as e:
            self.error_raised_sync(e)