Class IncomingStream

java.lang.Object

services.moleculer.stream.IncomingStream

public class IncomingStream
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
IncomingStream(String nodeID, ScheduledExecutorService scheduler, long timeoutMillis)

Method Summary

Modifier and Type	Method	Description
void	error(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 Object

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

Field Details

nodeID

protected final 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 HashMap<Long, io.datatree.Tree> pool

inited

protected AtomicBoolean inited

Constructor Details

IncomingStream

public IncomingStream(String nodeID,
 ScheduledExecutorService scheduler,
 long timeoutMillis)

Method Details

reset

public void reset()

Used for testing. Resets internal variables.

error

public void error(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()