com.inductiveautomation.xopc.driver.api.requests

Class TimedRequest<M>

java.lang.Object

com.inductiveautomation.xopc.driver.api.requests.TimedRequest<M>

All Implemented Interfaces:

Request<M>

public class TimedRequest<M>
extends java.lang.Object
implements Request<M>

Constructor Summary

Constructors

Constructor and Description
TimedRequest(Request<M> request, com.codahale.metrics.Timer timer)

Method Summary

Modifier and Type	Method and Description
void	fail(FailureType type, DriverState state, java.lang.Exception ex) Called if the response to the most recently created message is not going to be received.
java.lang.Object	getKey()
RequestPriority	getPriority() Returns the RequestPriority of this request.
int	getTimeout() Returns the amount of time (in milliseconds) that this request should be given to run, before it is failed out for a timeout.
boolean	isRetryAllowed()
ReceiveAction	receiveMessage(M message, java.lang.Object key) Called when a response message is received for this Request.
boolean	sendMessage() Creates and puts the Requests message "on the wire".
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TimedRequest

public TimedRequest(Request<M> request,
                    com.codahale.metrics.Timer timer)

Method Detail

sendMessage

public boolean sendMessage()

Description copied from interface: Request

Creates and puts the Requests message "on the wire". Each call should send a unique message (different transaction ID, if applicable), in case the request is re-used.

Specified by:

sendMessage in interface Request<M>

getKey

public java.lang.Object getKey()

Specified by:

getKey in interface Request<M>

Returns:

A unique key that identifies this Request.

receiveMessage

public ReceiveAction receiveMessage(M message,
                                    java.lang.Object key)

Description copied from interface: Request

Called when a response message is received for this Request. This function should process the message and update any ReadItems or WriteItems that it contains (if applicable).

If you are extending from AbstractSocketDriver you must do this work on the thread this call arrived on or risk the byte[] message being returned its pool and reused in the middle of processing it.

Specified by:

receiveMessage in interface Request<M>

Parameters:

message - The message that was received for this Request.

key - The key used to retrieve this Request.

Returns:

a ReceiveAction that indicates what the driver should do with this request.

fail

public void fail(FailureType type,
                 DriverState state,
                 java.lang.Exception ex)

Description copied from interface: Request

Called if the response to the most recently created message is not going to be received. Can be called before createMessage() in the case when it is known that any message will fail (for example, trying to issue a read request before a driver is connected).

Specified by:

fail in interface Request<M>

getTimeout

public int getTimeout()

Description copied from interface: Request

Returns the amount of time (in milliseconds) that this request should be given to run, before it is failed out for a timeout.

Specified by:

getTimeout in interface Request<M>

isRetryAllowed

public boolean isRetryAllowed()

Specified by:

isRetryAllowed in interface Request<M>

Returns:

true if retrying is allowed if Request.sendMessage() returns false.

getPriority

public RequestPriority getPriority()

Description copied from interface: Request

Returns the RequestPriority of this request.

Specified by:

getPriority in interface Request<M>

Returns:

The RequestPriority of this request.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object