org.qbroker.persister

Class ServerPersister

java.lang.Object

org.qbroker.persister.Persister

org.qbroker.persister.ServerPersister

All Implemented Interfaces:

MessagePersister

public class ServerPersister
extends Persister

ServerPersister listens to a ServerSocket and accepts the 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 keeps getting JMS messages from the input XQueue and writes the byte stream to the socket. Currently, it supports two operations, provide and publish. In case of the provide operation, ServerPersister allows multiple client threads to pick up messages from the same XQueue. ServerPersister supports flow control and allows object control from its owner. It is fault tolerant with retry and idle options. In case of the publish operation, however, ServerPersister allows multiple subscribers to pick up messages published from the same XQueue and each client gets its own copies. In this case, there is no flow control and buffer overrun may occur. Therefore, ServerPersister is a JMS message outlet, or a JMS message provider.

Author:

yannanlu@yahoo.com

Field Summary

Fields inherited from class org.qbroker.persister.Persister

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

Fields inherited from interface org.qbroker.persister.MessagePersister

PSTR_CLOSED, PSTR_DISABLED, PSTR_PAUSE, PSTR_READY, PSTR_RETRYING, PSTR_RUNNING, PSTR_STANDBY, PSTR_STOPPED

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close() closes all opened resources
void	doPublish(XQueue xq) It keeps publishing until its end of life
protected void	finalize()
void	persist(XQueue xq, int baseTime) gets all the JMS messages from the XQueue and delivers them to their destinations.
void	provide(XQueue xq, java.net.Socket sock, java.lang.String ip) It gets JMS Messages from an XQueue and writes the content of messages to the socket continuously.

Methods inherited from class org.qbroker.persister.Persister

getCapacity, getLinkName, getName, getOperation, 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

ServerPersister

public ServerPersister(java.util.Map props)

Method Detail

persist

public void persist(XQueue xq,
                    int baseTime)

Description copied from interface: MessagePersister

gets all the JMS messages from the XQueue and delivers them to their destinations. In case of failure, it should keep retry with the sleepTime in milliseconds.

Specified by:

persist in interface MessagePersister

Specified by:

persist in class Persister

provide

public void provide(XQueue xq,
                    java.net.Socket sock,
                    java.lang.String ip)

It gets JMS Messages from an XQueue and writes the content of messages to the socket continuously. It acts like a source of a byte stream. This method is used to write the content on behalf of a subscriber. In case of publish operation, the xq is the one created for the subscriber. The publisher will copy messages into the xq. For provide operation, the xq is the original source. So the flow control on the xq will impact on this method. For example, if the flow tries to disable the persister, the provide method will return.

doPublish

public void doPublish(XQueue xq)

It keeps publishing until its end of life

close

public void close()

Description copied from interface: MessagePersister

closes all opened resources

Specified by:

close in interface MessagePersister

Specified by:

close in class Persister

finalize

protected void finalize()

Overrides:

finalize in class java.lang.Object