Examples of ClientConsumer

org.hornetq.api.core.client.ClientConsumer

A ClientConsumer receives messages from HornetQ queues.
Messages can be consumed synchronously by using the receive() methods which will block until a message is received (or a timeout expires) or asynchronously by setting a {@link MessageHandler}.
These 2 types of consumption are exclusive: a ClientConsumer with a MessageHandler set will throw HornetQException if its receive() methods are called. @author Tim Fox @author Clebert Suconic @author Andy Taylor @see ClientSession#createConsumer(String)

org.jboss.jms.client.container.ClientConsumer

@author Ovidiu Feodorov @author Tim Fox/a> @version $Revision: 2774 $ $Id: MessageCallbackHandler.java 2774 2007-06-12 22:43:54Z timfox $

      CallbackManager newCallbackManager = ((ClientConnectionDelegate)ns.getParent().getParent().
         getDelegate()).getRemotingConnection().getCallbackManager();


      // We need to synchronize the old message callback handler using the new one


      ClientConsumer handler = oldCallbackManager.unregisterHandler(oldConsumerID);
      ClientConsumer newHandler = newCallbackManager.unregisterHandler(consumerID);
   
      handler.synchronizeWith(newHandler);
      newCallbackManager.registerHandler(consumerID, handler);
   }

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.

Examples of ClientConsumer

Examples of org.jboss.jms.client.container.ClientConsumer