Home
last modified time | relevance | path

Searched refs:MessageHandler (Results 1 – 14 of 14) sorted by relevance

/unit/src/java/nginx/unit/websocket/
H A DMessageHandlerResult.java19 import javax.websocket.MessageHandler;
23 private final MessageHandler handler;
27 public MessageHandlerResult(MessageHandler handler, in MessageHandlerResult()
34 public MessageHandler getHandler() { in getHandler()
H A DWrappedMessageHandler.java19 import javax.websocket.MessageHandler;
24 MessageHandler getWrappedHandler(); in getWrappedHandler()
H A DWsSession.java45 import javax.websocket.MessageHandler;
46 import javax.websocket.MessageHandler.Partial;
47 import javax.websocket.MessageHandler.Whole;
101 private volatile MessageHandler textMessageHandler = null;
103 private volatile MessageHandler binaryMessageHandler = null;
231 public void addMessageHandler(MessageHandler listener) { in addMessageHandler()
309 public Set<MessageHandler> getMessageHandlers() { in getMessageHandlers()
311 Set<MessageHandler> result = new HashSet<>(); in getMessageHandlers()
332 MessageHandler wrapped = null; in removeMessageHandler()
1018 protected MessageHandler getTextMessageHandler() { in getTextMessageHandler()
[all …]
H A DWsFrameBase.java31 import javax.websocket.MessageHandler;
72 private MessageHandler binaryMsgHandler = null;
73 private MessageHandler textMsgHandler = null;
352 MessageHandler.Whole<PongMessage> mhPong = wsSession.getPongMessageHandler(); in processDataControl()
388 if (textMsgHandler instanceof MessageHandler.Partial<?>) { in sendMessageText()
389 ((MessageHandler.Partial<String>) textMsgHandler) in sendMessageText()
393 ((MessageHandler.Whole<String>) textMsgHandler) in sendMessageText()
577 if (binaryMsgHandler instanceof MessageHandler.Partial<?>) { in sendMessageBinary()
581 ((MessageHandler.Whole<ByteBuffer>) binaryMsgHandler).onMessage(msg); in sendMessageBinary()
641 return textMsgHandler instanceof MessageHandler.Partial; in usePartial()
[all …]
H A DUtil.java47 import javax.websocket.MessageHandler;
169 static Class<?> getMessageType(MessageHandler listener) { in getMessageType()
170 return Util.getGenericType(MessageHandler.class, in getMessageType()
362 MessageHandler listener, EndpointConfig endpointConfig, in getMessageHandlers()
388 boolean whole = MessageHandler.Whole.class.isAssignableFrom(listener.getClass()); in getMessageHandlers()
554 private static Method getOnMessageMethod(MessageHandler listener) { in getOnMessageMethod()
563 private static Method getOnMessagePartialMethod(MessageHandler listener) { in getOnMessagePartialMethod()
H A DLocalStrings.properties68 wsFrame.messageTooBig=The message was [{0}] bytes long but the MessageHandler has a limit of [{1}] …
111 wsSession.invalidHandlerTypePong=A pong message handler must implement MessageHandler.Whole
/unit/src/java/javax/websocket/
H A DMessageHandler.java19 public interface MessageHandler { interface
21 interface Partial<T> extends MessageHandler {
33 interface Whole<T> extends MessageHandler {
H A DSession.java50 void addMessageHandler(MessageHandler handler) throws IllegalStateException; in addMessageHandler()
52 Set<MessageHandler> getMessageHandlers(); in getMessageHandlers()
54 void removeMessageHandler(MessageHandler listener); in removeMessageHandler()
173 <T> void addMessageHandler(Class<T> clazz, MessageHandler.Partial<T> handler) in addMessageHandler()
191 <T> void addMessageHandler(Class<T> clazz, MessageHandler.Whole<T> handler) in addMessageHandler()
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerBase.java24 import javax.websocket.MessageHandler;
98 public final MessageHandler getWrappedHandler() { in getWrappedHandler()
99 if (pojo instanceof MessageHandler) { in getWrappedHandler()
100 return (MessageHandler) pojo; in getWrappedHandler()
H A DPojoMethodMapping.java38 import javax.websocket.MessageHandler;
264 public Set<MessageHandler> getMessageHandlers(Object pojo, in getMessageHandlers()
267 Set<MessageHandler> result = new HashSet<>(); in getMessageHandlers()
630 public Set<MessageHandler> getMessageHandlers(Object pojo, in getMessageHandlers()
653 Set<MessageHandler> results = new HashSet<>(2); in getMessageHandlers()
667 MessageHandler mh = new PojoMessageHandlerWholeBinary(pojo, in getMessageHandlers()
672 MessageHandler mh = new PojoMessageHandlerWholeBinary(pojo, in getMessageHandlers()
683 MessageHandler mh = new PojoMessageHandlerWholeBinary( in getMessageHandlers()
691 MessageHandler mh = new PojoMessageHandlerWholeText( in getMessageHandlers()
710 MessageHandler mh = new PojoMessageHandlerPartialBinary( in getMessageHandlers()
[all …]
H A DPojoEndpointBase.java27 import javax.websocket.MessageHandler;
58 for (MessageHandler mh : methodMapping.getMessageHandlers(pojo, in doOnOpen()
113 Set<MessageHandler> messageHandlers = session.getMessageHandlers(); in onClose()
114 for (MessageHandler messageHandler : messageHandlers) { in onClose()
H A DPojoMessageHandlerPartialBase.java24 import javax.websocket.MessageHandler;
36 extends PojoMessageHandlerBase<T> implements MessageHandler.Partial<T> {
H A DPojoMessageHandlerWholeBase.java23 import javax.websocket.MessageHandler;
35 extends PojoMessageHandlerBase<T> implements MessageHandler.Whole<T> {
/unit/auto/modules/
H A Djava494 src/java/javax/websocket/MessageHandler.java \