Class Context

java.lang.Object

services.moleculer.context.ContextSource

services.moleculer.context.Context

public class Context
extends ContextSource

Field Summary

Fields

Modifier and Type	Field	Description
protected final long	createdAt	Timestamp
final String	id	Unique context ID
final int	level	Request level (in nested-calls) - the first level is 1
final String	name	Action name
final String	nodeID	Source nodeID
final CallOptions.Options	opts	Calling options
final io.datatree.Tree	params	Request parameters (including meta)
final String	parentID	Parent context ID (in nested-calls)
final String	requestID	Request ID (= first context ID)
final PacketStream	stream	Streamed content

Fields inherited from class ContextSource

eventbus, serviceInvoker, uidGenerator

Constructor Summary

Constructors

Constructor	Description
Context(ServiceInvoker serviceInvoker, Eventbus eventbus, UidGenerator uidGenerator, String id, String name, io.datatree.Tree params, int level, String parentID, String requestID, PacketStream stream, CallOptions.Options opts, String nodeID)

Method Summary

Modifier and Type	Method	Description
protected void	broadcast(String name, io.datatree.Tree payload, Groups groups, PacketStream stream, CallOptions.Options opts, boolean local)
protected io.datatree.Promise	call(String name, io.datatree.Tree params, CallOptions.Options opts, PacketStream stream)	Calls an action (local or remote).
protected void	emit(String name, io.datatree.Tree payload, Groups groups, PacketStream stream, CallOptions.Options opts)
protected io.datatree.Tree	mergeMeta(io.datatree.Tree newParams)
String	toString()

Methods inherited from class ContextSource

broadcast, broadcast, broadcast, broadcast, broadcast, broadcastLocal, broadcastLocal, broadcastLocal, call, call, call, call, call, createStream, emit, emit, emit, emit, emit

Methods inherited from class Object

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

Field Details

id

public final String id

Unique context ID

name

public final String name

Action name

params

public final io.datatree.Tree params

Request parameters (including meta)

level

public final int level

Request level (in nested-calls) - the first level is 1

parentID

public final String parentID

Parent context ID (in nested-calls)

requestID

public final String requestID

Request ID (= first context ID)

stream

public final PacketStream stream

Streamed content

opts

public final CallOptions.Options opts

Calling options

nodeID

public final String nodeID

Source nodeID

createdAt

protected final long createdAt

Timestamp

Constructor Details

Context

public Context(ServiceInvoker serviceInvoker,
 Eventbus eventbus,
 UidGenerator uidGenerator,
 String id,
 String name,
 io.datatree.Tree params,
 int level,
 String parentID,
 String requestID,
 PacketStream stream,
 CallOptions.Options opts,
 String nodeID)

Method Details

emit

protected void emit(String name,
 io.datatree.Tree payload,
 Groups groups,
 PacketStream stream,
 CallOptions.Options opts)

Overrides:

emit in class ContextSource

broadcast

protected void broadcast(String name,
 io.datatree.Tree payload,
 Groups groups,
 PacketStream stream,
 CallOptions.Options opts,
 boolean local)

Overrides:

broadcast in class ContextSource

call

protected io.datatree.Promise call(String name,
 io.datatree.Tree params,
 CallOptions.Options opts,
 PacketStream stream)

Calls an action (local or remote).

Overrides:

call in class ContextSource

Parameters:

name - action name (eg. "math.add" in "service.action" syntax)

params - Tree structure (input parameters of the method call)

opts - calling options (target nodeID, call timeout, number of retries)

stream - streamed data (optional)

Returns:

response Promise

mergeMeta

protected io.datatree.Tree mergeMeta(io.datatree.Tree newParams)

toString

public String toString()

Overrides:

toString in class Object