|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
java.lang.Objectorg.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.Referenceablepublic Reference getReference()
getReference in interface Referenceablepublic 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.QueueConnectionjavax.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.QueueConnectionjavax.jms.JMSException
public javax.jms.TopicSession createTopicSession(boolean transacted,
int acknowledgeMode)
throws javax.jms.JMSException
createTopicSession in interface javax.jms.TopicConnectionjavax.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.TopicConnectionjavax.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.Connectionjavax.jms.JMSExceptionpublic String getClientID() throws javax.jms.JMSException
getClientID in interface javax.jms.Connectionjavax.jms.JMSExceptionpublic void setClientID(String cID) throws javax.jms.JMSException
setClientID in interface javax.jms.Connectionjavax.jms.JMSException
public javax.jms.ConnectionMetaData getMetaData()
throws javax.jms.JMSException
getMetaData in interface javax.jms.Connectionjavax.jms.JMSException
public javax.jms.ExceptionListener getExceptionListener()
throws javax.jms.JMSException
getExceptionListener in interface javax.jms.Connectionjavax.jms.JMSException
public void setExceptionListener(javax.jms.ExceptionListener listener)
throws javax.jms.JMSException
setExceptionListener in interface javax.jms.Connectionjavax.jms.JMSException
public void start()
throws javax.jms.JMSException
start in interface javax.jms.Connectionjavax.jms.JMSException
public void stop()
throws javax.jms.JMSException
stop in interface javax.jms.Connectionjavax.jms.JMSException
public void close()
throws javax.jms.JMSException
close in interface javax.jms.Connectionjavax.jms.JMSExceptionpublic void closeSession(JmsSession session) throws javax.jms.JMSException
JmsSessionFactory
closeSession in interface JmsSessionFactoryjavax.jms.JMSException - for any errorpublic void addTemporaryQueue(javax.jms.TemporaryQueue temp)
JmsSessionFactory
addTemporaryQueue in interface JmsSessionFactorytemp - the temporary queuepublic void addTemporaryTopic(javax.jms.TemporaryTopic temp)
JmsSessionFactory
addTemporaryTopic in interface JmsSessionFactorytemp - the temporary topic
public 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.Connectionjavax.jms.JMSException
public javax.jms.Session createSession(boolean transacted,
int acknowledgeMode)
throws javax.jms.JMSException
createSession in interface javax.jms.Connectionjavax.jms.JMSExceptionprotected 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 | ||||||||||