| org.apache.cocoon.components.jms.JMSConnectionImpl
| JMSConnectionImpl | | public class JMSConnectionImpl extends AbstractLogEnabled implements Configurable,Disposable,ThreadSafe,Initializable,JMSConnection(Code) | | JMSConnection properties container plus utilities.
Configuration:
<jndi-info>
<parameter name="" value=""/>
<jndi-info>
Other parameters:
| topic-factory | (required, no default) |
| topic | (required, no default) |
| ack-mode | ("dups") |
| durable-subscription-id | (optional) |
version:
CVS $Id: JMSConnectionImpl.java 433543 2006-08-22 06:22:54Z crossley $
author:
haulorg.apache.cocoon.components.jms.JMSConnectionManager |
| Method Summary | |
| public void | configure(Configuration conf)
| | public void | dispose()
| | public TopicPublisher | getPublisher()
Get a new TopicPublisher for this connection. | | public TopicSession | getSession()
Get the session associated with this connection. | | public void | initialize()
| | public synchronized void | registerListener(MessageListener listener, String selector)
Register a new TopicListener for this connection. | | protected Context | setupContext()
Get initial context. |
| ackMode | | protected int ackMode(Code) | | |
| connection | | protected TopicConnection connection(Code) | | |
| durableSubscriptionID | | protected String durableSubscriptionID(Code) | | |
| session | | protected TopicSession session(Code) | | |
| topic | | protected Topic topic(Code) | | |
| topicConnectionFactory | | protected TopicConnectionFactory topicConnectionFactory(Code) | | |
| configure | | public void configure(Configuration conf) throws ConfigurationException(Code) | | |
| dispose | | public void dispose()(Code) | | |
| getPublisher | | public TopicPublisher getPublisher() throws JMSException, NamingException(Code) | | Get a new TopicPublisher for this connection.
TopicPublisher
throws:
JMSException -
throws:
NamingException - |
| getSession | | public TopicSession getSession() throws NamingException, JMSException(Code) | | Get the session associated with this connection. This is needed for example to
create messages.
session associated with this connection
throws:
NamingException -
throws:
JMSException - |
| registerListener | | public synchronized void registerListener(MessageListener listener, String selector) throws CascadingException, JMSException, NamingException(Code) | | Register a new TopicListener for this connection.
Parameters:
listener -
Parameters:
selector - |
|
|