|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jboss.resource.adapter.jms.JmsSessionFactoryImpl
Implements the JMS Connection API and produces JmsSession
objects.
Created: Thu Mar 29 15:36:51 2001
Constructor Summary | |
JmsSessionFactoryImpl(javax.resource.spi.ManagedConnectionFactory mcf,
javax.resource.spi.ConnectionManager cm,
int type)
|
Method Summary | |
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()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public JmsSessionFactoryImpl(javax.resource.spi.ManagedConnectionFactory mcf, javax.resource.spi.ConnectionManager cm, int type)
Method Detail |
public void setReference(Reference reference)
setReference
in interface javax.resource.Referenceable
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
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
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |