Channel.java |
/* * JBoss, the OpenSource J2EE webOS * * Distributable under LGPL license. * See terms of license at gnu.org. */ package org.jboss.messaging.channel.interfaces; import org.jboss.messaging.interfaces.MessageReference; /** * A channel. * * @author <a href="mailto:adrian@jboss.org">Adrian Brock</a> * @version $Revision: 1.1 $ */ public interface Channel { // Constants ----------------------------------------------------- // Public -------------------------------------------------------- /** * Send a message to the channel. * * @param reference the message reference to send */ void send(MessageReference reference); /** * Receive a message from the channel. * * @param wait the length of time to wait for a message if there are none * immediately available, use -1 for no wait. * @return a message or null if there are no messages */ MessageReference receive(long wait); /** * Close the channel */ void close(); // Inner Classes -------------------------------------------------- }
Channel.java |