org.outerj.daisy.jms.impl
Class JmsClientImpl

java.lang.Object
  extended byorg.apache.avalon.framework.logger.AbstractLogEnabled
      extended byorg.outerj.daisy.jms.impl.JmsClientImpl
All Implemented Interfaces:
org.apache.avalon.framework.configuration.Configurable, org.apache.avalon.framework.activity.Disposable, org.apache.avalon.framework.activity.Initializable, org.outerj.daisy.jms.JmsClient, org.apache.avalon.framework.logger.LogEnabled, org.apache.avalon.framework.thread.ThreadSafe

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


Constructor Summary
JmsClientImpl()
           
JmsClientImpl(java.util.Properties contextProperties, java.lang.String userName, java.lang.String password, java.lang.String topicConnectionFactoryName, java.lang.String queueConnectionFactoryName, org.apache.avalon.framework.logger.Logger logger)
           
 
Method Summary
 void configure(org.apache.avalon.framework.configuration.Configuration configuration)
           
 void dispose()
           
 org.outerj.daisy.jms.Sender getQueueSender(java.lang.String topicName)
           
 org.outerj.daisy.jms.Sender getTopicSender(java.lang.String topicName)
           
 void initialize()
           
protected  void initializeJmsQueueConnection(boolean failOnError)
           
protected  void initializeJmsTopicConnection(boolean failOnError)
           
 void registerDurableTopicListener(java.lang.String topicName, java.lang.String subscriptionName, javax.jms.MessageListener listener)
           
 void registerQueueListener(java.lang.String queueName, javax.jms.MessageListener listener)
           
 void registerTopicListener(java.lang.String topicName, javax.jms.MessageListener listener)
           
 void unregisterListener(javax.jms.MessageListener listener)
           
 void unregisterSender(org.outerj.daisy.jms.Sender sender)
           
 
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
 

Constructor Detail

JmsClientImpl

public JmsClientImpl()

JmsClientImpl

public JmsClientImpl(java.util.Properties contextProperties,
                     java.lang.String userName,
                     java.lang.String password,
                     java.lang.String topicConnectionFactoryName,
                     java.lang.String queueConnectionFactoryName,
                     org.apache.avalon.framework.logger.Logger logger)
              throws java.lang.Exception
Method Detail

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

initializeJmsTopicConnection

protected void initializeJmsTopicConnection(boolean failOnError)
                                     throws java.lang.Exception
Throws:
java.lang.Exception

initializeJmsQueueConnection

protected void initializeJmsQueueConnection(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

registerTopicListener

public void registerTopicListener(java.lang.String topicName,
                                  javax.jms.MessageListener listener)
                           throws java.lang.Exception
Specified by:
registerTopicListener in interface org.outerj.daisy.jms.JmsClient
Throws:
java.lang.Exception

registerQueueListener

public void registerQueueListener(java.lang.String queueName,
                                  javax.jms.MessageListener listener)
                           throws java.lang.Exception
Specified by:
registerQueueListener 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

getTopicSender

public org.outerj.daisy.jms.Sender getTopicSender(java.lang.String topicName)
Specified by:
getTopicSender in interface org.outerj.daisy.jms.JmsClient

getQueueSender

public org.outerj.daisy.jms.Sender getQueueSender(java.lang.String topicName)
Specified by:
getQueueSender 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 © -2005 . All Rights Reserved.