com.amazonaws.greengrass.streammanager.client.response

Class ResponseManager

java.lang.Object

com.amazonaws.greengrass.streammanager.client.response.ResponseManager

public class ResponseManager
extends Object

ResponseManager manages the response received from the server.

Constructor Summary

Constructors

Constructor and Description
ResponseManager(StreamManagerLogger logger)

Method Summary

Modifier and Type	Method and Description
void	deliverException(IOException cause) Delivers exception to all the callers waiting for a response Should be called when the callers of waitForResponse are not expected to get a real response eg, when the connection is dropped This is a way to fail fast and cleanup
void	deliverResponse(String requestId, Object response) Deliver a response object.
void	registerForResponse(String requestId) Register a pending response for a client request.
<T> T	waitForResponse(String requestId, long timeoutInSeconds, Class<T> responseTypeClass) Wait for the arrival of a response.

Methods inherited from class java.lang.Object

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

Constructor Detail

ResponseManager

public ResponseManager(StreamManagerLogger logger)

Method Detail

registerForResponse

public void registerForResponse(String requestId)
                         throws StreamManagerException

Register a pending response for a client request.

Parameters:

requestId - request id

Throws:

StreamManagerException

waitForResponse

public <T> T waitForResponse(String requestId,
                             long timeoutInSeconds,
                             Class<T> responseTypeClass)
                      throws InterruptedException,
                             IOException,
                             StreamManagerException

Wait for the arrival of a response. The call blocks until the specified timeout expires.

Type Parameters:

T - Response class type, should not be an IOException

Parameters:

requestId - Request id

timeoutInSeconds - Timeout in seconds

responseTypeClass - Response class

Returns:

Response object

Throws:

InterruptedException - InterruptedException

IOException - when an IOException is delivered

StreamManagerException - For other exceptions

deliverResponse

public void deliverResponse(String requestId,
                            Object response)

Deliver a response object. This will unblock the call blocked on waitForResponse.

Parameters:

requestId - Request id

response - Response object

deliverException

public void deliverException(IOException cause)

Delivers exception to all the callers waiting for a response Should be called when the callers of waitForResponse are not expected to get a real response eg, when the connection is dropped This is a way to fail fast and cleanup

Parameters:

cause - exception to deliver