Class MessageNode

java.lang.Object

io.aether.cloud.client.MessageNode

All Implemented Interfaces:

io.aether.utils.ToString

public class MessageNode
extends Object
implements io.aether.utils.ToString

Field Summary

Fields

Modifier and Type	Field	Description
final io.aether.utils.slots.EventConsumerWithQueue<byte[]>	bufferIn

Constructor Summary

Constructors

Constructor	Description
MessageNode(AetherCloudClient client, UUID consumer, MessageEventListener strategy)

Method Summary

Modifier and Type	Method	Description
void	addConsumerConnectionOut(ConnectionWork connectionWork)
void	addConsumerServerOut(int id)
void	addConsumerServerOut(io.aether.api.common.ServerDescriptor serverDescriptor)
UUID	getConsumerUUID()
MessageEventListener	getStrategy()
io.aether.utils.futures.AFuture	send(byte[] msg)
void	sendMessageFromServerToClient(byte[] data)
void	setStrategy(MessageEventListener strategy)
<LT> io.aether.net.fastMeta.FastApiContextLocal<LT>	toApi(io.aether.net.fastMeta.FastApiContextLocal<LT> ctx, io.aether.net.fastMeta.FastMetaApi<LT, ? extends LT> metaLt)
<LT> void	toApi(io.aether.net.fastMeta.FastFutureContext ctx, io.aether.net.fastMeta.FastMetaApi<LT, ? extends LT> metaLt, LT localApi)
<LT> io.aether.net.fastMeta.FastApiContextLocal<LT>	toApi(io.aether.net.fastMeta.FastMetaApi<LT, ? extends LT> metaLt, LT localApi)
<LT> io.aether.net.fastMeta.FastApiContextLocal<LT>	toApiR(io.aether.net.fastMeta.FastMetaApi<LT, ? extends LT> metaLt, io.aether.utils.interfaces.AFunction<io.aether.net.fastMeta.FastApiContextLocal<LT>, LT> localApi)
io.aether.utils.AString	toAString(io.aether.utils.AString sb)
void	toConsumer(io.aether.utils.interfaces.AConsumer<byte[]> o)
String	toString()

Methods inherited from class Object

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

Methods inherited from interface io.aether.utils.ToString

toString2

Field Details

bufferIn

public final io.aether.utils.slots.EventConsumerWithQueue<byte[]> bufferIn

Constructor Details

MessageNode

public MessageNode(AetherCloudClient client,
 UUID consumer,
 MessageEventListener strategy)

Method Details

toAString

public io.aether.utils.AString toAString(io.aether.utils.AString sb)

Specified by:

toAString in interface io.aether.utils.ToString

toString

public String toString()

Overrides:

toString in class Object

getStrategy

public MessageEventListener getStrategy()

setStrategy

public void setStrategy(MessageEventListener strategy)

send

public io.aether.utils.futures.AFuture send(byte[] msg)

getConsumerUUID

public UUID getConsumerUUID()

addConsumerServerOut

public void addConsumerServerOut(int id)

addConsumerServerOut

public void addConsumerServerOut(io.aether.api.common.ServerDescriptor serverDescriptor)

addConsumerConnectionOut

public void addConsumerConnectionOut(ConnectionWork connectionWork)

sendMessageFromServerToClient

public void sendMessageFromServerToClient(byte[] data)

toConsumer

public void toConsumer(io.aether.utils.interfaces.AConsumer<byte[]> o)

toApiR

public <LT>
io.aether.net.fastMeta.FastApiContextLocal<LT> toApiR(io.aether.net.fastMeta.FastMetaApi<LT, ? extends LT> metaLt,
 io.aether.utils.interfaces.AFunction<io.aether.net.fastMeta.FastApiContextLocal<LT>, LT> localApi)

toApi

public <LT> void toApi(io.aether.net.fastMeta.FastFutureContext ctx,
 io.aether.net.fastMeta.FastMetaApi<LT, ? extends LT> metaLt,
 LT localApi)

toApi

public <LT>
io.aether.net.fastMeta.FastApiContextLocal<LT> toApi(io.aether.net.fastMeta.FastApiContextLocal<LT> ctx,
 io.aether.net.fastMeta.FastMetaApi<LT, ? extends LT> metaLt)

toApi

public <LT>
io.aether.net.fastMeta.FastApiContextLocal<LT> toApi(io.aether.net.fastMeta.FastMetaApi<LT, ? extends LT> metaLt,
 LT localApi)