services.moleculer.stream

Class IncomingStream

java.lang.Object

services.moleculer.stream.IncomingStream

public class IncomingStream
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.atomic.AtomicBoolean	inited
protected java.lang.String	nodeID Currrent nodeID.
protected java.util.HashMap<java.lang.Long,io.datatree.Tree>	pool
protected long	prevSeq
protected PacketStream	stream Internal stream with listeners.
protected long	timeoutAt Timestamp of the next timeout (0 = no timeout).
protected long	timeoutMillis Stream inactivity/read timeout in MILLISECONDS (0 = no timeout).

Constructor Summary

Constructors

Constructor and Description
IncomingStream(java.lang.String nodeID, java.util.concurrent.ScheduledExecutorService scheduler, long timeoutMillis)

Method Summary

Modifier and Type	Method and Description
void	error(java.lang.Throwable cause)
PacketStream	getPacketStream()
long	getTimeoutAt()
boolean	inited()
protected boolean	processMessage(io.datatree.Tree message)
boolean	receive(io.datatree.Tree message)
void	reset() Used for testing.

Methods inherited from class java.lang.Object

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

Field Detail

nodeID

protected final java.lang.String nodeID

Currrent nodeID.

stream

protected final PacketStream stream

Internal stream with listeners.

timeoutMillis

protected final long timeoutMillis

Stream inactivity/read timeout in MILLISECONDS (0 = no timeout).

timeoutAt

protected volatile long timeoutAt

Timestamp of the next timeout (0 = no timeout).

prevSeq

protected volatile long prevSeq

pool

protected final java.util.HashMap<java.lang.Long,io.datatree.Tree> pool

inited

protected java.util.concurrent.atomic.AtomicBoolean inited

Constructor Detail

IncomingStream

public IncomingStream(java.lang.String nodeID,
                      java.util.concurrent.ScheduledExecutorService scheduler,
                      long timeoutMillis)

Method Detail

reset

public void reset()

Used for testing. Resets internal variables.

error

public void error(java.lang.Throwable cause)

inited

public boolean inited()

receive

public boolean receive(io.datatree.Tree message)

processMessage

protected boolean processMessage(io.datatree.Tree message)

getTimeoutAt

public long getTimeoutAt()

getPacketStream

public PacketStream getPacketStream()