public class MJmsSession extends MSession
m_app, m_defaultTimeout, m_deliveryMode, m_transactionLevel
m_registry
Constructor and Description |
---|
MJmsSession(MApp app,
java.lang.String name,
MJmsConnectionSpec connectionSpec)
Create a TIBCO Enterprise for JMS connection to access network for communication
between components for example, between a publisher and a subscriber.
|
Modifier and Type | Method and Description |
---|---|
void |
add(java.lang.Object p_consumer) |
javax.jms.QueueSession |
createQueueSession(int acknowledgeMode) |
javax.jms.Session |
createSession(int acknowledgeMode) |
javax.jms.TopicSession |
createTopicSession(int acknowledgeMode) |
void |
destroy() |
int |
getSubscriberQueueSize() |
java.lang.Object |
jndiLookup(java.lang.String lookup) |
boolean |
nextEvent(long p_timeout)
Call the next event for this
MSession instance. |
boolean |
processEvent() |
boolean |
processEvent(long p_timeout) |
void |
remove(java.lang.Object p_consumer) |
static void |
setSession(javax.jms.Session session)
Deprecated.
|
getApp, getDaemon, getDeliveryMode, getHost, getNetwork, getPort, getProtocol, getService, getSessionName, getTibrvQueue, getTibrvTransport, nextEvent
activate, deactivate, getComponentRegistry, getName, getStatus, isActivated, remove
public MJmsSession(MApp app, java.lang.String name, MJmsConnectionSpec connectionSpec) throws MException
app
- The MApp
with which this instance session is associated.name
- The name of the session to create (to be used in the component registry as a unique key).connectionSpec
- MJmsConnectionSpec
for this session.MException
public static void setSession(javax.jms.Session session)
public javax.jms.Session createSession(int acknowledgeMode) throws javax.jms.JMSException, javax.naming.NamingException
javax.jms.JMSException
javax.naming.NamingException
public javax.jms.TopicSession createTopicSession(int acknowledgeMode) throws javax.jms.JMSException, javax.naming.NamingException
javax.jms.JMSException
javax.naming.NamingException
public javax.jms.QueueSession createQueueSession(int acknowledgeMode) throws javax.jms.JMSException, javax.naming.NamingException
javax.jms.JMSException
javax.naming.NamingException
public java.lang.Object jndiLookup(java.lang.String lookup) throws javax.naming.NamingException
javax.naming.NamingException
public boolean nextEvent(long p_timeout) throws MException
MSession
MSession
instance.
This contrasts with MApp.nextEvent(long)
,
which calls the next event for this application instance.nextEvent
in class MSession
p_timeout
- Time limit in milliseconds.
If the next event cannot be executed within the time specified by this parameter, the method returns.
If, for example, you set the time limit to 10 milliseconds and no event occurs in 10 milliseconds (or has occurred in the past and has not yet been reported), then this method terminates and no exception is thrown.
MException
MApp.nextEvent(long)
public boolean processEvent(long p_timeout) throws MException
MException
public boolean processEvent() throws MException
MException
public void add(java.lang.Object p_consumer)
public void remove(java.lang.Object p_consumer)
public int getSubscriberQueueSize()
public void destroy()