站内搜索: 请输入搜索关键词
当前页面: 在线文档首页 > JBoss 4.0.1 sp1 connector API Documentation 英文版文档

JmsSessionFactoryImpl (JBoss Connector API) - JBoss 4.0.1 sp1 connector API Documentation 英文版文档


org.jboss.resource.adapter.jms
Class JmsSessionFactoryImpl

java.lang.Object
  extended byorg.jboss.resource.adapter.jms.JmsSessionFactoryImpl
All Implemented Interfaces:
javax.jms.Connection, JmsSessionFactory, javax.jms.QueueConnection, Referenceable, javax.resource.Referenceable, javax.jms.TopicConnection

public class JmsSessionFactoryImpl
extends Object
implements JmsSessionFactory, javax.resource.Referenceable

Implements the JMS Connection API and produces JmsSession objects.

Created: Thu Mar 29 15:36:51 2001

Version:
$Revision: 1.11 $
Author:
Peter Antman., Jason Dillon

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

JmsSessionFactoryImpl

public JmsSessionFactoryImpl(javax.resource.spi.ManagedConnectionFactory mcf,
                             javax.resource.spi.ConnectionManager cm,
                             int type)
Method Detail

setReference

public void setReference(Reference reference)
Specified by:
setReference in interface javax.resource.Referenceable

getReference

public Reference getReference()
Specified by:
getReference in interface Referenceable

setUserName

public void setUserName(String name)

setPassword

public void setPassword(String password)

createQueueSession

public javax.jms.QueueSession createQueueSession(boolean transacted,
                                                 int acknowledgeMode)
                                          throws javax.jms.JMSException
Specified by:
createQueueSession in interface javax.jms.QueueConnection
Throws:
javax.jms.JMSException

createConnectionConsumer

public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue queue,
                                                             String messageSelector,
                                                             javax.jms.ServerSessionPool sessionPool,
                                                             int maxMessages)
                                                      throws javax.jms.JMSException
Specified by:
createConnectionConsumer in interface javax.jms.QueueConnection
Throws:
javax.jms.JMSException

createTopicSession

public javax.jms.TopicSession createTopicSession(boolean transacted,
                                                 int acknowledgeMode)
                                          throws javax.jms.JMSException
Specified by:
createTopicSession in interface javax.jms.TopicConnection
Throws:
javax.jms.JMSException

createConnectionConsumer

public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Topic topic,
                                                             String messageSelector,
                                                             javax.jms.ServerSessionPool sessionPool,
                                                             int maxMessages)
                                                      throws javax.jms.JMSException
Specified by:
createConnectionConsumer in interface javax.jms.TopicConnection
Throws:
javax.jms.JMSException

createDurableConnectionConsumer

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

getClientID

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

setClientID

public void setClientID(String cID)
                 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

closeSession

public void closeSession(JmsSession session)
                  throws javax.jms.JMSException
Description copied from interface: JmsSessionFactory
Notification that a session is closed

Specified by:
closeSession in interface JmsSessionFactory
Throws:
javax.jms.JMSException - for any error

addTemporaryQueue

public void addTemporaryQueue(javax.jms.TemporaryQueue temp)
Description copied from interface: JmsSessionFactory
Add a temporary queue

Specified by:
addTemporaryQueue in interface JmsSessionFactory
Parameters:
temp - the temporary queue

addTemporaryTopic

public void addTemporaryTopic(javax.jms.TemporaryTopic temp)
Description copied from interface: JmsSessionFactory
Add a temporary topic

Specified by:
addTemporaryTopic in interface JmsSessionFactory
Parameters:
temp - the temporary topic

createConnectionConsumer

public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Destination destination,
                                                             javax.jms.ServerSessionPool pool,
                                                             int maxMessages)
                                                      throws javax.jms.JMSException
Throws:
javax.jms.JMSException

createConnectionConsumer

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

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

allocateConnection

protected JmsSession allocateConnection(boolean transacted,
                                        int acknowledgeMode,
                                        int sessionType)
                                 throws javax.jms.JMSException
Throws:
javax.jms.JMSException

checkClosed

protected void checkClosed()
                    throws javax.jms.IllegalStateException
Throws:
javax.jms.IllegalStateException


Copyright © 2002 JBoss Group, LLC. All Rights Reserved.