org.apache.ignite.internal.processors.continuous

Class GridContinuousProcessor.RemoteRoutineInfo

java.lang.Object

org.apache.ignite.internal.processors.continuous.GridContinuousProcessor.RemoteRoutineInfo

All Implemented Interfaces:

GridContinuousProcessor.RoutineInfo

Enclosing class:

GridContinuousProcessor

public static class GridContinuousProcessor.RemoteRoutineInfo
extends Object
implements GridContinuousProcessor.RoutineInfo

Remote routine info.

Method Summary

Modifier and Type	Method and Description
boolean	autoUnsubscribe()
int	bufferSize()
boolean	clearDelayedRegister() Clears delayed register flag if it was set.
boolean	delayedRegister()
GridContinuousHandler	handler()
long	interval()
long	lastSendTime()
void	markDelayedRegister() Marks info to be registered when cache is started.
UUID	nodeId()
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

nodeId

public UUID nodeId()

Specified by:

nodeId in interface GridContinuousProcessor.RoutineInfo

Returns:

Master node id.

handler

public GridContinuousHandler handler()

Specified by:

handler in interface GridContinuousProcessor.RoutineInfo

Returns:

Handler.

bufferSize

public int bufferSize()

Specified by:

bufferSize in interface GridContinuousProcessor.RoutineInfo

Returns:

Buffer size.

interval

public long interval()

Specified by:

interval in interface GridContinuousProcessor.RoutineInfo

Returns:

Notify interval.

autoUnsubscribe

public boolean autoUnsubscribe()

Specified by:

autoUnsubscribe in interface GridContinuousProcessor.RoutineInfo

Returns:

Auto unsubscribe flag value.

lastSendTime

public long lastSendTime()

Specified by:

lastSendTime in interface GridContinuousProcessor.RoutineInfo

Returns:

Last send time.

delayedRegister

public boolean delayedRegister()

Specified by:

delayedRegister in interface GridContinuousProcessor.RoutineInfo

Returns:

Delayed register flag.

markDelayedRegister

public void markDelayedRegister()

Marks info to be registered when cache is started.

clearDelayedRegister

public boolean clearDelayedRegister()

Clears delayed register flag if it was set.

Returns:

True if flag was cleared.

toString

public String toString()

Overrides:

toString in class Object