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.
-