org.qbroker.wmq

Class QConnector

java.lang.Object

org.qbroker.jms.JMSQConnector

org.qbroker.wmq.QConnector

All Implemented Interfaces:

javax.jms.ExceptionListener, QueueConnector

public class QConnector
extends JMSQConnector

QConnector connects to a 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.

This is NOT MT-Safe due to IBM's implementation on sessions and conn.

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 void	connect() establishes the queue connection to the JMS service
protected javax.jms.QueueBrowser	getQueueBrowser(java.lang.String name, java.lang.String ms) to support BrokerVersion = 0 of TConnector
protected javax.jms.QueueReceiver	getQueueReceiver(java.lang.String name, java.lang.String ms) to support BrokerVersion = 0 of TConnector
protected javax.jms.QueueSender	getQueueSender(java.lang.String name) to support BrokerVersion = 0 of TConnector
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, 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

connect

protected void connect()
                throws javax.jms.JMSException

Description copied from class: JMSQConnector

establishes the queue connection to the JMS service

Overrides:

connect in class JMSQConnector

Throws:

javax.jms.JMSException

getQueueSender

protected javax.jms.QueueSender getQueueSender(java.lang.String name)
                                        throws javax.jms.JMSException

to support BrokerVersion = 0 of TConnector

Throws:

javax.jms.JMSException

getQueueReceiver

protected javax.jms.QueueReceiver getQueueReceiver(java.lang.String name,
                                                   java.lang.String ms)
                                            throws javax.jms.JMSException

to support BrokerVersion = 0 of TConnector

Throws:

javax.jms.JMSException

getQueueBrowser

protected javax.jms.QueueBrowser getQueueBrowser(java.lang.String name,
                                                 java.lang.String ms)
                                          throws javax.jms.JMSException

to support BrokerVersion = 0 of TConnector

Throws:

javax.jms.JMSException