| org.apache.cocoon.components.jms.AbstractMessagePublisher
All known Subclasses: org.apache.cocoon.acting.JMSPublisherAction,
AbstractMessagePublisher | abstract public class AbstractMessagePublisher extends AbstractLogEnabled implements Serviceable,Parameterizable,Initializable,Disposable,JMSConnectionEventListener(Code) | | Abstract JMS message publisher. Use this as a basis for components
that want to publish JMS messages.
When used in conjunction with the default
org.apache.cocoon.components.jms.JMSConnectionManager
implementation this class supports automatic reconnection when the connection gets severed.
Parameters:
parameter |
required |
default |
description |
connection |
yes |
|
Name of the connection registered with
org.apache.cocoon.components.jms.JMSConnectionManager .
This must be a topic connection.
|
topic |
yes |
|
The name of the topic to publish messages to. |
priority |
no |
4 |
the priority of the published messages |
time-to-live |
no |
10000 |
the message's lifetime in milliseconds |
persistent-delivery |
no |
false |
whether to use persistent delivery mode when publishing messages |
version: CVS $Id: AbstractMessagePublisher.java 30941 2004-07-29 19:56:58Z vgritsenko $ |
m_acknowledgeMode | protected int m_acknowledgeMode(Code) | | |
m_mode | protected int m_mode(Code) | | |
m_priority | protected int m_priority(Code) | | |
m_publisher | protected TopicPublisher m_publisher(Code) | | |
m_session | protected TopicSession m_session(Code) | | |
m_timeToLive | protected int m_timeToLive(Code) | | |
AbstractMessagePublisher | public AbstractMessagePublisher()(Code) | | |
dispose | public void dispose()(Code) | | |
onDisconnection | public void onDisconnection(String name)(Code) | | |
parameterize | public void parameterize(Parameters parameters) throws ParameterException(Code) | | |
publishMessage | protected synchronized void publishMessage(Message message) throws JMSException(Code) | | Concrete classes call this method to publish messages.
|
service | public void service(ServiceManager manager) throws ServiceException(Code) | | |
|
|