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 LBMConnection

java.lang.Object
  extended by com.latencybusters.jms.LBMConnection
All Implemented Interfaces:
javax.jms.Connection
Direct Known Subclasses:
LBMQueueConnection, LBMTopicConnection
public class LBMConnection
extends java.lang.Object
implements javax.jms.Connection

Field Summary
protected  boolean allowClientIdChange
           
protected  java.lang.String cfName
           
static int CLOSED
           
protected  com.latencybusters.lbm.LBMEventQueue evq
           
static int INIT
           
protected  com.latencybusters.lbm.LBMContext myContext
           
static int OPEN
           
protected  java.util.ArrayList<NameValue> props
           
protected  int running
           
protected  java.util.Vector<LBMSession> sessionList
           
static int STOPPED
           
 
Constructor Summary
LBMConnection()
           
LBMConnection(com.latencybusters.lbm.LBMContext myContext, java.util.ArrayList<NameValue> props, boolean allowClientIdChange, java.lang.String clientID, com.latencybusters.lbm.LBMEventQueue evq, java.lang.String cfName, com.latencybusters.lbm.LBMContextAttributes qbContextAttributes)
           
 
Method Summary
 void addSource(java.lang.String topic, com.latencybusters.lbm.LBMSource source, java.lang.String type, com.latencybusters.lbm.LBMSourceEventCallback cb)
           
 void close()
           
 int closeSource(java.lang.String topic)
           
 javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Destination destination, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)
           
 javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic, java.lang.String subscriptionName, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)
           
 javax.jms.Session createSession(boolean transacted, int acknowledgeMode)
           
 com.latencybusters.lbm.LBMConfigOption[] dumpAttributeList()
           
protected  void finalize()
           
static void forwardException(java.lang.Exception ex)
          This is an internal Method.
 java.lang.String getClientID()
           
 java.lang.String getDurableName(java.lang.String name)
           
 java.util.Vector getDurables()
           
 javax.jms.ExceptionListener getExceptionListener()
           
 javax.jms.ConnectionMetaData getMetaData()
           
 com.latencybusters.jms.LBMCachedSourceAndCallback getSource(java.lang.String topic, java.lang.String type)
           
protected  void logContextConfigOptions(com.latencybusters.lbm.LBMConfigOption[] options)
           
 void setClientID(java.lang.String clientID)
           
 void setExceptionListener(javax.jms.ExceptionListener listener)
           
static void showNoOpException()
          This is an internal Method.
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

INIT

public static int INIT

OPEN

public static int OPEN

CLOSED

public static int CLOSED

STOPPED

public static int STOPPED

myContext

protected com.latencybusters.lbm.LBMContext myContext

evq

protected com.latencybusters.lbm.LBMEventQueue evq

sessionList

protected java.util.Vector<LBMSession> sessionList

props

protected java.util.ArrayList<NameValue> props

running

protected int running

allowClientIdChange

protected boolean allowClientIdChange

cfName

protected java.lang.String cfName
Constructor Detail

LBMConnection

public LBMConnection()

LBMConnection

public LBMConnection(com.latencybusters.lbm.LBMContext myContext,
                     java.util.ArrayList<NameValue> props,
                     boolean allowClientIdChange,
                     java.lang.String clientID,
                     com.latencybusters.lbm.LBMEventQueue evq,
                     java.lang.String cfName,
                     com.latencybusters.lbm.LBMContextAttributes qbContextAttributes)
Method Detail

createSession

public javax.jms.Session createSession(boolean transacted,
                                       int acknowledgeMode)
                                throws javax.jms.JMSException
Specified by:
createSession in interface javax.jms.Connection
Throws:
javax.jms.JMSException

getClientID

public java.lang.String getClientID()
                             throws javax.jms.JMSException
Specified by:
getClientID in interface javax.jms.Connection
Throws:
javax.jms.JMSException

setClientID

public void setClientID(java.lang.String clientID)
                 throws javax.jms.JMSException
Specified by:
setClientID in interface javax.jms.Connection
Throws:
javax.jms.JMSException

getMetaData

public javax.jms.ConnectionMetaData getMetaData()
                                         throws javax.jms.JMSException
Specified by:
getMetaData in interface javax.jms.Connection
Throws:
javax.jms.JMSException

getExceptionListener

public javax.jms.ExceptionListener getExceptionListener()
                                                 throws javax.jms.JMSException
Specified by:
getExceptionListener in interface javax.jms.Connection
Throws:
javax.jms.JMSException

setExceptionListener

public void setExceptionListener(javax.jms.ExceptionListener listener)
                          throws javax.jms.JMSException
Specified by:
setExceptionListener in interface javax.jms.Connection
Throws:
javax.jms.JMSException

start

public void start()
           throws javax.jms.JMSException
Specified by:
start in interface javax.jms.Connection
Throws:
javax.jms.JMSException

stop

public void stop()
          throws javax.jms.JMSException
Specified by:
stop in interface javax.jms.Connection
Throws:
javax.jms.JMSException

close

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

createConnectionConsumer

public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Destination destination,
                                                             java.lang.String messageSelector,
                                                             javax.jms.ServerSessionPool sessionPool,
                                                             int maxMessages)
                                                      throws javax.jms.JMSException
Specified by:
createConnectionConsumer in interface javax.jms.Connection
Throws:
javax.jms.JMSException

createDurableConnectionConsumer

public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic,
                                                                    java.lang.String subscriptionName,
                                                                    java.lang.String messageSelector,
                                                                    javax.jms.ServerSessionPool sessionPool,
                                                                    int maxMessages)
                                                             throws javax.jms.JMSException
Specified by:
createDurableConnectionConsumer in interface javax.jms.Connection
Throws:
javax.jms.JMSException

forwardException

public static void forwardException(java.lang.Exception ex)
                             throws javax.jms.JMSException
This is an internal Method.

Throws:
javax.jms.JMSException

showNoOpException

public static void showNoOpException()
                              throws javax.jms.JMSException
This is an internal Method.

Throws:
javax.jms.JMSException

getDurables

public java.util.Vector getDurables()

getDurableName

public java.lang.String getDurableName(java.lang.String name)

finalize

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

logContextConfigOptions

protected void logContextConfigOptions(com.latencybusters.lbm.LBMConfigOption[] options)

dumpAttributeList

public com.latencybusters.lbm.LBMConfigOption[] dumpAttributeList()

addSource

public void addSource(java.lang.String topic,
                      com.latencybusters.lbm.LBMSource source,
                      java.lang.String type,
                      com.latencybusters.lbm.LBMSourceEventCallback cb)

getSource

public com.latencybusters.jms.LBMCachedSourceAndCallback getSource(java.lang.String topic,
                                                                   java.lang.String type)
                                                            throws javax.jms.JMSException
Throws:
javax.jms.JMSException

closeSource

public int closeSource(java.lang.String topic)
                throws javax.jms.JMSException
Throws:
javax.jms.JMSException
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.