org.qbroker.receiver

Class ServerReceiver

java.lang.Object

org.qbroker.receiver.Receiver

org.qbroker.receiver.ServerReceiver

All Implemented Interfaces:

MessageReceiver

public class ServerReceiver
extends Receiver

ServerReceiver listens to a ServerSocket and accepts socket connections from it. Once there is a new connection, it will check out a thread to handle the message IO on the socket. The thread reads the byte stream, puts them into messages and adds them to the output XQueue. ServerReceiver supports flow control and allows object control from its owner. It is fault tolerant with retry and idle options. The max number of client connections is determined by both Capacity and Partition of the XQueue. Backlog is the queue length of the server socket listener.

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
ServerReceiver(java.util.Map props)

Method Summary

Modifier and Type	Method and Description
void	acquire(java.util.Map client) It continuously reads byte stream from the socket and package them into JMS Messages.
void	close() closes all opened resources
protected void	finalize()
void	receive(XQueue xq, int baseTime) puts all the received JMS messages to the XQueue as the output.
void	respond(java.util.Map client) It continuously reads byte stream from the socket and package them into JMS Messages.

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

ServerReceiver

public ServerReceiver(java.util.Map props)

Method Detail

receive

public void receive(XQueue xq,
                    int baseTime)

Description copied from interface: MessageReceiver

puts all the received JMS messages to the XQueue as the output. In case of failure, it should keep retry with the sleepTime in milliseconds.

Specified by:

receive in interface MessageReceiver

Specified by:

receive in class Receiver

acquire

public void acquire(java.util.Map client)

It continuously reads byte stream from the socket and package them into JMS Messages. It adds the messages to an XQueue as output. The messages are flowing downstream and they will be consumed eventually. It acts like a destination of messages.

respond

public void respond(java.util.Map client)

It continuously reads byte stream from the socket and package them into JMS Messages. It adds the messages to an XQueue as requests. The messages flow downstream and the requests will be fulfilled by some nodes. In the end, the messages will be collected and sent back to the socket as the responses. It acts like a service on messages.

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