com.softwareag.sagd.PMQServer
Class PMQInterfaceDispatcher

java.lang.Object
  com.softwareag.sagd.PMQServer.PMQInterfaceDispatcher

Direct Known Subclasses:

PMQMessageStreamDispatcher, ToHTTPStreamDispatcher, ToStdoutDispatcher, ToStreamStdoutDispatcher

public abstract class PMQInterfaceDispatcher
extends java.lang.Object

Implements the dispatcher interface to receive messages or streams. You must implement an own class of this abstract class and define the message type with setSingleMessageDispatcher() or setStreamSendResponseDispatcher(). Depends on the implemented dispatcher, you must implement doDispatch(BrokerMessage, BrokerMessage) or doDispatch(InputStream, OutputStream).

Version:

$Revision: 1.2 $

Constructor Summary

PMQInterfaceDispatcher()
Creates dispatcher

Method Summary

boolean	doDispatch(com.softwareag.entirex.aci.BrokerMessage receivedBuffer, com.softwareag.entirex.aci.BrokerMessage replyBuffer) The server dispatches incoming messages to this interface, if setSingleMessageDispatcher() was called.
boolean	doDispatch(java.io.InputStream receivedBuffer, java.io.OutputStream replyBuffer) The server dispatches incoming messages as stream to this interface, if setStreamSendResponseDispatcher() was called.
void	doInit() Incoming event from the server to initialize this object.
protected void	doInit(PMQServer server) Incoming event from the server to initialize this object.
protected void	doLog(boolean info, java.lang.String logMessage) Provides logger interface for the dispatcher class.
protected void	doLog(java.lang.Throwable exception) Provides logger interface for the dispatcher class.
void	doRelease() The server stops the wait-for-receive loop.
java.lang.String	getLifetime() Returns the lifetime.
boolean	getPersistentStatusFlagChanged()
boolean	getStatusPersistence() Returns true if status is saved.
boolean	isSingleMessageDispatcher() Returns the implemented dispatcher type.
boolean	isStreamSendResponseDispatcher() Returns the implemented dispatcher type.
protected void	setLifetime(java.lang.String value) Set the lifetime for new created UOW.
protected void	setSingleMessageDispatcher() Set the dispatcher type.
protected void	setStatusPersistence(boolean flag) Set the status of UOW to persistent.
protected void	setStreamSendResponseDispatcher() Set the dispatcher type.

Methods inherited from class java.lang.Object

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

Constructor Detail

PMQInterfaceDispatcher

public PMQInterfaceDispatcher()

Creates dispatcher

Method Detail

doInit

protected void doInit(PMQServer server)
               throws java.lang.Throwable

Incoming event from the server to initialize this object. Should not overwrite by own class.

Parameters:

server - contect

Throws:

java.lang.Throwable

doInit

public void doInit()
            throws java.lang.Throwable

Incoming event from the server to initialize this object. Can overwrite by own class. The own created class should set the dispatcher type with setSingleMessageDispatcher() or setStreamSendResponseDispatcher().

Throws:

java.lang.Throwable

doDispatch

public boolean doDispatch(com.softwareag.entirex.aci.BrokerMessage receivedBuffer,
                          com.softwareag.entirex.aci.BrokerMessage replyBuffer)

The server dispatches incoming messages to this interface, if setSingleMessageDispatcher() was called. The caller can replay a message in replyBuffer.

Parameters:

receivedBuffer - Incoming message

replyBuffer - Outgoing message

Returns:

true to commit the message. false does a backout and stops the server.

doDispatch

public boolean doDispatch(java.io.InputStream receivedBuffer,
                          java.io.OutputStream replyBuffer)

The server dispatches incoming messages as stream to this interface, if setStreamSendResponseDispatcher() was called. The caller can replay a message in replyBuffer.

Parameters:

receivedBuffer - Incoming message

replyBuffer - Outgoing message

Returns:

true to commit the message. false does a backout and stops the server.

doRelease

public void doRelease()

The server stops the wait-for-receive loop. The allocated resources can be freed.

setLifetime

protected void setLifetime(java.lang.String value)

Set the lifetime for new created UOW.

getLifetime

public java.lang.String getLifetime()

Returns the lifetime.

setStatusPersistence

protected void setStatusPersistence(boolean flag)

Set the status of UOW to persistent.

Parameters:

flag - true for persistent

getStatusPersistence

public boolean getStatusPersistence()

Returns true if status is saved.

getPersistentStatusFlagChanged

public boolean getPersistentStatusFlagChanged()

setSingleMessageDispatcher

protected void setSingleMessageDispatcher()

Set the dispatcher type. For incoming messages, doDispatch(BrokerMessage, BrokerMessage) is called.

isSingleMessageDispatcher

public boolean isSingleMessageDispatcher()

Returns the implemented dispatcher type.

setStreamSendResponseDispatcher

protected void setStreamSendResponseDispatcher()

Set the dispatcher type. For incoming messages, doDispatch(InputStream, OutputStream) is called.

isStreamSendResponseDispatcher

public boolean isStreamSendResponseDispatcher()

Returns the implemented dispatcher type.

doLog

protected void doLog(boolean info,
                     java.lang.String logMessage)

Provides logger interface for the dispatcher class. As default, the logger message is forwarded to PMQServer.doLog(boolean, String).

Parameters:

info - true for information log level

logMessage - the message text

doLog

protected void doLog(java.lang.Throwable exception)

Provides logger interface for the dispatcher class. As default, the logger message is forwarded to PMQServer.doLog(boolean, String).

Parameters:

exception - writes error message