public class JmsSessionFactoryImpl extends Object implements JmsSessionFactory, javax.resource.Referenceable
JmsSession
objects.ISE
Constructor and Description |
---|
JmsSessionFactoryImpl(javax.resource.spi.ManagedConnectionFactory mcf,
javax.resource.spi.ConnectionManager cm,
int type) |
Modifier and Type | Method and Description |
---|---|
void |
addTemporaryQueue(javax.jms.TemporaryQueue temp)
Add a temporary queue
|
void |
addTemporaryTopic(javax.jms.TemporaryTopic temp)
Add a temporary topic
|
protected JmsSession |
allocateConnection(boolean transacted,
int acknowledgeMode,
int sessionType) |
protected void |
checkClosed() |
void |
close() |
void |
closeSession(JmsSession session)
Notification that a session is closed
|
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Destination destination,
javax.jms.ServerSessionPool pool,
int maxMessages) |
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Destination destination,
String name,
javax.jms.ServerSessionPool pool,
int maxMessages) |
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Queue queue,
String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages) |
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Topic topic,
String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages) |
javax.jms.ConnectionConsumer |
createDurableConnectionConsumer(javax.jms.Topic topic,
String subscriptionName,
String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages) |
javax.jms.QueueSession |
createQueueSession(boolean transacted,
int acknowledgeMode) |
javax.jms.Session |
createSession(boolean transacted,
int acknowledgeMode) |
javax.jms.TopicSession |
createTopicSession(boolean transacted,
int acknowledgeMode) |
String |
getClientID() |
javax.jms.ExceptionListener |
getExceptionListener() |
javax.jms.ConnectionMetaData |
getMetaData() |
Reference |
getReference() |
void |
setClientID(String cID) |
void |
setExceptionListener(javax.jms.ExceptionListener listener) |
void |
setPassword(String password) |
void |
setReference(Reference reference) |
void |
setUserName(String name) |
void |
start() |
void |
stop() |
public JmsSessionFactoryImpl(javax.resource.spi.ManagedConnectionFactory mcf, javax.resource.spi.ConnectionManager cm, int type)
public void setReference(Reference reference)
public Reference getReference()
getReference
in interface Referenceable
public void setUserName(String name)
public void setPassword(String password)
public javax.jms.QueueSession createQueueSession(boolean transacted, int acknowledgeMode) throws javax.jms.JMSException
createQueueSession
in interface javax.jms.QueueConnection
javax.jms.JMSException
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue queue, String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages) throws javax.jms.JMSException
createConnectionConsumer
in interface javax.jms.QueueConnection
javax.jms.JMSException
public javax.jms.TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws javax.jms.JMSException
createTopicSession
in interface javax.jms.TopicConnection
javax.jms.JMSException
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Topic topic, String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages) throws javax.jms.JMSException
createConnectionConsumer
in interface javax.jms.TopicConnection
javax.jms.JMSException
public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic, String subscriptionName, String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages) throws javax.jms.JMSException
createDurableConnectionConsumer
in interface javax.jms.Connection
createDurableConnectionConsumer
in interface javax.jms.TopicConnection
javax.jms.JMSException
public String getClientID() throws javax.jms.JMSException
getClientID
in interface javax.jms.Connection
javax.jms.JMSException
public void setClientID(String cID) throws javax.jms.JMSException
setClientID
in interface javax.jms.Connection
javax.jms.JMSException
public javax.jms.ConnectionMetaData getMetaData() throws javax.jms.JMSException
getMetaData
in interface javax.jms.Connection
javax.jms.JMSException
public javax.jms.ExceptionListener getExceptionListener() throws javax.jms.JMSException
getExceptionListener
in interface javax.jms.Connection
javax.jms.JMSException
public void setExceptionListener(javax.jms.ExceptionListener listener) throws javax.jms.JMSException
setExceptionListener
in interface javax.jms.Connection
javax.jms.JMSException
public void start() throws javax.jms.JMSException
start
in interface javax.jms.Connection
javax.jms.JMSException
public void stop() throws javax.jms.JMSException
stop
in interface javax.jms.Connection
javax.jms.JMSException
public void close() throws javax.jms.JMSException
close
in interface javax.jms.Connection
javax.jms.JMSException
public void closeSession(JmsSession session) throws javax.jms.JMSException
JmsSessionFactory
closeSession
in interface JmsSessionFactory
javax.jms.JMSException
- for any errorpublic void addTemporaryQueue(javax.jms.TemporaryQueue temp)
JmsSessionFactory
addTemporaryQueue
in interface JmsSessionFactory
temp
- the temporary queuepublic void addTemporaryTopic(javax.jms.TemporaryTopic temp)
JmsSessionFactory
addTemporaryTopic
in interface JmsSessionFactory
temp
- the temporary topicpublic javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Destination destination, javax.jms.ServerSessionPool pool, int maxMessages) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Destination destination, String name, javax.jms.ServerSessionPool pool, int maxMessages) throws javax.jms.JMSException
createConnectionConsumer
in interface javax.jms.Connection
javax.jms.JMSException
public javax.jms.Session createSession(boolean transacted, int acknowledgeMode) throws javax.jms.JMSException
createSession
in interface javax.jms.Connection
javax.jms.JMSException
protected JmsSession allocateConnection(boolean transacted, int acknowledgeMode, int sessionType) throws javax.jms.JMSException
javax.jms.JMSException
protected void checkClosed() throws javax.jms.IllegalStateException
javax.jms.IllegalStateException
Copyright © 2017 JBoss by Red Hat. All rights reserved.