gov.nih.nci.caarray.services.util.jms
Class DefaultJMSMessageHandler

java.lang.Object
  extended by gov.nih.nci.caarray.services.util.jms.DefaultJMSMessageHandler
All Implemented Interfaces:
JMSMessageHandler

public class DefaultJMSMessageHandler
extends java.lang.Object
implements JMSMessageHandler

Author:
Joshua Phillips

Field Summary
static int DEFAULT_BATCH_SIZE
           
static long DEFAULT_FLUSH_INTERVAL
           
static java.lang.String DEFAULT_QUEUE_CONN_FACT
           
static java.lang.String DEFAULT_TOPIC_CONN_FACT
           
 
Method Summary
 javax.jms.ObjectMessage createQueueObjectMessage(java.lang.String queueName)
           
 javax.jms.ObjectMessage createTopicObjectMessage(java.lang.String topicName)
           
 void endQueueSession(java.lang.String queueName)
           
 void endTopicSession(java.lang.String queueName)
           
 void finalize()
           
 void flushAllQueues()
           
 void flushAllTopics()
           
 void flushQueue(java.lang.String queueName)
           
 int getBatchSize()
           
static DefaultJMSMessageHandler getInstance()
           
 java.util.Collection getQueueSessionNames()
           
 java.util.Collection getTopicSessionNames()
           
 void publish(java.lang.String topicName, javax.jms.Message msg)
           
 void send(java.lang.String queueName, javax.jms.Message msg)
           
 void send(java.lang.String queueName, javax.jms.Message msg, long waitTime)
           
 void setBatchSize(int b)
           
 void startQueueSession(java.lang.String queueName)
           
 void startQueueSession(java.lang.String queueName, java.lang.String connFactName)
           
 void startTopicSession(java.lang.String queueName)
           
 void startTopicSession(java.lang.String topicName, java.lang.String topicFactName)
           
 
Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

DEFAULT_QUEUE_CONN_FACT

public static final java.lang.String DEFAULT_QUEUE_CONN_FACT
See Also:
Constant Field Values

DEFAULT_TOPIC_CONN_FACT

public static final java.lang.String DEFAULT_TOPIC_CONN_FACT
See Also:
Constant Field Values

DEFAULT_BATCH_SIZE

public static int DEFAULT_BATCH_SIZE

DEFAULT_FLUSH_INTERVAL

public static long DEFAULT_FLUSH_INTERVAL
Method Detail

getInstance

public static DefaultJMSMessageHandler getInstance()

startQueueSession

public void startQueueSession(java.lang.String queueName)
                       throws javax.jms.JMSException,
                              ServiceLookupException
Specified by:
startQueueSession in interface JMSMessageHandler
Throws:
javax.jms.JMSException
ServiceLookupException

startQueueSession

public void startQueueSession(java.lang.String queueName,
                              java.lang.String connFactName)
                       throws javax.jms.JMSException,
                              ServiceLookupException
Specified by:
startQueueSession in interface JMSMessageHandler
Throws:
javax.jms.JMSException
ServiceLookupException

startTopicSession

public void startTopicSession(java.lang.String queueName)
                       throws javax.jms.JMSException
Specified by:
startTopicSession in interface JMSMessageHandler
Throws:
javax.jms.JMSException

startTopicSession

public void startTopicSession(java.lang.String topicName,
                              java.lang.String topicFactName)
                       throws javax.jms.JMSException
Specified by:
startTopicSession in interface JMSMessageHandler
Throws:
javax.jms.JMSException

send

public void send(java.lang.String queueName,
                 javax.jms.Message msg,
                 long waitTime)
          throws javax.jms.JMSException
Specified by:
send in interface JMSMessageHandler
Throws:
javax.jms.JMSException

flushQueue

public void flushQueue(java.lang.String queueName)
                throws javax.jms.JMSException
Throws:
javax.jms.JMSException

flushAllQueues

public void flushAllQueues()
                    throws javax.jms.JMSException
Throws:
javax.jms.JMSException

getBatchSize

public int getBatchSize()
Returns:

setBatchSize

public void setBatchSize(int b)

publish

public void publish(java.lang.String topicName,
                    javax.jms.Message msg)
             throws javax.jms.JMSException
Specified by:
publish in interface JMSMessageHandler
Throws:
javax.jms.JMSException

finalize

public void finalize()
Overrides:
finalize in class java.lang.Object

flushAllTopics

public void flushAllTopics()

endQueueSession

public void endQueueSession(java.lang.String queueName)
                     throws javax.jms.JMSException
Specified by:
endQueueSession in interface JMSMessageHandler
Throws:
javax.jms.JMSException

getQueueSessionNames

public java.util.Collection getQueueSessionNames()
Specified by:
getQueueSessionNames in interface JMSMessageHandler

getTopicSessionNames

public java.util.Collection getTopicSessionNames()
Specified by:
getTopicSessionNames in interface JMSMessageHandler

endTopicSession

public void endTopicSession(java.lang.String queueName)
                     throws javax.jms.JMSException
Specified by:
endTopicSession in interface JMSMessageHandler
Throws:
javax.jms.JMSException

createQueueObjectMessage

public javax.jms.ObjectMessage createQueueObjectMessage(java.lang.String queueName)
                                                 throws javax.jms.JMSException
Specified by:
createQueueObjectMessage in interface JMSMessageHandler
Throws:
javax.jms.JMSException

createTopicObjectMessage

public javax.jms.ObjectMessage createTopicObjectMessage(java.lang.String topicName)
                                                 throws javax.jms.JMSException
Specified by:
createTopicObjectMessage in interface JMSMessageHandler
Throws:
javax.jms.JMSException

send

public void send(java.lang.String queueName,
                 javax.jms.Message msg)
          throws javax.jms.JMSException
Specified by:
send in interface JMSMessageHandler
Throws:
javax.jms.JMSException