1 7 package org.jboss.jms.server.standard; 8 9 import org.jboss.jms.message.JBossMessage; 10 import org.jboss.jms.server.DeliveryEndpoint; 11 import org.jboss.jms.server.DeliveryEndpointFactory; 12 import org.jboss.jms.server.MessageBroker; 13 import org.jboss.jms.server.MessageReference; 14 import org.jboss.jms.server.list.MessageList; 15 16 22 public class QueueDeliveryEndpointFactory 23 implements DeliveryEndpointFactory 24 { 25 27 29 30 private MessageBroker broker; 31 32 33 private MessageList list; 34 35 37 39 public QueueDeliveryEndpointFactory(MessageBroker broker, MessageList list) 40 { 41 this.broker = broker; 42 this.list = list; 43 } 44 45 47 49 public DeliveryEndpoint getDeliveryEndpoint(MessageReference message) 50 { 51 return new QueueDeliveryEndpoint(list); 52 } 53 54 public MessageReference getMessageReference(JBossMessage message) 55 { 56 return broker.getMessageReference(message); 57 } 58 59 61 63 65 } 67 | Popular Tags |