Modifier and Type | Method and Description |
---|---|
Destination |
EjbMessageBean.getDestination()
Returns the destination.
|
Destination |
JmsActivationConfig.getDestinationObject() |
Destination |
MessageDestination.getResolvedDestination() |
Modifier and Type | Method and Description |
---|---|
java.lang.Class<? extends Destination> |
JmsActivationConfig.getDestinationType() |
Modifier and Type | Method and Description |
---|---|
void |
JmsActivationConfig.setDestinationObject(Destination destination) |
void |
EjbMessageBean.setDestinationValue(Destination destination)
Sets the JMS destination.
|
Modifier and Type | Method and Description |
---|---|
void |
BamJmsService.setDestination(Destination queue)
Sets the destination
|
Modifier and Type | Class and Description |
---|---|
class |
ClusterQueue<X extends java.io.Serializable>
ClusterQueue provides reliable point to point transfer of messages.
|
class |
ClusterTopic<X extends java.io.Serializable>
ClusterTopic provides reliable Publish/Subscribe message model
communication between the nodes in the Resin cluster.
Following example shows how to make two nodes in resin cluster
communicate between each other using cluster topic.
|
class |
FileQueue<X extends java.io.Serializable>
A JMS queue backed by a file-based database.
|
class |
FileTopic<E>
A JMS topic backed by a file-based database.
|
class |
MemoryQueue<X>
A JMS queue stored in memory.
|
class |
MemoryTopic
A JMS topic stored in memory.
|
Modifier and Type | Method and Description |
---|---|
Session |
Jms.createListener(Connection conn,
Destination queue,
MessageListener listener)
Creates a session and listener.
|
Message |
Jms.receive(Destination dest) |
Message |
Jms.receive(Destination dest,
long timeout) |
Message |
Jms.receiveNoWait(Destination dest) |
void |
Jms.send(Destination dest,
Message msg) |
void |
Jms.send(Destination dest,
Message msg,
int deliveryMode,
int priority,
long ttl) |
Modifier and Type | Class and Description |
---|---|
class |
ClusterQueueImpl<E extends java.io.Serializable>
Implements a cluster receive queue.
|
class |
ClusterTopicImpl<E extends java.io.Serializable>
Workflow
ClusterTopic sends out a
SubscribeTopic message to Triad
Traid stores all the topic subscriptions
Message Producer sends out a TriadTopicMessage to the Triad
Triad node sends out TriadTopicMessage to all the topic subscribers
|
Modifier and Type | Class and Description |
---|---|
class |
TemporaryQueueImpl
A temporary queue
|
class |
TemporaryTopicImpl
A basic topic.
|
Modifier and Type | Method and Description |
---|---|
Destination |
MessageProducerImpl.getDestination()
Returns the producer's destination.
|
Modifier and Type | Method and Description |
---|---|
ConnectionConsumer |
ConnectionImpl.createConnectionConsumer(Destination destination,
java.lang.String messageSelector,
ServerSessionPool sessionPool,
int maxMessages)
Creates a new consumer (optional)
|
MessageConsumer |
JmsSession.createConsumer(Destination destination)
Creates a consumer to receive messages.
|
MessageConsumer |
JmsSession.createConsumer(Destination destination,
java.lang.String messageSelector)
Creates a consumer to receive messages.
|
MessageConsumer |
JmsSession.createConsumer(Destination destination,
java.lang.String messageSelector,
boolean noLocal)
Creates a consumer to receive messages.
|
MessageProducer |
JmsSession.createProducer(Destination destination)
Creates a producer to produce messages.
|
void |
MessageProducerImpl.send(Destination destination,
Message message)
Sends a message to the destination
|
void |
MessageProducerImpl.send(Destination destination,
Message message,
int deliveryMode,
int priority,
long timeToLive)
Sends a message to the destination
|
Modifier and Type | Class and Description |
---|---|
class |
FileQueueImpl<E extends java.io.Serializable>
A JMS queue backed by a file-based database.
|
class |
FileSubscriberQueue<E>
Implements a file queue.
|
class |
FileTopicImpl<E>
Implements a file topic.
|
Modifier and Type | Method and Description |
---|---|
Destination |
HubImpl.createTopic(java.lang.String name) |
Destination |
Hub.createTopic(java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
Destination |
ResourceAdapterImpl.getDestination()
Gets the destination
|
Modifier and Type | Method and Description |
---|---|
void |
ResourceAdapterImpl.setDestination(Destination destination)
Sets the destination
|
Constructor and Description |
---|
ManagedSessionImpl(ConnectionFactory factory,
Destination destination) |
Modifier and Type | Class and Description |
---|---|
class |
JdbcDestination
Represents a JDBC destination.
|
class |
JdbcQueue<E>
A jdbc queue.
|
Modifier and Type | Class and Description |
---|---|
class |
MemoryQueueImpl<E>
Implements a memory queue.
|
class |
MemorySubscriberQueue<E>
Implements a memory queue.
|
class |
MemoryTopicImpl<E>
Implements a memory topic.
|
Modifier and Type | Method and Description |
---|---|
Destination |
MessageImpl.getJMSDestination()
Gets the destination
|
Destination |
MessageImpl.getJMSReplyTo()
Gets the reply-to destination
|
Modifier and Type | Method and Description |
---|---|
void |
MessageImpl.setJMSDestination(Destination destination)
Sets the reply-to destination
|
void |
MessageImpl.setJMSReplyTo(Destination replyTo)
Sets the reply-to destination
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDestination<E>
Implements an abstract queue.
|
class |
AbstractMemoryQueue<E,QE extends QueueEntry<E>>
Provides abstract implementation for a memory queue.
|
class |
AbstractQueue<E>
Implements an abstract queue.
|
class |
AbstractTopic<E>
Implements an abstract topic.
|
class |
DestinationHandle
Implements an abstract queue.
|
class |
PollingQueue<E>
Implements an queue which polls the data periodically.
|
class |
PollingTopic<E>
Implements an topic which polls the data periodically.
|
Modifier and Type | Method and Description |
---|---|
Destination |
AbstractDestination.getJMSDestination() |
Modifier and Type | Method and Description |
---|---|
void |
JmsBlockingQueue.setDestination(Destination destination) |
Constructor and Description |
---|
JmsBlockingQueue(ConnectionFactory factory,
Destination destination) |
Modifier and Type | Method and Description |
---|---|
void |
MessageSenderResource.setDestination(Destination destination)
Sets the JMS Destination (Queue or Topic)
|
void |
ListenerResource.setDestination(Destination destination)
Sets the JMS Destination (Queue or Topic)
|
Modifier and Type | Method and Description |
---|---|
void |
JMSServlet.setDestination(Destination destination) |
void |
HessianListener.setDestination(Destination destination)
Sets the name of the input queue.
|
Modifier and Type | Method and Description |
---|---|
void |
JmsHandler.addTarget(Destination target)
Adds a target (queue or jms destination)
|
Constructor and Description |
---|
JMSQueue(ConnectionFactory connectionFactory,
Destination queue)
Connects to a named queue.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Queue
The main destination.
|
interface |
TemporaryQueue
The main destination.
|
interface |
TemporaryTopic
The main destination.
|
interface |
Topic
The main destination.
|
Modifier and Type | Method and Description |
---|---|
Destination |
MessageProducer.getDestination() |
Destination |
Message.getJMSDestination() |
Destination |
Message.getJMSReplyTo() |
Modifier and Type | Method and Description |
---|---|
ConnectionConsumer |
Connection.createConnectionConsumer(Destination destination,
java.lang.String messageSelector,
ServerSessionPool sessionPool,
int maxMessages) |
MessageConsumer |
Session.createConsumer(Destination destination) |
MessageConsumer |
Session.createConsumer(Destination destination,
java.lang.String selector) |
MessageConsumer |
Session.createConsumer(Destination destination,
java.lang.String selector,
boolean noLocal) |
MessageProducer |
Session.createProducer(Destination destination) |
void |
MessageProducer.send(Destination destination,
Message message) |
void |
MessageProducer.send(Destination destination,
Message message,
int deliveryMode,
int priority,
long timeToLive) |
void |
Message.setJMSDestination(Destination replyTo) |
void |
Message.setJMSReplyTo(Destination replyTo) |