Uses of Class
xyz.cofe.trambda.tcp.TcpHeader
-
-
Uses of TcpHeader in xyz.cofe.trambda.tcp
Fields in xyz.cofe.trambda.tcp declared as TcpHeader Modifier and Type Field Description protected TcpHeaderRawPack. headerЗаголовок пакетаprotected TcpHeaderTcpSession.IncomingMessageEvent. headerMethods in xyz.cofe.trambda.tcp that return TcpHeader Modifier and Type Method Description TcpHeaderRawPack. getHeader()Возвращает заголовок пакетаTcpHeaderRawPackReadonly. getHeader()Methods in xyz.cofe.trambda.tcp that return types with arguments of type TcpHeader Modifier and Type Method Description static Optional<TcpHeader>TcpHeader. parse(byte[] buff, int off, int len)Парсинг заголовкаBiConsumer<ErrMessage,TcpHeader>TcpProtocol. unbindedError()Возвращает обработчик общих ошибок, смTcpProtocol.getErrorConsumers()BiConsumer<Message,TcpHeader>TcpProtocol. unbindedMessage()Возвращает обработчик сообщений, смTcpProtocol.getResponseConsumers()Methods in xyz.cofe.trambda.tcp with parameters of type TcpHeader Modifier and Type Method Description default Optional<T>HeaderValue. parse(TcpHeader header)protected voidTcpProtocol. process(Message msg, TcpHeader header)Обработка входящего сообщения.protected voidTcpProtocol. process(Ping ping, TcpHeader header)При получении Ping сообщения, отсылает ответPongprotected voidTcpProtocol. process(Pong pong, TcpHeader header)При получении ответаPongуведомляет подписанотовTcpProtocol.ping(Consumer), тех кто отправил запрос Pingprotected voidTcpProtocol. process(ServerEvent sevent, TcpHeader header)Обработка входящего серверного события Уведомляет подписчиковTcpProtocol.listenServerEvent(String, Consumer)о серверном событииprotected voidTcpSession. process(Compile compile, TcpHeader header)protected voidTcpSession. process(Execute exec, TcpHeader header)protected voidTcpSession. process(Message msg, TcpHeader header)protected voidTcpSession. process(Ping ping, TcpHeader header)protected voidTcpSession. process(Subscribe msg, TcpHeader header)Обработка запроса подписки на события сервера, смSubscribeprotected voidTcpSession. process(UnSubscribe msg, TcpHeader header)Отписка от событий сервераvoidRawPack. setHeader(TcpHeader header)Указывает заголовок пакетаvoidRawPackReadonly. setHeader(TcpHeader header)Method parameters in xyz.cofe.trambda.tcp with type arguments of type TcpHeader Modifier and Type Method Description TcpProtocolTcpProtocol. unbindedError(BiConsumer<ErrMessage,TcpHeader> cons)Указывает обработчик общих ошибок, смTcpProtocol.getErrorConsumers()TcpProtocolTcpProtocol. unbindedMessage(BiConsumer<Message,TcpHeader> cons)Указывает обработчик сообщений, смTcpProtocol.getResponseConsumers()Constructors in xyz.cofe.trambda.tcp with parameters of type TcpHeader Constructor Description IncomingMessageEvent(TcpSession<ENV> session, T message, TcpHeader header)RawPack(TcpHeader header, byte[] payload)КонструкторRawPackReadonly(TcpHeader header, byte[] payload)
-