| QueueDeliveryEndpoint.java |
/*
* JBoss, the OpenSource J2EE webOS
*
* Distributable under LGPL license.
* See terms of license at gnu.org.
*/
package org.jboss.jms.server.standard;
import org.jboss.jms.server.DeliveryEndpoint;
import org.jboss.jms.server.MessageReference;
import org.jboss.jms.server.list.MessageList;
/**
* A queue delivery endpoint
*
* @author <a href="mailto:adrian@jboss.org>Adrian Brock</a>
* @version $Revision: 1.1 $
*/
public class QueueDeliveryEndpoint
implements DeliveryEndpoint
{
// Constants -----------------------------------------------------
// Attributes ----------------------------------------------------
/** The message list */
private MessageList list;
// Static --------------------------------------------------------
// Constructors --------------------------------------------------
public QueueDeliveryEndpoint(MessageList list)
{
this.list = list;
}
// Public --------------------------------------------------------
// DeliveryEndpoint implementation -------------------------------
public void deliver(MessageReference message)
throws Exception
{
list.add(message);
}
// Protected ------------------------------------------------------
// Package Private ------------------------------------------------
// Private --------------------------------------------------------
// Inner Classes --------------------------------------------------
}
| QueueDeliveryEndpoint.java |