org.agilewiki.jactor.parallel

Class JAResponseCounter2

java.lang.Object

org.agilewiki.jactor.RP

org.agilewiki.jactor.parallel.JAResponseCounter2

public class JAResponseCounter2
extends RP

Counts the number of responses received and responds with the count of requests sent when the iteration is finished.

Field Summary

Fields

Modifier and Type	Field and Description
int	sent The number of requests sent.

Constructor Summary

Constructors

Constructor and Description
JAResponseCounter2(RP xrp) Create a PubSubResponseProcessor.

Method Summary

Methods

Modifier and Type	Method and Description
void	finished() Signals that all requests have been sent.
void	processResponse(Object response) Receives and processes a response.

Methods inherited from class org.agilewiki.jactor.RP

isEvent

Methods inherited from class java.lang.Object

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

Field Detail

sent

public int sent

The number of requests sent.

Constructor Detail

JAResponseCounter2

public JAResponseCounter2(RP xrp)

Create a PubSubResponseProcessor.

Parameters:

xrp - The external response processor.

Method Detail

finished

public void finished()
              throws Exception

Signals that all requests have been sent.

Throws:

Exception - Any excpetions raised while processing the external response.

processResponse

public void processResponse(Object response)
                     throws Exception

Receives and processes a response.

Specified by:

processResponse in class RP

Parameters:

response - The response.

Throws:

Exception - Any uncaught exceptions raised when processing the response.