Package dev.getelements.elements.rt.remote.jeromq

Class JeroMQAsyncOperation

java.lang.Object

dev.getelements.elements.rt.remote.jeromq.JeroMQAsyncOperation

All Implemented Interfaces:

AsyncOperation

public class JeroMQAsyncOperation
extends Object
implements AsyncOperation

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JeroMQAsyncOperation.ConnectionState
static enum	JeroMQAsyncOperation.State

Field Summary

Fields inherited from interface dev.getelements.elements.rt.remote.AsyncOperation

DEFAULT

Constructor Summary

Constructors

Constructor	Description
JeroMQAsyncOperation()

Method Summary

Modifier and Type	Method	Description
JeroMQAsyncOperation.ConnectionState	acquire(AsyncConnection<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> connection)	Called when the connection is acquired.
void	cancel()	Cancels the invocation.
JeroMQAsyncOperation.ConnectionState	finish()	Finishes the operation and returns the underlying connection to the pool.
JeroMQAsyncOperation.ConnectionState	finishCancellation()	Finishes the cancellation.
JeroMQAsyncOperation.ConnectionState	requestFinish()	Attempts to finish the operation by setting the state to JeroMQAsyncOperation.State.FINISH_PENDING.
void	timeout(long time, TimeUnit timeUnit)	Sets the operation to automatically cancel after the supplied time has elapsed.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

JeroMQAsyncOperation

public JeroMQAsyncOperation()

Method Details

cancel

public void cancel()

Description copied from interface: AsyncOperation

Cancels the invocation.

Specified by:

cancel in interface AsyncOperation

timeout

public void timeout(long time,
 TimeUnit timeUnit)

Description copied from interface: AsyncOperation

Sets the operation to automatically cancel after the supplied time has elapsed.

Specified by:

timeout in interface AsyncOperation

Parameters:

time - the time to wait

timeUnit - the time unit to wait

finishCancellation

public JeroMQAsyncOperation.ConnectionState finishCancellation()

Finishes the cancellation.

Returns:

finished

acquire

public JeroMQAsyncOperation.ConnectionState acquire(AsyncConnection<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> connection)

Called when the connection is acquired. If the operation is still in a suitable state, this will return true incicating that the operation may proceed. This is only valid if the current state is JeroMQAsyncOperation.State.CONNECTION_PENDING. For any other state, this will return false indicating that the connection has already finished or is in the process of being canceled.

Returns:

true if the operation may proceed.

requestFinish

public JeroMQAsyncOperation.ConnectionState requestFinish()

Attempts to finish the operation by setting the state to JeroMQAsyncOperation.State.FINISH_PENDING. This indicates that the response is ready and the response w ill be written shortly. If this transition is successful, then a subsequent call to finish() must happen to ensure the connection is properly recycled.

finish

public JeroMQAsyncOperation.ConnectionState finish()

Finishes the operation and returns the underlying connection to the pool.

Returns:

the current JeroMQAsyncOperation.ConnectionState

toString

public String toString()

Overrides:

toString in class Object