com.latencybusters.jms.queue
Class LBMQueueSession

java.lang.Object
  extended by com.latencybusters.jms.LBMSession
      extended by com.latencybusters.jms.queue.LBMQueueSession
All Implemented Interfaces:
java.lang.Runnable, javax.jms.QueueSession, javax.jms.Session

public class LBMQueueSession
extends LBMSession
implements javax.jms.QueueSession


Field Summary
 
Fields inherited from class com.latencybusters.jms.LBMSession
acknowledgeMode, active, cfName, connection, consumerList, evq, listener, myContext, open, producerList, props, transacted, usingSessionIds
 
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
 
Constructor Summary
LBMQueueSession(LBMConnection connection, com.latencybusters.lbm.LBMContext myContext, com.latencybusters.lbm.LBMEventQueue evq, java.util.ArrayList<NameValue> props, int acknowledgeMode, boolean transacted, java.lang.String cfName)
          This is an internal Method.
 
Method Summary
 javax.jms.Queue createQueue(java.lang.String queueName)
           
 javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue)
           
 javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue, java.lang.String messageSelector)
           
 javax.jms.QueueSender createSender(javax.jms.Queue queue)
           
 
Methods inherited from class com.latencybusters.jms.LBMSession
close, commit, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTemporaryQueue, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, dispatch, flush, getAcknowledgeMode, getConnection, getMessageListener, getTransacted, isQueueEmpty, isSerializerAlive, recover, removeDurable, rollback, run, setMessageListener, start, startSerializer, stop, unsubscribe
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface javax.jms.QueueSession
createBrowser, createBrowser, createTemporaryQueue
 
Methods inherited from interface javax.jms.Session
close, commit, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getAcknowledgeMode, getMessageListener, getTransacted, recover, rollback, run, setMessageListener, unsubscribe
 

Constructor Detail

LBMQueueSession

public LBMQueueSession(LBMConnection connection,
                       com.latencybusters.lbm.LBMContext myContext,
                       com.latencybusters.lbm.LBMEventQueue evq,
                       java.util.ArrayList<NameValue> props,
                       int acknowledgeMode,
                       boolean transacted,
                       java.lang.String cfName)
This is an internal Method.

Method Detail

createQueue

public javax.jms.Queue createQueue(java.lang.String queueName)
                            throws javax.jms.IllegalStateException
Specified by:
createQueue in interface javax.jms.QueueSession
Specified by:
createQueue in interface javax.jms.Session
Overrides:
createQueue in class LBMSession
Throws:
javax.jms.IllegalStateException

createReceiver

public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue)
                                       throws javax.jms.IllegalStateException,
                                              javax.jms.JMSException
Specified by:
createReceiver in interface javax.jms.QueueSession
Throws:
javax.jms.IllegalStateException
javax.jms.JMSException

createReceiver

public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue,
                                              java.lang.String messageSelector)
                                       throws javax.jms.IllegalStateException,
                                              javax.jms.JMSException
Specified by:
createReceiver in interface javax.jms.QueueSession
Throws:
javax.jms.IllegalStateException
javax.jms.JMSException

createSender

public javax.jms.QueueSender createSender(javax.jms.Queue queue)
                                   throws javax.jms.IllegalStateException,
                                          javax.jms.JMSException
Specified by:
createSender in interface javax.jms.QueueSession
Throws:
javax.jms.IllegalStateException
javax.jms.JMSException


All of the documentation and software included in this and any other Informatica, Inc. "Ultra Messaging" Release is Copyright (C) 2004-2014, Informatica Corporation. All rights reserved. Redistribution and use in source and binary forms, with or without modification, are permitted only as covered by the terms of a valid software license agreement with Informatica Inc. Copyright © 2004-2014, Informatica, Inc. All Rights Reserved.