fipaos.test.mts.service
Class CollectorService

java.lang.Object
  |
  +--fipaos.test.mts.service.CollectorService
All Implemented Interfaces:
PostParserService, PreParserService, Service

public class CollectorService
extends java.lang.Object
implements PostParserService, PreParserService

General purpose class for use when testing MTS Service components


Fields inherited from interface fipaos.mts.service.Service
ACL_LANGUAGE_UNKNOWN, CONTENT_LANGUAGE_UNKNOWN, ERROR_STRING, ERROR_UNKNOWN, FIPAOS_DEBUG, FIPAOS_MSG_ID_SLOT, MALFORMED_ENVELOPE, MSG_DELIVERY_FAILURE_REASON, NONE, PROTOCOL_UNKNOWN, TARGET_UNKNOWN
 
Constructor Summary
CollectorService()
           
 
Method Summary
 java.lang.Object[] getNextEnvelopeAndByteArray()
           
 Message getNextMessage()
           
 void incoming(Envelope p1, byte[] p2)
          Incoming messages are passed to this via this method
 void incoming(Message p1)
          Incoming messages are passed to this via this method
 void initialise(PostParserService p1, PostParserService p2)
          Invoked when the undelying implementation should initialise itself.
 void initialise(PreParserService p1, PreParserService p2)
          Invoked when the undelying implementation should initialise itself.
 void outgoing(Envelope p1, byte[] p2)
          Outgoing messages are passed to this via this method
 void outgoing(Message p1)
          Outgoing messages are passed to this via this method
 void shutdown()
          This should be invoked when the service should be safely shutdown
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

CollectorService

public CollectorService()
Method Detail

incoming

public void incoming(Message p1)
Description copied from interface: PreParserService
Incoming messages are passed to this via this method
Specified by:
incoming in interface PreParserService
Following copied from interface: fipaos.mts.service.PreParserService
Parameters:
msg - Incoming message

incoming

public void incoming(Envelope p1,
                     byte[] p2)
Description copied from interface: PostParserService
Incoming messages are passed to this via this method
Specified by:
incoming in interface PostParserService
Following copied from interface: fipaos.mts.service.PostParserService
Parameters:
msg - Incoming message

initialise

public void initialise(PostParserService p1,
                       PostParserService p2)
Description copied from interface: PostParserService
Invoked when the undelying implementation should initialise itself. Allows references to other PostParserService's before and after it in the stack to be passed
Specified by:
initialise in interface PostParserService
Following copied from interface: fipaos.mts.service.PostParserService
Parameters:
previous - Previous PostParserService instance (Incoming messages should be passed to this)
next - Next PostParserService instance (Outgoing messages should be passed to this)

initialise

public void initialise(PreParserService p1,
                       PreParserService p2)
Description copied from interface: PreParserService
Invoked when the undelying implementation should initialise itself. Allows references to other PreParserService's before and after it in the stack to be passed
Specified by:
initialise in interface PreParserService
Following copied from interface: fipaos.mts.service.PreParserService
Parameters:
previous - Previous PreParserService instance (Incoming messages should be passed to this)
next - Next PreParserService instance (Outgoing messages should be passed to this)

outgoing

public void outgoing(Message p1)
Description copied from interface: PreParserService
Outgoing messages are passed to this via this method
Specified by:
outgoing in interface PreParserService
Following copied from interface: fipaos.mts.service.PreParserService
Parameters:
msg - Outgoing message

outgoing

public void outgoing(Envelope p1,
                     byte[] p2)
Description copied from interface: PostParserService
Outgoing messages are passed to this via this method
Specified by:
outgoing in interface PostParserService
Following copied from interface: fipaos.mts.service.PostParserService
Parameters:
msg - Outgoing message

shutdown

public void shutdown()
Description copied from interface: Service
This should be invoked when the service should be safely shutdown
Specified by:
shutdown in interface Service

getNextMessage

public Message getNextMessage()

getNextEnvelopeAndByteArray

public java.lang.Object[] getNextEnvelopeAndByteArray()