app.spa
Interface SPAEventStreamSource

All Known Implementing Classes:
SimplerSPAEventStreamChannel, SPAEventStreamChannel

public interface SPAEventStreamSource

Interface defining a source from which successive items in an SPAEvent stream can be obtained, and via which an SPAEventAck can be delivered in response.


Method Summary
 void deliverAck(SPAEventAck ack)
          Delivers the given acknowledgement in response to the event most recently obtained via getNextEvent(), waiting if necessary until it can be accepted.
 void deliverAck(java.lang.String ackmsg)
          Delivers a new failure acknowledgement with the given descriptive text in response to the event most recently obtained via getNextEvent(), waiting if necessary until it can be accepted.
 void deliverOKAck()
          Delivers an OK acknowledgement.
 SPAEvent getNextEvent()
          Obtains the next event from this source, waiting if necessary until it becomes available.
 

Method Detail

getNextEvent

SPAEvent getNextEvent()
                      throws java.lang.InterruptedException
Obtains the next event from this source, waiting if necessary until it becomes available.

Throws:
java.lang.InterruptedException

deliverAck

void deliverAck(SPAEventAck ack)
                throws java.lang.InterruptedException
Delivers the given acknowledgement in response to the event most recently obtained via getNextEvent(), waiting if necessary until it can be accepted.

Throws:
java.lang.InterruptedException

deliverOKAck

void deliverOKAck()
                  throws java.lang.InterruptedException
Delivers an OK acknowledgement.

Throws:
java.lang.InterruptedException

deliverAck

void deliverAck(java.lang.String ackmsg)
                throws java.lang.InterruptedException
Delivers a new failure acknowledgement with the given descriptive text in response to the event most recently obtained via getNextEvent(), waiting if necessary until it can be accepted.

Throws:
java.lang.InterruptedException