com.ibm.broker.config.proxy

Class LocalCMPReceiver

  • java.lang.Object
    • com.ibm.broker.config.proxy.LocalCMPReceiver

  • public class LocalCMPReceiver
extends java.lang.Object

    • Constructor Summary

      Constructors 
      Constructor and Description
      LocalCMPReceiver(java.lang.String brokerName, int sessionID) 

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      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() 

      • Methods inherited from class java.lang.Object

        equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • LocalCMPReceiver

        public LocalCMPReceiver(java.lang.String brokerName,
                        int sessionID)

    • Method Detail

      • run

        public void run()

      • deliverMessage

        public void deliverMessage(byte[] messageToDeliver)

      • registerReceiverListener

        public void registerReceiverListener(com.ibm.broker.config.proxy.ReceiverListener r)
        Tells the Receiver to notify the supplied object about all incoming messages from the broker.
        Parameters:
        r - The object that should be notified when a message arrives.

      • deregisterReceiverListener

        public 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. If, after this call, there are no remaining listeners for this receiver, the Receiver thread should close down.
        Parameters:
        r - The object that was previously registered, that should no longer be notified when a message arrives.

      • associateSender

        public void associateSender(com.ibm.broker.config.proxy.Sender senderObject)
        Associates an Sender object with this Receiver. The Receiver will disconnect the sender if it detects that the queue manager has gone down.
Skip navigation links