com.aspc.DBObj.Internal.impl

Class MasterSNS

java.lang.Object

com.aspc.DBObj.Internal.impl.MasterSNS

All Implemented Interfaces:

MasterMessageServer, ShutdownListener

public class MasterSNS
extends java.lang.Object
implements MasterMessageServer

Connect to SQS from the master database.

Since:

4 Oct 2017

Author:

Nigel Leck

Field Summary

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

MAX_BODY_SIZE

Constructor Summary

Constructors

Constructor and Description
MasterSNS(java.lang.String parameters)

Method Summary

Modifier and Type	Method and Description
void	connect() Connect to the JMS server
static java.lang.String	expand(java.lang.String data, java.lang.String timestamp)
java.lang.String	getCurrentClientID() The current the client ID
static java.lang.String	minimize(java.lang.String xml)
void	send(MutableDataSource mds, long transNr, DBObject[] list, long transMS) sends a message
void	sendClear() Send clear Message
void	shutdown() We are shutting down

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, make, makeClear, makeMSG

Constructor Detail

MasterSNS

public MasterSNS(@Nonnull
                 java.lang.String parameters)

Method Detail

connect

public void connect()
             throws java.lang.Exception

Description copied from interface: MasterMessageServer

Connect to the JMS server

Specified by:

connect in interface MasterMessageServer

Throws:

java.lang.Exception - A serious problem.

minimize

public static java.lang.String minimize(@Nonnull
                                        java.lang.String xml)
                                 throws java.lang.Exception

Throws:

java.lang.Exception

expand

public static java.lang.String expand(@Nonnull
                                      java.lang.String data,
                                      @Nullable
                                      java.lang.String timestamp)
                               throws java.lang.Exception

Throws:

java.lang.Exception

send

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

Description copied from interface: MasterMessageServer

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

getCurrentClientID

public java.lang.String getCurrentClientID()

Description copied from interface: MasterMessageServer

The current the client ID

Specified by:

getCurrentClientID in interface MasterMessageServer

Returns:

the client ID

sendClear

public void sendClear()
               throws java.lang.Exception

Description copied from interface: MasterMessageServer

Send clear Message

Specified by:

sendClear in interface MasterMessageServer

Throws:

java.lang.Exception

shutdown

public void shutdown()

Description copied from interface: ShutdownListener

We are shutting down

Specified by:

shutdown in interface ShutdownListener