org.qbroker.jms

Class QConnector

java.lang.Object

org.qbroker.jms.JMSQConnector

org.qbroker.jms.QConnector

All Implemented Interfaces:

javax.jms.ExceptionListener, QueueConnector

public class QConnector
extends JMSQConnector

QConnector connects to a JMS queue and initializes one of the operations, such as browse, query, get or put. It supports repeated browse on a queue with auto increment of JMSTimestamp. But it requires Mode is set to daemon and SequentialSearch is on. The application is supposed to reset the browser every time with null string as the only argument. If ReferenceFile is defined, the state info will be persisted to the file for restart.

Author:

yannanlu@yahoo.com

Field Summary

Fields inherited from class org.qbroker.jms.JMSQConnector

batchSize, bBrowser, boundary, bReceiver, bSender, bSession, bufferSize, cache, displayMask, enable_exlsnr, endTime, eotBytes, expiry, isPhysical, maxIdleTime, maxMsgLength, maxNumberMsg, mode, MS_EOT, MS_SOT, msField, msg2Text, msgFilters, msgID, msgSelector, offhead, offtail, operation, overwrite, partition, password, persistence, priority, propertyName, propertyValue, qBrowser, qConnection, qName, qReceiver, qSender, qSession, queue, rcField, receiveTime, referenceFile, resetOption, respPropertyName, resultField, resultType, sequentialSearch, sleepTime, sotBytes, startTime, template, textMode, timeout, timestamp, username, waitTime, withFlowControlDisabled, xaMode

Fields inherited from interface org.qbroker.jms.QueueConnector

QC_QUEUE, QC_STREAM, QC_TOPIC, QC_XQ, XA_CLIENT, XA_COMMIT

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected javax.jms.QueueConnectionFactory	initialize() Initializes the JMS components (QueueConnectionFactory, QueueConnection) for use later in the application

Methods inherited from class org.qbroker.jms.JMSQConnector

browse, close, commit, connect, createMessage, createQueue, createTemporaryQueue, get, getOperation, getQueueBrowser, getQueueReceiver, getQueueSender, onException, put, put, qClose, qOpen, qReopen, query, reconnect, reply, request, resetQueueBrowser, rollback, saveReference, toKey

Methods inherited from class java.lang.Object

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

Constructor Detail

QConnector

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

Creates new QConnector

Throws:

javax.jms.JMSException

Method Detail

initialize

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

Initializes the JMS components (QueueConnectionFactory, QueueConnection) for use later in the application

Specified by:

initialize in class JMSQConnector

Throws:

javax.jms.JMSException - occurs on any JMS Error