Home
last modified time | relevance | path

Searched refs:message (Results 1 – 25 of 33) sorted by relevance

12

/unit/src/java/javax/websocket/
H A DDecodeException.java28 public DecodeException(ByteBuffer bb, String message, Throwable cause) { in DecodeException() argument
29 super(message, cause); in DecodeException()
33 public DecodeException(String encodedString, String message, in DecodeException() argument
35 super(message, cause); in DecodeException()
39 public DecodeException(ByteBuffer bb, String message) { in DecodeException() argument
40 super(message); in DecodeException()
44 public DecodeException(String encodedString, String message) { in DecodeException() argument
45 super(message); in DecodeException()
H A DDeploymentException.java23 public DeploymentException(String message) { in DeploymentException() argument
24 super(message); in DeploymentException()
27 public DeploymentException(String message, Throwable cause) { in DeploymentException() argument
28 super(message, cause); in DeploymentException()
H A DEncodeException.java25 public EncodeException(Object object, String message) { in EncodeException() argument
26 super(message); in EncodeException()
30 public EncodeException(Object object, String message, Throwable cause) { in EncodeException() argument
31 super(message, cause); in EncodeException()
H A DSessionException.java26 public SessionException(String message, Throwable cause, Session session) { in SessionException() argument
27 super(message, cause); in SessionException()
H A DMessageHandler.java40 void onMessage(T message); in onMessage() argument
/unit/test/node/loader/es_modules_websocket_indirect/
H A Dmodule.mjs20 connection.on('message', function(message) { argument
21 if (message.type === 'utf8') {
22 connection.send(message.utf8Data);
23 } else if (message.type === 'binary') {
24 connection.send(message.binaryData);
/unit/test/node/loader/es_modules_websocket/
H A Dapp.mjs20 connection.on('message', function(message) { argument
21 if (message.type === 'utf8') {
22 connection.send(message.utf8Data);
23 } else if (message.type === 'binary') {
24 connection.send(message.binaryData);
/unit/test/node/websockets/mirror/
H A Dapp.js18 connection.on('message', function(message) { argument
19 if (message.type === 'utf8') {
20 connection.send(message.utf8Data);
21 } else if (message.type === 'binary') {
22 connection.send(message.binaryData);
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerWholeBinary.java91 protected Object decode(ByteBuffer message) throws DecodeException { in decode() argument
94 if (((Binary<?>) decoder).willDecode(message)) { in decode()
95 return ((Binary<?>) decoder).decode(message); in decode()
98 byte[] array = new byte[message.limit() - message.position()]; in decode()
99 message.get(array); in decode()
104 throw new DecodeException(message, sm.getString( in decode()
114 protected Object convert(ByteBuffer message) { in convert() argument
115 byte[] array = new byte[message.remaining()]; in convert()
116 message.get(array); in convert()
H A DPojoMessageHandlerWholeBase.java46 public final void onMessage(T message) { in onMessage() argument
57 payload = decode(message); in onMessage()
66 payload = convert(message); in onMessage()
68 payload = message; in onMessage()
87 protected Object convert(T message) { in convert() argument
88 return message; in convert()
92 protected abstract Object decode(T message) throws DecodeException; in decode() argument
H A DPojoMessageHandlerWholeText.java99 protected Object decode(String message) throws DecodeException { in decode() argument
102 return Util.coerceToType(primitiveType, message); in decode()
107 if (((Text<?>) decoder).willDecode(message)) { in decode()
108 return ((Text<?>) decoder).decode(message); in decode()
111 StringReader r = new StringReader(message); in decode()
115 throw new DecodeException(message, sm.getString( in decode()
125 protected Object convert(String message) { in convert() argument
126 return new StringReader(message); in convert()
H A DPojoMessageHandlerPartialBase.java51 public final void onMessage(T message, boolean last) { in onMessage() argument
65 parameters[indexPayload] = ((ByteBuffer) message).array(); in onMessage()
67 parameters[indexPayload] = message; in onMessage()
H A DPojoMessageHandlerWholePong.java38 protected Object decode(PongMessage message) { in decode() argument
H A DLocalStrings.properties25 pojoMethodMapping.duplicateMessageParam=Multiple message parameters present on the method [{0}] of …
39 pojoMessageHandlerWhole.decodeIoFail=IO error while decoding message
40 pojoMessageHandlerWhole.maxBufferSize=The maximum supported message size for this implementation is…
/unit/test/
H A Dtest_node_es_modules.py34 message = 'blah'
38 self.ws.frame_write(sock, self.ws.OP_TEXT, message)
41 assert message == frame['data'].decode('utf-8'), 'mirror'
43 self.ws.frame_write(sock, self.ws.OP_TEXT, message)
46 assert message == frame['data'].decode('utf-8'), 'mirror 2'
H A Dtest_asgi_websockets.py88 message = 'blah'
92 self.ws.frame_write(sock, self.ws.OP_TEXT, message)
97 self.ws.frame_write(sock, self.ws.OP_TEXT, message)
107 message = 'blah'
128 message = 'blah'
144 message = 'blah'
154 assert message + ' ' + message == frame['data'].decode(
175 message = 'blah'
200 message = '0123456789' * 300
212 assert message == data, 'large'
[all …]
H A Dtest_node_websockets.py67 message = 'blah'
71 self.ws.frame_write(sock, self.ws.OP_TEXT, message)
76 self.ws.frame_write(sock, self.ws.OP_TEXT, message)
86 message = 'blah'
102 message = 'blah'
108 self.ws.frame_write(sock, self.ws.OP_CONT, message)
112 assert message + ' ' + message == frame['data'].decode(
121 message = 'blah'
146 message = '0123456789' * 3000
150 self.ws.frame_write(sock, self.ws.OP_TEXT, message)
[all …]
H A Dtest_java_websockets.py67 message = 'blah'
71 self.ws.frame_write(sock, self.ws.OP_TEXT, message)
74 assert message == frame['data'].decode('utf-8'), 'mirror'
76 self.ws.frame_write(sock, self.ws.OP_TEXT, message)
79 assert message == frame['data'].decode('utf-8'), 'mirror 2'
86 message = 'blah'
102 message = 'blah'
106 self.ws.frame_write(sock, self.ws.OP_TEXT, message, fin=False)
108 self.ws.frame_write(sock, self.ws.OP_CONT, message)
112 assert message + ' ' + message == frame['data'].decode(
[all …]
/unit/test/python/lifespan/failed/
H A Dasgi.py4 message = await receive()
5 if message['type'] == 'lifespan.startup':
9 elif message['type'] == 'lifespan.shutdown':
/unit/test/python/lifespan/empty/
H A Dasgi.py11 message = await receive()
12 if message['type'] == 'lifespan.startup':
15 elif message['type'] == 'lifespan.shutdown':
/unit/src/java/nginx/unit/websocket/
H A DAuthenticationException.java31 public AuthenticationException(String message) { in AuthenticationException() argument
32 super(message); in AuthenticationException()
H A DLocalStrings.properties47 util.invalidMessageHandler=The message handler provided does not have an onMessage(Object) method
69 wsFrame.noContinuation=A new message was started when a continuation frame was expected
74 wsFrame.suspendRequested=Suspend of the message receiving has already been requested.
83 wsRemoteEndpoint.acquireTimeout=The current message was not fully sent within the specified timeout
99 # Note the following message is used as a close reason in a WebSocket control
108 wsSession.duplicateHandlerBinary=A binary message handler has already been configured
109 wsSession.duplicateHandlerPong=A pong message handler has already been configured
110 wsSession.duplicateHandlerText=A text message handler has already been configured
111 wsSession.invalidHandlerTypePong=A pong message handler must implement MessageHandler.Whole
114 wsSession.sendCloseFail=Failed to send close message for session [{0}] to remote endpoint
[all …]
/unit/test/node/websockets/mirror_fragmentation/
H A Dapp.js15 connection.on('message', function(message) { argument
17 connection.send(message.utf8Data);
/unit/test/unit/applications/
H A Dwebsockets.py210 def message(self, sock, type, message, fragmention_size=None, **kwargs): member in TestApplicationWebsocket
211 message_len = len(message)
217 self.frame_write(sock, type, message, **kwargs)
225 self.frame_write(sock, op_code, message[pos:end], fin=fin, **kwargs)
/unit/src/python/
H A Dnxt_python_asgi_lifespan.c468 PyObject *message) in nxt_py_asgi_lifespan_send_startup() argument
476 if (nxt_fast_path(message != NULL && PyUnicode_Check(message))) { in nxt_py_asgi_lifespan_send_startup()
477 message_str = PyUnicode_AsUTF8AndSize(message, &message_len); in nxt_py_asgi_lifespan_send_startup()
538 PyObject *message) in nxt_py_asgi_lifespan_send_shutdown() argument

12