org.outerj.daisy.jms.impl
Class JmsClientImpl
java.lang.Object
org.apache.avalon.framework.logger.AbstractLogEnabled
org.outerj.daisy.jms.impl.JmsClientImpl
- All Implemented Interfaces:
- org.apache.avalon.framework.activity.Disposable, org.apache.avalon.framework.activity.Initializable, org.apache.avalon.framework.configuration.Configurable, org.apache.avalon.framework.logger.LogEnabled, org.apache.avalon.framework.service.Serviceable, org.apache.avalon.framework.thread.ThreadSafe, org.outerj.daisy.jms.JmsClient
public class JmsClientImpl
- extends org.apache.avalon.framework.logger.AbstractLogEnabled
- implements org.outerj.daisy.jms.JmsClient, org.apache.avalon.framework.configuration.Configurable, org.apache.avalon.framework.activity.Initializable, org.apache.avalon.framework.activity.Disposable, org.apache.avalon.framework.thread.ThreadSafe, org.apache.avalon.framework.service.Serviceable
Constructor Summary |
JmsClientImpl()
|
JmsClientImpl(java.util.Properties contextProperties,
java.lang.String userName,
java.lang.String password,
java.lang.String clientId,
java.lang.String connectionFactoryName,
org.apache.avalon.framework.logger.Logger logger)
|
Methods inherited from class org.apache.avalon.framework.logger.AbstractLogEnabled |
enableLogging, getLogger, setupLogger, setupLogger, setupLogger |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JmsClientImpl
public JmsClientImpl()
JmsClientImpl
public JmsClientImpl(java.util.Properties contextProperties,
java.lang.String userName,
java.lang.String password,
java.lang.String clientId,
java.lang.String connectionFactoryName,
org.apache.avalon.framework.logger.Logger logger)
throws java.lang.Exception
- Parameters:
clientId
- the JMS client ID, should be unique for each client
- Throws:
java.lang.Exception
suspend
public boolean suspend(long msecs)
throws java.lang.InterruptedException
- Specified by:
suspend
in interface org.outerj.daisy.jms.JmsClient
- Throws:
java.lang.InterruptedException
resume
public void resume()
- Specified by:
resume
in interface org.outerj.daisy.jms.JmsClient
service
public void service(org.apache.avalon.framework.service.ServiceManager serviceManager)
throws org.apache.avalon.framework.service.ServiceException
- Specified by:
service
in interface org.apache.avalon.framework.service.Serviceable
- Throws:
org.apache.avalon.framework.service.ServiceException
configure
public void configure(org.apache.avalon.framework.configuration.Configuration configuration)
throws org.apache.avalon.framework.configuration.ConfigurationException
- Specified by:
configure
in interface org.apache.avalon.framework.configuration.Configurable
- Throws:
org.apache.avalon.framework.configuration.ConfigurationException
initialize
public void initialize()
throws java.lang.Exception
- Specified by:
initialize
in interface org.apache.avalon.framework.activity.Initializable
- Throws:
java.lang.Exception
initializeJmsConnection
protected void initializeJmsConnection(boolean failOnError)
throws java.lang.Exception
- Throws:
java.lang.Exception
dispose
public void dispose()
- Specified by:
dispose
in interface org.apache.avalon.framework.activity.Disposable
registerDurableTopicListener
public void registerDurableTopicListener(java.lang.String topicName,
java.lang.String subscriptionName,
javax.jms.MessageListener listener)
throws java.lang.Exception
- Specified by:
registerDurableTopicListener
in interface org.outerj.daisy.jms.JmsClient
- Throws:
java.lang.Exception
registerListener
public void registerListener(java.lang.String destinationName,
javax.jms.MessageListener listener)
throws java.lang.Exception
- Specified by:
registerListener
in interface org.outerj.daisy.jms.JmsClient
- Throws:
java.lang.Exception
unregisterListener
public void unregisterListener(javax.jms.MessageListener listener)
- Specified by:
unregisterListener
in interface org.outerj.daisy.jms.JmsClient
getSender
public org.outerj.daisy.jms.Sender getSender(java.lang.String destinationName)
- Specified by:
getSender
in interface org.outerj.daisy.jms.JmsClient
unregisterSender
public void unregisterSender(org.outerj.daisy.jms.Sender sender)
- Specified by:
unregisterSender
in interface org.outerj.daisy.jms.JmsClient
Copyright © -2012 . All Rights Reserved.