org.apache.ignite.internal.processors.platform.events

Class PlatformEvents

java.lang.Object

org.apache.ignite.internal.processors.platform.PlatformAbstractTarget

org.apache.ignite.internal.processors.platform.events.PlatformEvents

All Implemented Interfaces:

PlatformTarget

public class PlatformEvents
extends PlatformAbstractTarget

Interop events.

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget

ERROR, FALSE, log, platformCtx, TRUE

Constructor Summary

Constructors

Constructor and Description
PlatformEvents(PlatformContext platformCtx, IgniteEvents events) Ctor.

Method Summary

Methods

Modifier and Type	Method and Description
protected IgniteInternalFuture	currentFuture() When overridden in a derived class, gets future for the current operation.
protected PlatformFutureUtils.Writer	futureWriter(int opId) When overridden in a derived class, gets a custom future writer.
protected long	processInLongOutLong(int type, long val) Process IN operation.
protected long	processInStreamOutLong(int type, BinaryRawReaderEx reader) Process IN operation.
protected void	processInStreamOutStream(int type, BinaryRawReaderEx reader, BinaryRawWriterEx writer) Process IN-OUT operation.
protected Object	processOutObject(int type) Process OUT operation.
protected void	processOutStream(int type, BinaryRawWriterEx writer) Process OUT operation.

Methods inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget

convertException, inLongOutLong, inObjectStreamOutObjectStream, inStreamOutLong, inStreamOutObject, inStreamOutStream, listenFuture, listenFutureForOperation, outObject, outStream, platformContext, processInObjectStreamOutObjectStream, processInStreamOutLong, processInStreamOutObject, readAndListenFuture, readAndListenFuture, readAndListenFuture, readAndListenFuture, readAndListenFuture, throwUnsupported

Methods inherited from class java.lang.Object

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

Constructor Detail

PlatformEvents

public PlatformEvents(PlatformContext platformCtx,
              IgniteEvents events)

Ctor.

Parameters:

platformCtx - Context.

events - Ignite events.

Method Detail

processInStreamOutLong

protected long processInStreamOutLong(int type,
                          BinaryRawReaderEx reader)
                               throws IgniteCheckedException

Process IN operation.

Overrides:

processInStreamOutLong in class PlatformAbstractTarget

Parameters:

type - Type.

reader - Binary reader.

Returns:

Result.

Throws:

IgniteCheckedException - In case of exception.

processInStreamOutStream

protected void processInStreamOutStream(int type,
                            BinaryRawReaderEx reader,
                            BinaryRawWriterEx writer)
                                 throws IgniteCheckedException

Process IN-OUT operation.

Overrides:

processInStreamOutStream in class PlatformAbstractTarget

Parameters:

type - Type.

reader - Binary reader.

writer - Binary writer.

Throws:

IgniteCheckedException - In case of exception.

processOutStream

protected void processOutStream(int type,
                    BinaryRawWriterEx writer)
                         throws IgniteCheckedException

Process OUT operation.

Overrides:

processOutStream in class PlatformAbstractTarget

Parameters:

type - Type.

writer - Binary writer.

Throws:

IgniteCheckedException - In case of exception.

processOutObject

protected Object processOutObject(int type)
                           throws IgniteCheckedException

Process OUT operation.

Overrides:

processOutObject in class PlatformAbstractTarget

Parameters:

type - Type.

Throws:

IgniteCheckedException - In case of exception.

processInLongOutLong

protected long processInLongOutLong(int type,
                        long val)
                             throws IgniteCheckedException

Process IN operation.

Overrides:

processInLongOutLong in class PlatformAbstractTarget

Parameters:

type - Type.

val - Value.

Returns:

Result.

Throws:

IgniteCheckedException - In case of exception.

currentFuture

protected IgniteInternalFuture currentFuture()
                                      throws IgniteCheckedException

When overridden in a derived class, gets future for the current operation.

Overrides:

currentFuture in class PlatformAbstractTarget

Returns:

current future.

Throws:

IgniteCheckedException - If failed.

futureWriter

@Nullable
protected PlatformFutureUtils.Writer futureWriter(int opId)

When overridden in a derived class, gets a custom future writer.

Overrides:

futureWriter in class PlatformAbstractTarget

Parameters:

opId - Operation id.

Returns:

A custom writer for given op id.