org.hornetq.jms.client

Class HornetQQueueConnection

java.lang.Object

org.hornetq.jms.client.HornetQConnection

org.hornetq.jms.client.HornetQQueueConnection

All Implemented Interfaces:

Connection, QueueConnection, TopicConnection

public class HornetQQueueConnection
extends HornetQConnection
implements QueueConnection

HornetQ implementation of a JMS QueueConnection.

Author:

Howard Gao

Field Summary

Fields inherited from class org.hornetq.jms.client.HornetQConnection

CONNECTION_ID_PROPERTY_NAME, EXCEPTION_DISCONNECT, EXCEPTION_FAILOVER, TYPE_GENERIC_CONNECTION, TYPE_QUEUE_CONNECTION, TYPE_TOPIC_CONNECTION

Constructor Summary

Constructors

Constructor and Description
HornetQQueueConnection(String username, String password, int connectionType, String clientID, int dupsOKBatchSize, int transactionBatchSize, ClientSessionFactory sessionFactory)

Method Summary

Methods inherited from class org.hornetq.jms.client.HornetQConnection

addTemporaryQueue, authorize, close, containsTemporaryQueue, createConnectionConsumer, createConnectionConsumer, createConnectionConsumer, createDurableConnectionConsumer, createQueueSession, createSession, createTopicSession, createXAQueueSession, createXASession, createXATopicSession, finalize, getClientID, getExceptionListener, getInitialSession, getMetaData, getUID, hasNoLocal, removeSession, removeTemporaryQueue, setClientID, setExceptionListener, setHasNoLocal, setReference, start, stop

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface javax.jms.QueueConnection

createConnectionConsumer, createQueueSession

Methods inherited from interface javax.jms.Connection

close, createConnectionConsumer, createDurableConnectionConsumer, createSession, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop

Constructor Detail

HornetQQueueConnection

public HornetQQueueConnection(String username,
                      String password,
                      int connectionType,
                      String clientID,
                      int dupsOKBatchSize,
                      int transactionBatchSize,
                      ClientSessionFactory sessionFactory)