ConsumerDelegate.java |
/* * JBoss, the OpenSource J2EE webOS * * Distributable under LGPL license. * See terms of license at gnu.org. */ package org.jboss.jms.client; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; /** * The implementation of a consumer * * @author <a href="mailto:adrian@jboss.org>Adrian Brock</a> * @version $Revision: 1.2 $ */ public interface ConsumerDelegate extends Lifecycle { // Constants ----------------------------------------------------- // Public -------------------------------------------------------- /** * Receive a message * * @param timeout the timeout * @return the message * @throws JMSException for any error */ Message receive(long timeout) throws JMSException; /** * * Set the message listener * @param the new message listener * @throws JMSException for any error */ void setMessageListener(MessageListener listener) throws JMSException; // Inner Classes -------------------------------------------------- }
ConsumerDelegate.java |