Menu
▾
▴
[jboss-cvs] jboss-jms/src/main/org/jboss/jms/server/standard StandardMessageBroker.java QueueBrowserEndpointFactory.java QueueDeliveryEndpoint.java StandardMessageReference.java QueueDeliveryEndpointFactory.java QueueBrowserEndpoint.java
User: ejort
Date: 03/08/30 07:23:44
Added: src/main/org/jboss/jms/server/standard
StandardMessageBroker.java
QueueBrowserEndpointFactory.java
QueueDeliveryEndpoint.java
StandardMessageReference.java
QueueDeliveryEndpointFactory.java
QueueBrowserEndpoint.java
Log:
Getting there, something actually works now
Revision Changes Path
1.1 jboss-jms/src/main/org/jboss/jms/server/standard/StandardMessageBroker.java
Index: StandardMessageBroker.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.destination.JBossDestination;
import org.jboss.jms.message.JBossMessage;
import org.jboss.jms.server.BrowserEndpointFactory;
import org.jboss.jms.server.DeliveryEndpointFactory;
import org.jboss.jms.server.MessageBroker;
import org.jboss.jms.server.MessageReference;
import org.jboss.jms.server.list.memory.MemoryMessageList;
/**
* The standard message broker
*
* @author <a href="mailto:ad...@jb...>Adrian Brock</a>
* @version $Revision: 1.1 $
*/
public class StandardMessageBroker
implements MessageBroker
{
// Constants -----------------------------------------------------
// Attributes ----------------------------------------------------
/** The message list */
private MemoryMessageList list = new MemoryMessageList();
// Static --------------------------------------------------------
// Constructors --------------------------------------------------
// Public --------------------------------------------------------
// MessageBroker implementation ----------------------------------
public BrowserEndpointFactory getBrowserEndpointFactory(JBossDestination destination, String selector)
{
return new QueueBrowserEndpointFactory(list, selector);
}
public DeliveryEndpointFactory getDeliveryEndpointFactory(JBossDestination destination)
{
return new QueueDeliveryEndpointFactory(this, list);
}
public MessageReference getMessageReference(JBossMessage message)
{
return new StandardMessageReference(message);
}
// Protected ------------------------------------------------------
// Package Private ------------------------------------------------
// Private --------------------------------------------------------
// Inner Classes --------------------------------------------------
}
1.1 jboss-jms/src/main/org/jboss/jms/server/standard/QueueBrowserEndpointFactory.java
Index: QueueBrowserEndpointFactory.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.BrowserEndpoint;
import org.jboss.jms.server.BrowserEndpointFactory;
import org.jboss.jms.server.list.MessageList;
/**
* A queue delivery endpoint factory
*
* @author <a href="mailto:ad...@jb...>Adrian Brock</a>
* @version $Revision: 1.1 $
*/
public class QueueBrowserEndpointFactory
implements BrowserEndpointFactory
{
// Constants -----------------------------------------------------
// Attributes ----------------------------------------------------
/** The message list */
private MessageList list;
/** The selector */
private String selector;
// Static --------------------------------------------------------
// Constructors --------------------------------------------------
public QueueBrowserEndpointFactory(MessageList list, String selector)
{
this.list = list;
this.selector = selector;
}
// Public --------------------------------------------------------
// BrowserEndpointFactory implementation -------------------------
public BrowserEndpoint getBrowserEndpoint()
{
return new QueueBrowserEndpoint(list, selector);
}
// Protected ------------------------------------------------------
// Package Private ------------------------------------------------
// Private --------------------------------------------------------
// Inner Classes --------------------------------------------------
}
1.1 jboss-jms/src/main/org/jboss/jms/server/standard/QueueDeliveryEndpoint.java
Index: 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:ad...@jb...>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 --------------------------------------------------
}
1.1 jboss-jms/src/main/org/jboss/jms/server/standard/StandardMessageReference.java
Index: StandardMessageReference.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.message.JBossMessage;
import org.jboss.jms.server.MessageReference;
/**
* A message reference
*
* @author <a href="mailto:ad...@jb...>Adrian Brock</a>
* @version $Revision: 1.1 $
*/
public class StandardMessageReference
implements MessageReference
{
// Constants -----------------------------------------------------
// Attributes ----------------------------------------------------
/** The message */
private JBossMessage message;
// Static --------------------------------------------------------
// Constructors --------------------------------------------------
public StandardMessageReference(JBossMessage message)
{
this.message = message;
}
// Public --------------------------------------------------------
// MessageReference implementation -------------------------------
public JBossMessage getMessage()
throws Exception
{
return message;
}
public int getPriority()
throws Exception
{
return message.getJMSPriority();
}
public String getMessageID()
throws Exception
{
return message.getJMSMessageID();
}
// Protected ------------------------------------------------------
// Package Private ------------------------------------------------
// Private --------------------------------------------------------
// Inner Classes --------------------------------------------------
}
1.1 jboss-jms/src/main/org/jboss/jms/server/standard/QueueDeliveryEndpointFactory.java
Index: QueueDeliveryEndpointFactory.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.message.JBossMessage;
import org.jboss.jms.server.DeliveryEndpoint;
import org.jboss.jms.server.DeliveryEndpointFactory;
import org.jboss.jms.server.MessageBroker;
import org.jboss.jms.server.MessageReference;
import org.jboss.jms.server.list.MessageList;
/**
* A queue delivery endpoint factory
*
* @author <a href="mailto:ad...@jb...>Adrian Brock</a>
* @version $Revision: 1.1 $
*/
public class QueueDeliveryEndpointFactory
implements DeliveryEndpointFactory
{
// Constants -----------------------------------------------------
// Attributes ----------------------------------------------------
/** The message broker */
private MessageBroker broker;
/** The message list */
private MessageList list;
// Static --------------------------------------------------------
// Constructors --------------------------------------------------
public QueueDeliveryEndpointFactory(MessageBroker broker, MessageList list)
{
this.broker = broker;
this.list = list;
}
// Public --------------------------------------------------------
// DeliveryEndpointFactory implementation ------------------------
public DeliveryEndpoint getDeliveryEndpoint(MessageReference message)
{
return new QueueDeliveryEndpoint(list);
}
public MessageReference getMessageReference(JBossMessage message)
{
return broker.getMessageReference(message);
}
// Protected ------------------------------------------------------
// Package Private ------------------------------------------------
// Private --------------------------------------------------------
// Inner Classes --------------------------------------------------
}
1.1 jboss-jms/src/main/org/jboss/jms/server/standard/QueueBrowserEndpoint.java
Index: QueueBrowserEndpoint.java
===================================================================
/*
* JBoss, the OpenSource J2EE webOS
*
* Distributable under LGPL license.
* See terms of license at gnu.org.
*/
package org.jboss.jms.server.standard;
import java.util.List;
import org.jboss.jms.server.BrowserEndpoint;
import org.jboss.jms.server.list.MessageList;
/**
* A queue browser endpoint
*
* @author <a href="mailto:ad...@jb...>Adrian Brock</a>
* @version $Revision: 1.1 $
*/
public class QueueBrowserEndpoint
implements BrowserEndpoint
{
// Constants -----------------------------------------------------
// Attributes ----------------------------------------------------
/** The message list */
private MessageList list;
/** The selector */
private String selector;
// Static --------------------------------------------------------
// Constructors --------------------------------------------------
public QueueBrowserEndpoint(MessageList list, String selector)
{
this.list = list;
this.selector = selector;
}
// Public --------------------------------------------------------
// BrowserEndpoint implementation --------------------------------
public List browse()
throws Exception
{
return list.browse(selector);
}
// Protected ------------------------------------------------------
// Package Private ------------------------------------------------
// Private --------------------------------------------------------
// Inner Classes --------------------------------------------------
}
|