com.aspc.DBObj.Internal.impl

Class MasterDBJMSClient

java.lang.Object

com.aspc.remote.jms.Client

com.aspc.DBObj.Internal.impl.MasterDBJMSClient

All Implemented Interfaces:

MasterMessageServer, ShutdownListener

Direct Known Subclasses:

NoJmsClient

public class MasterDBJMSClient
extends Client
implements MasterMessageServer

A JMS Client for the master DB. THREAD MODE: MULTI-THREADED

Since:

April 23, 2005

Author:

Nigel Leck

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ENV_JMS_MAX_PROCESS_MS Environment variable to control the max processing time in milliseconds
static java.lang.String	ENV_JMS_MAX_TRANSFER_MS Environment variable to control the max transfer time in milliseconds
static java.lang.String	SENDER_ID The sender ID ( we lose this in multiple JMS servers)

Fields inherited from class com.aspc.remote.jms.Client

ATTRIBUTE_RECORD_COUNT, ATTRIBUTE_SENT_MS, ATTRIBUTE_TRANS_MS, ATTRIBUTE_TRANS_NR, DISABLE_JMS, ENV_JMS_MAX_LIVE_MS, ENV_JMS_PENDING_COUNT, ENV_JMS_TIMEOUT, JMS_TIMEOUT, MAX_INACTIVITY_DURATION, PROPERTY_MAX_INACTIVITY_DURATION

Fields inherited from interface com.aspc.DBObj.Internal.MasterMessageServer

MAX_BODY_SIZE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MasterDBJMSClient() Listen for JMS messages to keep the cache in sync with other servers.
	MasterDBJMSClient(MasterDB masterDB) Listen for JMS messages to keep the cache in sync with other servers.

Method Summary

Modifier and Type	Method and Description
java.lang.String	getContextFactory() get the context factory
protected MessageListener	getMessageListener() Get the listener
java.lang.String	getProviderUrl() get the context factory
static void	logRecievedMessage(java.lang.String message, long startMS, long sentMS, java.lang.String clientID, java.lang.String messageID) log a message
void	onException(javax.jms.JMSException jMSException) Handle a JMS exception
void	onMessage(Message message) Each XML to process.
static void	processMessage(java.lang.String text, java.lang.String clientID, java.lang.String messageID) Each XML to process.
protected void	refreshContext() reload the context from the database.
void	send(MutableDataSource mds, long transNr, DBObject[] list, long transMS) sends a message
void	sendClear() Send clear Message

Methods inherited from class com.aspc.remote.jms.Client

connect, connectionFailed, getConnectionCount, getConnectionStats, getCurrentClientID, getLastConnected, getTotalSentCount, isConnected, isEnabled, logSentMessage, postPublish, prePublish, reconnectedJMS, send, shutdown, shutdownJMS

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.aspc.DBObj.Internal.MasterMessageServer

checkTransHeaderExists, connect, getCurrentClientID, make, makeClear, makeMSG

Methods inherited from interface com.aspc.remote.application.ShutdownListener

shutdown

Field Detail

SENDER_ID

public static final java.lang.String SENDER_ID

The sender ID ( we lose this in multiple JMS servers)

See Also:

Constant Field Values

ENV_JMS_MAX_PROCESS_MS

public static final java.lang.String ENV_JMS_MAX_PROCESS_MS

Environment variable to control the max processing time in milliseconds

See Also:

Constant Field Values

ENV_JMS_MAX_TRANSFER_MS

public static final java.lang.String ENV_JMS_MAX_TRANSFER_MS

Environment variable to control the max transfer time in milliseconds

See Also:

Constant Field Values

Constructor Detail

MasterDBJMSClient

public MasterDBJMSClient(@Nonnull
                         MasterDB masterDB)

Listen for JMS messages to keep the cache in sync with other servers.

Parameters:

masterDB - The master DB

MasterDBJMSClient

protected MasterDBJMSClient()

Listen for JMS messages to keep the cache in sync with other servers.

Method Detail

getMessageListener

protected MessageListener getMessageListener()

Get the listener

Overrides:

getMessageListener in class Client

Returns:

The listener

sendClear

public void sendClear()
               throws java.lang.Exception

Send clear Message

Specified by:

sendClear in interface MasterMessageServer

Throws:

java.lang.Exception

send

public void send(@Nonnull
                 MutableDataSource mds,
                 @Nonnegative
                 long transNr,
                 @Nonnull
                 DBObject[] list,
                 @Nonnegative
                 long transMS)
          throws java.lang.Exception

sends a message

Specified by:

send in interface MasterMessageServer

Parameters:

mds - the datasource

transNr - the transaction number

list - the object list

transMS - transaction time.

Throws:

java.lang.Exception - a serious problem

getContextFactory

@CheckReturnValue
 @Nonnull
public java.lang.String getContextFactory()

get the context factory

Specified by:

getContextFactory in class Client

Returns:

The context factory

getProviderUrl

@CheckReturnValue
 @Nonnull
public java.lang.String getProviderUrl()

get the context factory

Specified by:

getProviderUrl in class Client

Returns:

the context factory

refreshContext

protected void refreshContext()
                       throws java.lang.Exception

reload the context from the database.

Overrides:

refreshContext in class Client

Throws:

java.lang.Exception - A serious problem.

onException

public void onException(javax.jms.JMSException jMSException)

Handle a JMS exception

Overrides:

onException in class Client

Parameters:

jMSException - The exception

onMessage

public void onMessage(Message message)

Each XML to process.

Parameters:

message - The message to be processed.

processMessage

public static void processMessage(java.lang.String text,
                                  java.lang.String clientID,
                                  java.lang.String messageID)
                           throws java.lang.Exception

Each XML to process.

Parameters:

clientID - The client ID

messageID - the message ID

text - The message text

Throws:

java.lang.Exception - A serious problem

logRecievedMessage

public static void logRecievedMessage(java.lang.String message,
                                      long startMS,
                                      long sentMS,
                                      java.lang.String clientID,
                                      java.lang.String messageID)

log a message

Parameters:

clientID - The client ID

messageID - the message id

message - the message

startMS - the start time

sentMS - the sent time