io.elastic.api

Class EventEmitter

java.lang.Object

io.elastic.api.EventEmitter

public final class EventEmitter
extends java.lang.Object

Used by a Component to communicate with the elastic.io runtime. The implementation of this class has been inspired by the Node.js EventEmitter class.

See Also:

Component

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EventEmitter.Builder Used to build EventEmitter instances.
static interface	EventEmitter.Callback This interface defines a callback to be used by Executor to pass errors, data and snapshots to its callee.

Method Summary

Modifier and Type	Method and Description
EventEmitter	emitData(Message message) Emits a Message.
EventEmitter	emitRebound(java.lang.Object reason) Emits the rebound event specifying a Object reason.
EventEmitter	emitSnapshot(com.google.gson.JsonObject snapshot) Emits JsonObject snapshot.

Methods inherited from class java.lang.Object

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

Method Detail

emitData

public EventEmitter emitData(Message message)

Emits a Message.

Parameters:

message - message to emit

Returns:

this instance

emitSnapshot

public EventEmitter emitSnapshot(com.google.gson.JsonObject snapshot)

Emits JsonObject snapshot.

Parameters:

snapshot - snapshot to emit

Returns:

this instance

emitRebound

public EventEmitter emitRebound(java.lang.Object reason)

Emits the rebound event specifying a Object reason.

Parameters:

reason - reason for rebound

Returns:

this instance