com.aspc.DBObj.Internal

Interface MasterMessageServer

All Superinterfaces:

ShutdownListener

All Known Implementing Classes:

MasterDBJMSClient, MasterSNS, NoJmsClient

public interface MasterMessageServer
extends ShutdownListener

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 int	MAX_BODY_SIZE

Method Summary

Modifier and Type	Method and Description
static boolean	checkTransHeaderExists(VirtualDB layer, long transNr)
void	connect() Connect to the JMS server
java.lang.String	getCurrentClientID() The current the client ID
static MasterMessageServer	make(MasterDB master) if jms_context is SQS then the jms_provider_url format is expected to be:- accessKey=xxxxxxxxxxxxxx,secretKey=yyyyyyyyyyyyyyyyyy,region=ap-southeast-2,queue=DEV_TRANSACTIONS
static java.lang.String	makeClear(MasterMessageServer mms) make the clear Message
static java.lang.String	makeMSG(MasterMessageServer mms, MutableDataSource mds, long transNr, DBObject[] list, long transMS) Make the XML MSG.
void	send(MutableDataSource mds, long transNr, DBObject[] list, long transMS) sends a message
void	sendClear() Send clear Message

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

shutdown

Field Detail

MAX_BODY_SIZE

static final int MAX_BODY_SIZE

See Also:

Constant Field Values

Method Detail

connect

void connect()
      throws java.lang.Exception

Connect to the JMS server

Throws:

java.lang.Exception - A serious problem.

send

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

sends a message

Parameters:

mds - the datasource

transNr - the transaction number

list - the object list

transMS - transaction time.

Throws:

java.lang.Exception - a serious problem

getCurrentClientID

@Nonnull
 @CheckReturnValue
java.lang.String getCurrentClientID()

The current the client ID

Returns:

the client ID

sendClear

void sendClear()
        throws java.lang.Exception

Send clear Message

Throws:

java.lang.Exception

make

@CheckReturnValue
 @Nonnull
static MasterMessageServer make(@Nonnull
                                                            MasterDB master)
                                                     throws java.lang.Exception

if jms_context is SQS then the jms_provider_url format is expected to be:- accessKey=xxxxxxxxxxxxxx,secretKey=yyyyyyyyyyyyyyyyyy,region=ap-southeast-2,queue=DEV_TRANSACTIONS

Parameters:

master - The current master.

Returns:

the message server.

Throws:

java.lang.Exception - a serious problem.

checkTransHeaderExists

static boolean checkTransHeaderExists(@Nonnull
                                      VirtualDB layer,
                                      @Nonnegative
                                      long transNr)

makeMSG

static java.lang.String makeMSG(@Nonnull
                                MasterMessageServer mms,
                                @Nonnull
                                MutableDataSource mds,
                                @Nonnegative
                                long transNr,
                                @Nonnull
                                DBObject[] list,
                                @Nonnegative
                                long transMS)
                         throws java.lang.Exception

Make the XML MSG.

Parameters:

mms - the client

mds -

transNr -

list -

transMS -

Returns:

the message.

Throws:

java.lang.Exception

makeClear

@Nonnull
 @CheckReturnValue
static java.lang.String makeClear(@Nonnull
                                                              MasterMessageServer mms)
                                                       throws java.lang.Exception

make the clear Message

Parameters:

mms - the client

Returns:

the clear message.

Throws:

java.lang.Exception