Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

com.latencybusters.jms
Class LBMSession

java.lang.Object
  extended by com.latencybusters.jms.LBMSession
All Implemented Interfaces:
java.lang.Runnable, javax.jms.Session
Direct Known Subclasses:
LBMQueueSession, LBMTopicSession
public class LBMSession
extends java.lang.Object
implements javax.jms.Session

Field Summary
protected  int acknowledgeMode
           
protected  boolean active
           
protected  java.lang.String cfName
           
protected  LBMConnection connection
           
protected  java.util.Vector consumerList
           
protected  com.latencybusters.lbm.LBMEventQueue evq
           
protected  javax.jms.MessageListener listener
           
protected  com.latencybusters.lbm.LBMContext myContext
           
protected  boolean open
           
protected  java.util.Vector producerList
           
protected  java.util.ArrayList<NameValue> props
           
 boolean transacted
           
protected  boolean usingSessionIds
           
 
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
 
Constructor Summary
LBMSession()
           
LBMSession(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
 void close()
           
 void commit()
           
 javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue)
          This method has not been implemented.
 javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue, java.lang.String messageSelector)
           
 javax.jms.BytesMessage createBytesMessage()
           
 javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination)
           
 javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination, java.lang.String messageSelector)
          This method has not been implemented.
 javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination, java.lang.String messageSelector, boolean NoLocal)
           
 javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, java.lang.String name)
           
 javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, java.lang.String name, java.lang.String messageSelector, boolean noLocal)
           
 javax.jms.MapMessage createMapMessage()
           
 javax.jms.Message createMessage()
           
 javax.jms.ObjectMessage createObjectMessage()
           
 javax.jms.ObjectMessage createObjectMessage(java.io.Serializable object)
           
 javax.jms.MessageProducer createProducer(javax.jms.Destination destination)
           
 javax.jms.Queue createQueue(java.lang.String queueName)
           
 javax.jms.StreamMessage createStreamMessage()
           
 javax.jms.TemporaryQueue createTemporaryQueue()
           
 javax.jms.TemporaryTopic createTemporaryTopic()
           
 javax.jms.TextMessage createTextMessage()
           
 javax.jms.TextMessage createTextMessage(java.lang.String text)
           
 javax.jms.Topic createTopic(java.lang.String topicName)
           
protected  void dispatch(javax.jms.Message m)
           
protected  void flush(LBMDestination dest)
           
 int getAcknowledgeMode()
           
 LBMConnection getConnection()
           
 javax.jms.MessageListener getMessageListener()
           
 boolean getTransacted()
           
 boolean isQueueEmpty(javax.jms.MessageConsumer consumer)
           
 boolean isSerializerAlive()
           
 void recover()
          This method has not been implemented.
 void removeDurable(java.lang.String name)
           
 void rollback()
           
 void run()
           
 void setMessageListener(javax.jms.MessageListener listener)
           
 void start()
           
 void startSerializer()
           
 void stop()
           
 void unsubscribe(java.lang.String name)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

myContext

protected com.latencybusters.lbm.LBMContext myContext

evq

protected com.latencybusters.lbm.LBMEventQueue evq

props

protected java.util.ArrayList<NameValue> props

acknowledgeMode

protected int acknowledgeMode

consumerList

protected java.util.Vector consumerList

producerList

protected java.util.Vector producerList

active

protected boolean active

listener

protected javax.jms.MessageListener listener

connection

protected LBMConnection connection

open

protected boolean open

transacted

public boolean transacted

cfName

protected java.lang.String cfName

usingSessionIds

protected boolean usingSessionIds
Constructor Detail

LBMSession

public LBMSession()

LBMSession

public LBMSession(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

dispatch

protected void dispatch(javax.jms.Message m)

isQueueEmpty

public boolean isQueueEmpty(javax.jms.MessageConsumer consumer)

isSerializerAlive

public boolean isSerializerAlive()

flush

protected void flush(LBMDestination dest)

start

public void start()
           throws javax.jms.IllegalStateException,
                  javax.jms.JMSException
Throws:
javax.jms.IllegalStateException
javax.jms.JMSException

stop

public void stop()
          throws javax.jms.IllegalStateException,
                 javax.jms.JMSException
Throws:
javax.jms.IllegalStateException
javax.jms.JMSException

createBytesMessage

public javax.jms.BytesMessage createBytesMessage()
                                          throws javax.jms.IllegalStateException
Specified by:
createBytesMessage in interface javax.jms.Session
Throws:
javax.jms.IllegalStateException

createMapMessage

public javax.jms.MapMessage createMapMessage()
                                      throws javax.jms.IllegalStateException
Specified by:
createMapMessage in interface javax.jms.Session
Throws:
javax.jms.IllegalStateException

createMessage

public javax.jms.Message createMessage()
                                throws javax.jms.IllegalStateException
Specified by:
createMessage in interface javax.jms.Session
Throws:
javax.jms.IllegalStateException

createObjectMessage

public javax.jms.ObjectMessage createObjectMessage()
                                            throws javax.jms.IllegalStateException
Specified by:
createObjectMessage in interface javax.jms.Session
Throws:
javax.jms.IllegalStateException

createObjectMessage

public javax.jms.ObjectMessage createObjectMessage(java.io.Serializable object)
                                            throws javax.jms.IllegalStateException
Specified by:
createObjectMessage in interface javax.jms.Session
Throws:
javax.jms.IllegalStateException

createStreamMessage

public javax.jms.StreamMessage createStreamMessage()
                                            throws javax.jms.JMSException
Specified by:
createStreamMessage in interface javax.jms.Session
Throws:
javax.jms.JMSException

createTextMessage

public javax.jms.TextMessage createTextMessage()
                                        throws javax.jms.IllegalStateException
Specified by:
createTextMessage in interface javax.jms.Session
Throws:
javax.jms.IllegalStateException

createTextMessage

public javax.jms.TextMessage createTextMessage(java.lang.String text)
                                        throws javax.jms.IllegalStateException
Specified by:
createTextMessage in interface javax.jms.Session
Throws:
javax.jms.IllegalStateException

getTransacted

public boolean getTransacted()
                      throws javax.jms.IllegalStateException
Specified by:
getTransacted in interface javax.jms.Session
Throws:
javax.jms.IllegalStateException

getAcknowledgeMode

public int getAcknowledgeMode()
                       throws javax.jms.IllegalStateException
Specified by:
getAcknowledgeMode in interface javax.jms.Session
Throws:
javax.jms.IllegalStateException

commit

public void commit()
            throws javax.jms.JMSException
Specified by:
commit in interface javax.jms.Session
Throws:
javax.jms.JMSException

rollback

public void rollback()
              throws javax.jms.JMSException
Specified by:
rollback in interface javax.jms.Session
Throws:
javax.jms.JMSException

close

public void close()
           throws javax.jms.JMSException
Specified by:
close in interface javax.jms.Session
Throws:
javax.jms.JMSException

recover

public void recover()
             throws javax.jms.JMSException
This method has not been implemented.

Specified by:
recover in interface javax.jms.Session
Throws:
javax.jms.JMSException

getMessageListener

public javax.jms.MessageListener getMessageListener()
                                             throws javax.jms.IllegalStateException
Specified by:
getMessageListener in interface javax.jms.Session
Throws:
javax.jms.IllegalStateException

setMessageListener

public void setMessageListener(javax.jms.MessageListener listener)
                        throws javax.jms.IllegalStateException
Specified by:
setMessageListener in interface javax.jms.Session
Throws:
javax.jms.IllegalStateException

run

public void run()
Specified by:
run in interface java.lang.Runnable
Specified by:
run in interface javax.jms.Session

createProducer

public javax.jms.MessageProducer createProducer(javax.jms.Destination destination)
                                         throws javax.jms.IllegalStateException,
                                                javax.jms.JMSException
Specified by:
createProducer in interface javax.jms.Session
Throws:
javax.jms.IllegalStateException
javax.jms.JMSException

createConsumer

public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination)
                                         throws javax.jms.IllegalStateException,
                                                javax.jms.JMSException
Specified by:
createConsumer in interface javax.jms.Session
Throws:
javax.jms.IllegalStateException
javax.jms.JMSException

createConsumer

public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination,
                                                java.lang.String messageSelector)
                                         throws javax.jms.JMSException
This method has not been implemented.

Specified by:
createConsumer in interface javax.jms.Session
Throws:
javax.jms.JMSException

createConsumer

public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination,
                                                java.lang.String messageSelector,
                                                boolean NoLocal)
                                         throws javax.jms.JMSException
Specified by:
createConsumer in interface javax.jms.Session
Throws:
javax.jms.JMSException

createQueue

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

createTopic

public javax.jms.Topic createTopic(java.lang.String topicName)
                            throws javax.jms.IllegalStateException
Specified by:
createTopic in interface javax.jms.Session
Throws:
javax.jms.IllegalStateException

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                         java.lang.String name)
                                                  throws javax.jms.JMSException
Specified by:
createDurableSubscriber in interface javax.jms.Session
Throws:
javax.jms.JMSException

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                         java.lang.String name,
                                                         java.lang.String messageSelector,
                                                         boolean noLocal)
                                                  throws javax.jms.JMSException
Specified by:
createDurableSubscriber in interface javax.jms.Session
Throws:
javax.jms.JMSException

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue)
                                     throws javax.jms.JMSException
This method has not been implemented.

Specified by:
createBrowser in interface javax.jms.Session
Throws:
javax.jms.JMSException

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue,
                                            java.lang.String messageSelector)
                                     throws javax.jms.JMSException
Specified by:
createBrowser in interface javax.jms.Session
Throws:
javax.jms.JMSException

createTemporaryQueue

public javax.jms.TemporaryQueue createTemporaryQueue()
                                              throws javax.jms.JMSException
Specified by:
createTemporaryQueue in interface javax.jms.Session
Throws:
javax.jms.JMSException

createTemporaryTopic

public javax.jms.TemporaryTopic createTemporaryTopic()
                                              throws javax.jms.JMSException
Specified by:
createTemporaryTopic in interface javax.jms.Session
Throws:
javax.jms.JMSException

unsubscribe

public void unsubscribe(java.lang.String name)
                 throws javax.jms.JMSException
Specified by:
unsubscribe in interface javax.jms.Session
Throws:
javax.jms.JMSException

removeDurable

public void removeDurable(java.lang.String name)

startSerializer

public void startSerializer()

getConnection

public LBMConnection getConnection()
Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD
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.