com.softwareag.jca
Class PMQMessageServer

java.lang.Object
  com.softwareag.sagd.PMQServer.PMQServer
      com.softwareag.jca.PMQMessageServer

All Implemented Interfaces:

java.lang.Runnable, javax.resource.spi.work.Work

public class PMQMessageServer
extends PMQServer
implements javax.resource.spi.work.Work

Implements worker thread for one PMQ server instance.

Version:

$Revision: 1.2 $

Field Summary

Fields inherited from class com.softwareag.sagd.PMQServer.PMQServer

DEFAULT_MAX_RECEIVE_LENGTH, DEFAULT_WAIT_TIMEOUT

Constructor Summary

protected

PMQMessageServer(PMQActivationSpec spec, javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory) Create a worker.

Method Summary

void	doLog(boolean info, java.lang.String message) Implements logging.
void	doLog(java.lang.Throwable exception) Implements logging.
void	release() Stop worker.
void	run() Start worker.

Methods inherited from class com.softwareag.sagd.PMQServer.PMQServer

getDispatcherException, initBroker, initBroker, initDispatcher, initDispatcher, main, setRestartDelay, setStopOnWaitTimeout, setWaitTimeout, shutdown, start, startAsynch

Methods inherited from class java.lang.Object

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

Constructor Detail

PMQMessageServer

protected PMQMessageServer(PMQActivationSpec spec,
                           javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory)

Create a worker.

Parameters:

spec - parameter properties

endpointFactory - for message bean receiver

Method Detail

release

public void release()

Stop worker.

Specified by:

release in interface javax.resource.spi.work.Work

run

public void run()

Start worker.

Specified by:

run in interface java.lang.Runnable

doLog

public void doLog(boolean info,
                  java.lang.String message)

Implements logging.

Overrides:

doLog in class PMQServer

Parameters:

info - true for information, false for debug.

message - message text

doLog

public void doLog(java.lang.Throwable exception)

Implements logging.

Overrides:

doLog in class PMQServer

Parameters:

exception - Writes this message