Package | Description |
---|---|
org.apache.commons.messagelet |
This package provides the mechansim to deploy MessageListener beans in a
servlet application server which are intialized and destroyed with a web-application
as well as introducing MessageDrivenObjects which are MessageListeners which
receive servlet-style lifecycle events and Messagelets which are servlets that
process Messages.
|
org.apache.commons.messagelet.impl |
This package contains implementation classes to support both MDO's as well
as to be able to dispatch into a Servlet engine to be able to process
Messagelets.
|
org.apache.commons.messenger |
The main Messenger interface, a simple facade for working with JMS, together with all
the default implementation classes and additional factory classes.
|
org.apache.commons.messenger.task |
A collection of Ant tasks for working with JMS.
|
org.apache.commons.messenger.tool |
A collection of tools for working with Messenger.
|
Modifier and Type | Field and Description |
---|---|
private Messenger |
ConsumerThread.messenger |
private Messenger |
MessengerMDO.messenger
the Messenger with which this MDO is associated
|
private Messenger |
BridgeMDO.outputMessenger
the Messenger used to output messages
|
Modifier and Type | Method and Description |
---|---|
Messenger |
ConsumerThread.getMessenger()
Returns the messenger.
|
Messenger |
MessengerMDO.getMessenger()
Provides access to the current Messenger which was used to generate the current
Message.
|
Messenger |
Main.getMessenger(java.lang.String name) |
protected Messenger |
SubscriptionManager.getMessenger(java.lang.String name) |
Messenger |
BridgeMDO.getOutputMessenger()
Gets the Messenger used to output messages
|
Messenger |
MessageletResponse.getReplyMessenger()
Returns the Messenger that should be used for sending replies to this incoming request
|
Modifier and Type | Method and Description |
---|---|
protected XACapable |
XAConsumerThread.getXACapable(Messenger messenger) |
void |
ConsumerThread.setMessenger(Messenger messenger)
Sets the messenger.
|
void |
MessengerMDO.setMessenger(Messenger messenger) |
void |
BridgeMDO.setOutputMessenger(Messenger outputMessenger)
Sets the Messenger used to output messages
|
Modifier and Type | Field and Description |
---|---|
private Messenger |
MessageletResponseImpl.messenger
the messenger used to send replies to
|
private Messenger |
MessageHttpServletDispatcher.messenger
The reply to messenger
|
private Messenger |
MessageServletDispatcher.messenger
The reply to messenger
|
private Messenger |
HttpMessageletResponseImpl.messenger
the messenger used to send replies to
|
Modifier and Type | Method and Description |
---|---|
Messenger |
MessageletResponseImpl.getReplyMessenger() |
Messenger |
HttpMessageletResponseImpl.getReplyMessenger() |
Modifier and Type | Method and Description |
---|---|
void |
MessageletRequestImpl.setMessenger(Messenger messenger) |
void |
HttpMessageletRequestImpl.setMessenger(Messenger messenger) |
void |
MessageHttpServletDispatcher.setMessenger(Messenger messenger) |
void |
MessageServletDispatcher.setMessenger(Messenger messenger) |
void |
MessageletResponseImpl.setReplyMessenger(Messenger messenger) |
void |
HttpMessageletResponseImpl.setReplyMessenger(Messenger messenger) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultMessenger
DefaultMessenger is the default implementation of
Messenger which uses a ThreadLocal variable
to keep the JMS Session that should be used for a given calling thread. |
class |
MessengerSupport
MessengerSupport is an abstract base class which implements
most of the functionality of Messenger. |
class |
SimpleMessenger
SimpleMessenger is an implementation of
Messenger which uses a single JMS Session for sending
to keep the JMS Session that should be used for a given calling thread. |
class |
XAMessenger
XAMessenger is a default implementation of
Messenger which can also support XA transactions by enlisting and delisting
XAResources. |
Modifier and Type | Field and Description |
---|---|
private Messenger |
MessengerListenerSupport.messenger |
private Messenger |
MessengerServlet.messenger
Holds value of property messenger.
|
private Messenger |
XACapableAdapter.messenger |
Modifier and Type | Method and Description |
---|---|
static Messenger |
MessengerManager.get(java.lang.String name)
Uses the default configuration mechanism this method will return
the Messenger for the given name.
|
Messenger |
MessengerListenerSupport.getMessenger()
Returns the Messenger that this MessageListener is associated with
making it easy to send replies or other messages using
the same Messenger instance that this object is listening to.
|
Messenger |
MessengerServlet.getMessenger()
Getter for property messenger.
|
Messenger |
MessengerManager.getMessenger(java.lang.String name)
Returns the messenger for the given name
|
Modifier and Type | Method and Description |
---|---|
void |
MessengerManager.addMessenger(Messenger messenger) |
void |
MessengerManager.removeMessenger(Messenger messenger) |
void |
MessengerListenerSupport.setMessenger(Messenger messenger)
Called whenever this MessageListener is added to a
Messenger via the addListener() method to associate
this MessageListener with a Messenger instance..
|
void |
MessengerServlet.setMessenger(Messenger messenger)
Setter for property messenger.
|
void |
MessengerListener.setMessenger(Messenger messager)
Called whenever this MessageListener is added to a
Messenger via the addListener() method to associate
this MessageListener with a Messenger instance..
|
Constructor and Description |
---|
XACapableAdapter(Messenger messenger) |
Modifier and Type | Field and Description |
---|---|
private Messenger |
ConsumerTask.messenger |
private Messenger |
ProducerTask.messenger |
Modifier and Type | Method and Description |
---|---|
Messenger |
ConsumerTask.getMessenger() |
Messenger |
ProducerTask.getMessenger() |
Modifier and Type | Method and Description |
---|---|
protected void |
ProducerTask.sendFile(java.io.File file,
Messenger messenger,
javax.jms.Destination destination)
Sends the contents of the given file to the given Destination
using the given Messenger instance
|
void |
ConsumerTask.setMessenger(Messenger messenger)
Sets the Messenger to be used
|
void |
ProducerTask.setMessenger(Messenger messenger)
Sets the Messenger to be used
|
Modifier and Type | Field and Description |
---|---|
private Messenger |
Consumer.messenger |
protected Messenger |
Producer.messenger |