org.qbroker.receiver

Class JMSSubscriber

java.lang.Object

org.qbroker.receiver.Receiver

org.qbroker.receiver.JMSSubscriber

All Implemented Interfaces:

MessageReceiver

public class JMSSubscriber
extends Receiver

JMSSubscriber subscribes a JMS Topic and receives JMS messages from it. It puts the JMS Messages to an XQueue as the output. JMSSubscriber supports flow control and allows object control from its owner. It is fault tolerant with retry and idle options.

Due to the serial access of subscription for IBM MQSeries, you can specify ActionSynchronized = true to keep creation, reaction as serial processes.

Author:

yannanlu@yahoo.com

Field Summary

Fields inherited from class org.qbroker.receiver.Receiver

capacity, displayMask, linkName, maxRetry, mode, operation, partition, pauseTime, propertyName, propertyValue, repeatPeriod, standbyTime, status, timeout, tolerance, uri, waitTime, xaMode

Fields inherited from interface org.qbroker.receiver.MessageReceiver

RCVR_CLOSED, RCVR_DISABLED, RCVR_PAUSE, RCVR_READY, RCVR_RETRYING, RCVR_RUNNING, RCVR_STANDBY, RCVR_STOPPED

Constructor Summary

Constructors

Constructor and Description
JMSSubscriber(java.util.Map props)

Method Summary

Modifier and Type	Method and Description
void	close() closes all opened resources
protected void	finalize()
void	receive(XQueue xq, int baseTime) implementation of receive() with flow control individual object control will be provided by the owner

Methods inherited from class org.qbroker.receiver.Receiver

getCapacity, getLinkName, getName, getOperation, getPartition, getStatus, getXAMode, isStopped, keepRunning, resetStatus, setStatus

Methods inherited from class java.lang.Object

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

Constructor Detail

JMSSubscriber

public JMSSubscriber(java.util.Map props)

Method Detail

receive

public void receive(XQueue xq,
                    int baseTime)

implementation of receive() with flow control individual object control will be provided by the owner

Specified by:

receive in interface MessageReceiver

Specified by:

receive in class Receiver

close

public void close()

Description copied from interface: MessageReceiver

closes all opened resources

Specified by:

close in interface MessageReceiver

Specified by:

close in class Receiver

finalize

protected void finalize()

Overrides:

finalize in class java.lang.Object