| java.lang.Object org.jboss.mq.Connection org.jboss.mq.SpyConnection
All known Subclasses: org.jboss.mq.SpyXAConnection,
SpyConnection | public class SpyConnection extends Connection implements Serializable,TopicConnection,QueueConnection(Code) | | This class implements javax.jms.QueueConnection and
javax.jms.TopicConnection
author: Norbert Lataille (Norbert.Lataille@m4x.org) author: Hiram Chirino (Cojonudo14@hotmail.com) author: Adrian Brock version: $Revision: 57198 $ |
Field Summary | |
final public static int | QUEUE | final public static int | TOPIC | final public static int | UNIFIED |
Method Summary | |
public ConnectionConsumer | createConnectionConsumer(Destination destination, String messageSelector, ServerSessionPool sessionPool, int maxMessages) | public ConnectionConsumer | createConnectionConsumer(Topic topic, String messageSelector, ServerSessionPool sessionPool, int maxMessages) | public ConnectionConsumer | createConnectionConsumer(Queue queue, String messageSelector, ServerSessionPool sessionPool, int maxMessages) | public ConnectionConsumer | createDurableConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages) | Queue | createQueue(String name) | public QueueSession | createQueueSession(boolean transacted, int acknowledgeMode) | public Session | createSession(boolean transacted, int acknowledgeMode) | Topic | createTopic(String name) | public TopicSession | createTopicSession(boolean transacted, int acknowledgeMode) | TemporaryQueue | getTemporaryQueue() | TemporaryTopic | getTemporaryTopic() |
QUEUE | final public static int QUEUE(Code) | | Queue
|
TOPIC | final public static int TOPIC(Code) | | Topic
|
UNIFIED | final public static int UNIFIED(Code) | | Unified
|
SpyConnection | public SpyConnection(String userId, String password, GenericConnectionFactory gcf) throws JMSException(Code) | | Create a new SpyConnection
Parameters: userId - the user Parameters: password - the password Parameters: gcf - the constructing class throws: JMSException - for any error |
SpyConnection | public SpyConnection(GenericConnectionFactory gcf) throws JMSException(Code) | | Create a new SpyConnection
Parameters: gcf - the constructing class throws: JMSException - for any error |
SpyConnection | public SpyConnection(int type, String userId, String password, GenericConnectionFactory gcf) throws JMSException(Code) | | Create a new SpyConnection
Parameters: type - the type of connection Parameters: userId - the user Parameters: password - the password Parameters: gcf - the constructing class throws: JMSException - for any error |
SpyConnection | public SpyConnection(int type, GenericConnectionFactory gcf) throws JMSException(Code) | | Create a new SpyConnection
Parameters: type - the type of connection Parameters: gcf - the constructing class throws: JMSException - for any error |
createConnectionConsumer | public ConnectionConsumer createConnectionConsumer(Destination destination, String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException(Code) | | |
createConnectionConsumer | public ConnectionConsumer createConnectionConsumer(Topic topic, String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException(Code) | | |
createConnectionConsumer | public ConnectionConsumer createConnectionConsumer(Queue queue, String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException(Code) | | |
createDurableConnectionConsumer | public ConnectionConsumer createDurableConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException(Code) | | |
createQueue | Queue createQueue(String name) throws JMSException(Code) | | |
createQueueSession | public QueueSession createQueueSession(boolean transacted, int acknowledgeMode) throws JMSException(Code) | | |
createSession | public Session createSession(boolean transacted, int acknowledgeMode) throws JMSException(Code) | | |
createTopic | Topic createTopic(String name) throws JMSException(Code) | | |
createTopicSession | public TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws JMSException(Code) | | |
getTemporaryQueue | TemporaryQueue getTemporaryQueue() throws JMSException(Code) | | |
getTemporaryTopic | TemporaryTopic getTemporaryTopic() throws JMSException(Code) | | |
|
|