pip_services3_messaging.test.TestMessageReceiver module

class pip_services3_messaging.test.TestMessageReceiver.TestMessageReceiver

Bases: pip_services3_messaging.queues.IMessageReceiver.IMessageReceiver, pip_services3_commons.run.ICleanable.ICleanable

TODO add description

clear(correlation_id: Optional[str])

Clears all received messagers.

Parameters

correlation_id – (optional) transaction id to trace execution through call chain.

property message_count

Gets the received message count.

property messages

Gets the list of received messages.

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

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

See MessageEnvelope, class:IMessageQueue <pip_services3_messaging.queues.IMessageQueue.IMessageQueue>