Uses of Interface
xyz.cofe.trambda.tcp.Message

Uses of Message in xyz.cofe.trambda.tcp

Classes in xyz.cofe.trambda.tcp with type parameters of type Message

Modifier and Type	Class	Description
class	ResultConsumer<Req extends Message,Res extends Message>	Синхронное и асинхронное выполнение запроса
class	ResultConsumer<Req extends Message,Res extends Message>	Синхронное и асинхронное выполнение запроса
static class	TcpSession.IncomingMessageEvent<T extends Message,ENV>	Входящие сообщение
static class	TcpSession.MessageEvent<T extends Message,ENV>	Сообщение
static class	TcpSession.OutgoingMessageEvent<T extends Message,ENV>	Исходящие сообщение

Classes in xyz.cofe.trambda.tcp that implement Message

Modifier and Type	Class	Description
class	Compile	Запрос компиляции лямбды
class	CompileResult	Результат компиляции Compile
class	ErrMessage	Сообщение о ошибке
class	Execute	Запрос выполнения скомпилированной лямбды, Предварительно лямбда должны быть скомпилирована: Compile, CompileResult, TcpClient.compile(LambdaDump), см call(Fn1, SerializedLambda, LambdaDump) ()}
class	ExecuteResult	Результат выполнения Execute
class	Ping	Пинг запрос, ожидается ответ на него Pong
class	Pong	Ответ на Ping запрос
class	ServerEvent	Событие сервера
class	Subscribe	Подписка на уведомления сервера
class	SubscribeResult	Результат подписки (успешное) на событие сервера
class	UnSubscribe	Отписка от событий сервера
class	UnSubscribeResult	Отписка от событий сервера

Fields in xyz.cofe.trambda.tcp declared as Message

Modifier and Type	Field	Description
Message	TcpProtocol.SentRawData.message
protected T	TcpSession.MessageEvent.message
protected T	TcpSession.OutgoingMessageEvent.message
protected Req	ResultConsumer.req	запрос

Fields in xyz.cofe.trambda.tcp with type parameters of type Message

Modifier and Type	Field	Description
protected ThreadLocal<Message>	TcpProtocol.sendMessage

Methods in xyz.cofe.trambda.tcp that return Message

Modifier and Type	Method	Description
Message	RawPackReadonly.payloadMessage()	Возвращает сообщение из пакета

Methods in xyz.cofe.trambda.tcp that return types with arguments of type Message

Modifier and Type	Method	Description
Map<Integer,Consumer<? extends Message>>	TcpProtocol.getResponseConsumers()	Возвращает обработчики на конкретные запросы TcpHeader.getSid()
BiConsumer<Message,TcpHeader>	TcpProtocol.unbindedMessage()	Возвращает обработчик сообщений, см TcpProtocol.getResponseConsumers()

Methods in xyz.cofe.trambda.tcp with parameters of type Message

Modifier and Type	Method	Description
protected void	TcpProtocol.process(Message msg, TcpHeader header)	Обработка входящего сообщения.
protected void	TcpSession.process(Message msg, TcpHeader header)
int	TcpProtocol.send(Message message, Consumer<Integer> sid, HeaderValue<? extends Object>... headerValues)	Отправка сообщения
int	TcpProtocol.send(Message message, HeaderValue<? extends Object>... headerValues)	Отправка сообщения

Method parameters in xyz.cofe.trambda.tcp with type arguments of type Message

Modifier and Type	Method	Description
TcpProtocol	TcpProtocol.unbindedMessage(BiConsumer<Message,TcpHeader> cons)	Указывает обработчик сообщений, см TcpProtocol.getResponseConsumers()