Package org.apache.activemq

Interface CustomDestination

All Superinterfaces:

Destination

public interface CustomDestination
extends Destination

Represents a hook to allow the support of custom destinations such as to support Apache Camel to create and manage endpoints

Method Summary

Modifier and Type	Method	Description
MessageConsumer	createConsumer(ActiveMQSession session, String messageSelector)
MessageConsumer	createConsumer(ActiveMQSession session, String messageSelector, boolean noLocal)
TopicSubscriber	createDurableSubscriber(ActiveMQSession session, String name, String messageSelector, boolean noLocal)
MessageProducer	createProducer(ActiveMQSession session)
TopicPublisher	createPublisher(ActiveMQSession session)
QueueReceiver	createReceiver(ActiveMQSession session, String messageSelector)
QueueSender	createSender(ActiveMQSession session)
TopicSubscriber	createSubscriber(ActiveMQSession session, String messageSelector, boolean noLocal)

Method Detail

createConsumer

MessageConsumer createConsumer(ActiveMQSession session,
                               String messageSelector)

createConsumer

MessageConsumer createConsumer(ActiveMQSession session,
                               String messageSelector,
                               boolean noLocal)

createSubscriber

TopicSubscriber createSubscriber(ActiveMQSession session,
                                 String messageSelector,
                                 boolean noLocal)

createDurableSubscriber

TopicSubscriber createDurableSubscriber(ActiveMQSession session,
                                        String name,
                                        String messageSelector,
                                        boolean noLocal)

createReceiver

QueueReceiver createReceiver(ActiveMQSession session,
                             String messageSelector)

createProducer

MessageProducer createProducer(ActiveMQSession session)
                        throws JMSException

Throws:

JMSException

createPublisher

TopicPublisher createPublisher(ActiveMQSession session)
                        throws JMSException

Throws:

JMSException

createSender

QueueSender createSender(ActiveMQSession session)
                  throws JMSException

Throws:

JMSException