Package org.pipservices3.messaging.queues

Interface IMessageReceiver

public interface IMessageReceiver

Callback interface to receive incoming messages.

### Example ###

 
 class MyMessageReceiver implements IMessageReceiver {
   public void receiveMessage(MessageEnvelop envelop, IMessageQueue queue) {
       System.out.println("Received message: " + envelop.getMessageAsString());
       ...
   }
 }
 
 MemoryMessageQueue messageQueue = new MemoryMessageQueue();
 messageQueue.listen("123", new MyMessageReceiver());
 
 messageQueue.open("123");
 messageQueue.send("123", new MessageEnvelop(null, "mymessage", "ABC")); // Output in console: "ABC"
 
 

Method Summary

Modifier and Type	Method	Description
void	receiveMessage(MessageEnvelop message, IMessageQueue queue)	Receives incoming message from the queue.

Method Details

receiveMessage

void receiveMessage(MessageEnvelop message,
IMessageQueue queue)

Receives incoming message from the queue.

Parameters:

message - an incoming message

queue - a queue where the message comes from

See Also:

MessageEnvelop, IMessageQueue