org.hornetq.jms.client

Class HornetQTopicConnection

java.lang.Object

org.hornetq.jms.client.HornetQConnection

org.hornetq.jms.client.HornetQTopicConnection

All Implemented Interfaces:

Connection, QueueConnection, TopicConnection

public class HornetQTopicConnection
extends HornetQConnection
implements TopicConnection

HornetQ implementation of a JMS TopicConnection.

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
HornetQTopicConnection(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.TopicConnection

createConnectionConsumer, createDurableConnectionConsumer, createTopicSession

Methods inherited from interface javax.jms.Connection

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

Constructor Detail

HornetQTopicConnection

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