pikachewie.consumer – PikaChewie base consumer class

class pikachewie.consumer.Consumer

Base class for RabbitMQ consumers.

process(message)

Process the given RabbitMQ message.

To implement logic for processing messages in Consumer subclasses, override process_message(), not this method.

Parameters:message (pikachewie.message.Message) – the message to process

process_message()

Subclasses must override this method to implement consumer logic.