pip_services3_messaging.queues.CallbackMessageReceiver module

class pip_services3_messaging.queues.CallbackMessageReceiver.CallbackMessageReceiver(callback: Callable[[pip_services3_messaging.queues.MessageEnvelope.MessageEnvelope, pip_services3_messaging.queues.IMessageQueue.IMessageQueue], None])

Bases: pip_services3_messaging.queues.IMessageReceiver.IMessageReceiver

Wraps message callback into IMessageReceiver

receive_message(message: pip_services3_messaging.queues.MessageEnvelope.MessageEnvelope, queue: pip_services3_messaging.queues.IMessageQueue.IMessageQueue)

Receives incoming message from the queue.

Parameters

• message – an incoming message

• queue – a queue where the message comes from