org.qbroker.jms

Class TConnector

java.lang.Object

org.qbroker.jms.JMSTConnector

org.qbroker.jms.TConnector

All Implemented Interfaces:

javax.jms.ExceptionListener, TopicConnector

public class TConnector
extends JMSTConnector

TConnector connects to a JMS topic and initializes one of the operations, such as sub, pub, DeregSub and RegSub.

For durable subscriptions, you have to specify SubscriptionID. On the other hand, if SubscriptionID is defined, it is assumed to be durable subscription.

Author:

yannanlu@yahoo.com

Field Summary

Fields inherited from class org.qbroker.jms.JMSTConnector

batchSize, boundary, bPublisher, bSession, bSubscriber, bufferSize, cellID, check_body, clientID, connectionFactoryName, displayMask, enable_exlsnr, endTime, eotBytes, expiry, isDurable, isPhysical, maxIdleTime, maxMsgLength, maxNumberMsg, mode, MS_EOT, MS_SOT, msgID, msgSelector, offhead, offtail, operation, overwrite, partition, password, persistence, priority, propertyName, propertyValue, receiveTime, resetOption, sleepTime, sotBytes, startTime, subscriptionID, tConnection, textMode, tName, topic, tPublisher, tSession, tSubscriber, username, waitTime, withFlowControlDisabled, xaMode

Fields inherited from interface org.qbroker.jms.TopicConnector

TC_QUEUE, TC_STREAM, TC_TOPIC, TC_XQ, XA_CLIENT, XA_COMMIT

Constructor Summary

Constructors

Constructor and Description
TConnector(java.util.Map props) Creates new TConnector

Method Summary

Modifier and Type	Method and Description
protected javax.jms.TopicConnectionFactory	initialize() Initializes the JMS components (TopicConnectionFactory, TopicConnection, TopicPublisher, BytesMessage) for use later in the application

Methods inherited from class org.qbroker.jms.JMSTConnector

close, commit, connect, createMessage, createQueue, getOperation, getTopicPublisher, getTopicSubscriber, onException, pub, pub, reconnect, rollback, sub, tClose, tOpen, tReopen

Methods inherited from class java.lang.Object

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

Constructor Detail

TConnector

public TConnector(java.util.Map props)
           throws javax.jms.JMSException

Creates new TConnector

Throws:

javax.jms.JMSException

Method Detail

initialize

protected javax.jms.TopicConnectionFactory initialize()
                                               throws javax.jms.JMSException

Initializes the JMS components (TopicConnectionFactory, TopicConnection, TopicPublisher, BytesMessage) for use later in the application

Specified by:

initialize in class JMSTConnector

Throws:

javax.jms.JMSException - occurs on any JMS Error