org.gridgain.grid.kernal.processors.continuous

Interface GridContinuousHandler

All Superinterfaces:

Externalizable, Serializable

All Known Implementing Classes:

GridMessageListenHandler

public interface GridContinuousHandler
extends Externalizable

Continuous routine handler.

Method Summary

Methods

Modifier and Type	Method and Description
void	notifyCallback(UUID nodeId, UUID routineId, Collection<?> objs, GridKernalContext ctx) Notifies local callback.
void	onListenerRegistered(UUID routineId, GridKernalContext ctx) Callback called after listener is registered and acknowledgement is sent.
Object	orderedTopic()
void	p2pMarshal(GridKernalContext ctx) Deploys and marshals inner objects (called only if peer deployment is enabled).
void	p2pUnmarshal(UUID nodeId, GridKernalContext ctx) Unmarshals inner objects (called only if peer deployment is enabled).
boolean	register(UUID nodeId, UUID routineId, GridKernalContext ctx) Registers listener.
void	unregister(UUID routineId, GridKernalContext ctx) Unregisters listener.

Methods inherited from interface java.io.Externalizable

readExternal, writeExternal

Method Detail

register

boolean register(UUID nodeId,
               UUID routineId,
               GridKernalContext ctx)
                 throws GridException

Registers listener.

Parameters:

nodeId - ID of the node that started routine.

routineId - Routine ID.

ctx - Kernal context.

Returns:

Whether listener was actually registered.

Throws:

GridException - In case of error.

onListenerRegistered

void onListenerRegistered(UUID routineId,
                        GridKernalContext ctx)

Callback called after listener is registered and acknowledgement is sent.

Parameters:

routineId - Routine ID.

ctx - Kernal context.

unregister

void unregister(UUID routineId,
              GridKernalContext ctx)

Unregisters listener.

Parameters:

routineId - Routine ID.

ctx - Kernal context.

notifyCallback

void notifyCallback(UUID nodeId,
                  UUID routineId,
                  Collection<?> objs,
                  GridKernalContext ctx)

Notifies local callback.

Parameters:

nodeId - ID of the node where notification came from.

routineId - Routine ID.

objs - Notification objects.

ctx - Kernal context.

p2pMarshal

void p2pMarshal(GridKernalContext ctx)
                throws GridException

Deploys and marshals inner objects (called only if peer deployment is enabled).

Parameters:

ctx - Kernal context.

Throws:

GridException - In case of error.

p2pUnmarshal

void p2pUnmarshal(UUID nodeId,
                GridKernalContext ctx)
                  throws GridException

Unmarshals inner objects (called only if peer deployment is enabled).

Parameters:

nodeId - Sender node ID.

ctx - Kernal context.

Throws:

GridException - In case of error.

orderedTopic

@Nullable
Object orderedTopic()

Returns:

Topic for ordered notifications. If null, notifications will be sent in non-ordered messages.