public class LocalCMPReceiver
extends java.lang.Object
Constructor and Description |
---|
LocalCMPReceiver(java.lang.String brokerName,
int sessionID) |
Modifier and Type | Method and Description |
---|---|
void |
associateSender(com.ibm.broker.config.proxy.Sender senderObject)
Associates an Sender object with this Receiver.
|
void |
deliverMessage(byte[] messageToDeliver) |
void |
deregisterReceiverListener(com.ibm.broker.config.proxy.ReceiverListener r)
Tells the Receiver to stop notifying the supplied object about all
incoming messages from the broker.
|
void |
registerReceiverListener(com.ibm.broker.config.proxy.ReceiverListener r)
Tells the Receiver to notify the supplied object about all incoming
messages from the broker.
|
void |
run() |
public LocalCMPReceiver(java.lang.String brokerName, int sessionID)
public void run()
public void deliverMessage(byte[] messageToDeliver)
public void registerReceiverListener(com.ibm.broker.config.proxy.ReceiverListener r)
r
- The object that should be notified when a
message arrives.public void deregisterReceiverListener(com.ibm.broker.config.proxy.ReceiverListener r)
r
- The object that was previously
registered, that should no longer be notified when a message
arrives.public void associateSender(com.ibm.broker.config.proxy.Sender senderObject)