pip_services3_messaging.queues.IMessageReceiver module¶

pip_services3_messaging.queues.IMessageReceiver¶

Interface for message receivers.

copyright: Conceptual Vision Consulting LLC 2018-2019, see AUTHORS for more details.
license: MIT, see LICENSE for more details.

class pip_services3_messaging.queues.IMessageReceiver.IMessageReceiver¶

Bases: abc.ABC

Callback interface to receive incoming messages.

Example:

class MyMessageReceiver(IMessageReceiver):
    def receive_message(self, envelop, queue):
        print "Received message: " + envelop.get_message_as_string()

messageQueue = MemoryMessageQueue()
messageQueue.listen("123", MyMessageReceiver())

messageQueue.open("123")
messageQueue.send("123", MessageEnvelope(None, "mymessage", "ABC")) # Output in console: "ABC"

receive_message(message: pip_services3_messaging.queues.MessageEnvelope.MessageEnvelope, queue: <module 'pip_services3_messaging.queues.IMessageQueue' from '/pip_services3_messaging/queues/IMessageQueue.py'>)¶

Receives incoming message from the queue. :param message: an incoming message :param queue: a queue where the message comes from

See MessageEnvelope, IMessageQueue