SpyConsumer.java |
/* * JBossMQ, the OpenSource JMS implementation * * Distributable under LGPL license. See terms of license at gnu.org. */ package org.jboss.mq; import javax.jms.JMSException; /** * This class defines the interface which is used by the ConnectionReceiver to * send messages to the consumers. * * @author Hiram Chirino (Cojonudo14@hotmail.com) * @author <a href="mailto:adrian@jboss.org">Adrian Brock</a> * @version $Revision: 1.3 $ */ public interface SpyConsumer { // Public -------------------------------------------------------- /** * A ConnectionReceiver uses this method to load a Consumer with a message * * @param mes the message * @throws JMSException for any error */ void addMessage(SpyMessage mes) throws JMSException; /** * This is used to know what type of messages the consumer wants * * @return the subscription */ Subscription getSubscription(); // Inner classes ------------------------------------------------- }
SpyConsumer.java |