org.outerj.daisy.jms.impl
Class JmsClientImpl

java.lang.Object
  extended by org.apache.avalon.framework.logger.AbstractLogEnabled
      extended by 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)
           
 
Method Summary
 void configure(org.apache.avalon.framework.configuration.Configuration configuration)
           
 void dispose()
           
 org.outerj.daisy.jms.Sender getSender(java.lang.String destinationName)
           
 void initialize()
           
protected  void initializeJmsConnection(boolean failOnError)
           
 void registerDurableTopicListener(java.lang.String topicName, java.lang.String subscriptionName, javax.jms.MessageListener listener)
           
 void registerListener(java.lang.String destinationName, javax.jms.MessageListener listener)
           
 void resume()
           
 void service(org.apache.avalon.framework.service.ServiceManager serviceManager)
           
 boolean suspend(long msecs)
           
 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 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
Method Detail

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.