/*
* Copyright (c) 2010, 2017 Oracle and/or its affiliates. All rights reserved.
*
* This program and the accompanying materials are made available under the
* terms of the Eclipse Public License v. 2.0, which is available at
* http://www.eclipse.org/legal/epl-2.0.
*
* This Source Code may also be made available under the following Secondary
* Licenses when the conditions for such availability set forth in the
* Eclipse Public License v. 2.0 are satisfied: GNU General Public License,
* version 2 with the GNU Classpath Exception, which is available at
* https://www.gnu.org/software/classpath/license.html.
*
* SPDX-License-Identifier: EPL-2.0 OR GPL-2.0 WITH Classpath-exception-2.0
*/
package org.glassfish.grizzly.websockets;
import org.glassfish.grizzly.GrizzlyFuture;
General WebSocket unit interface.
Author: Alexey Stashok
/**
* General WebSocket unit interface.
*
* @author Alexey Stashok
*/
public interface WebSocket {
Indicates a normal closure, meaning whatever purpose the connection was established for has been fulfilled.
/**
* Indicates a normal closure, meaning whatever purpose the connection was established for has been fulfilled.
*/
int NORMAL_CLOSURE = 1000;
Indicates that an endpoint is "going away", such as a server going down, or a browser having navigated away from
a page.
/**
* Indicates that an endpoint is "going away", such as a server going down, or a browser having navigated away from
* a page.
*/
int END_POINT_GOING_DOWN = 1001;
Indicates that an endpoint is terminating the connection due to a protocol error.
/**
* Indicates that an endpoint is terminating the connection due to a protocol error.
*/
int PROTOCOL_ERROR = 1002;
Indicates that an endpoint is terminating the connection because it has received a type of data it cannot accept
(e.g. an endpoint that understands only text data may send this if it receives a binary message.)
/**
* Indicates that an endpoint is terminating the connection because it has received a type of data it cannot accept
* (e.g. an endpoint that understands only text data may send this if it receives a binary message.)
*/
int INVALID_DATA = 1003;
indicates that an endpoint is terminating the connection because it has received a message that is too large.
/**
* indicates that an endpoint is terminating the connection because it has received a message that is too large.
*/
int MESSAGE_TOO_LARGE = 1004;
a reserved value and MUST NOT be set as a status code in a Close control frame by an endpoint. It is designated
for use in applications expecting a status code to indicate that no status code was actually present.
/**
* a reserved value and MUST NOT be set as a status code in a Close control frame by an endpoint. It is designated
* for use in applications expecting a status code to indicate that no status code was actually present.
*/
int NO_STATUS_CODE = 1005;
a reserved value and MUST NOT be set as a status code in a Close control frame by an endpoint. It is designated
for use in applications expecting a status code to indicate that the connection was closed abnormally, e.g.
without sending or receiving a Close control frame.
/**
* a reserved value and MUST NOT be set as a status code in a Close control frame by an endpoint. It is designated
* for use in applications expecting a status code to indicate that the connection was closed abnormally, e.g.
* without sending or receiving a Close control frame.
*/
int ABNORMAL_CLOSE = 1006;
Send a text frame to the remote end-point.
Returns: GrizzlyFuture
which could be used to control/check the sending completion state.
/**
* <p>
* Send a text frame to the remote end-point.
* <p>
*
* @return {@link GrizzlyFuture} which could be used to control/check the sending completion state.
*/
GrizzlyFuture<DataFrame> send(String data);
Send a binary frame to the remote end-point.
Returns: GrizzlyFuture
which could be used to control/check the sending completion state.
/**
* <p>
* Send a binary frame to the remote end-point.
* </p>
*
* @return {@link GrizzlyFuture} which could be used to control/check the sending completion state.
*/
GrizzlyFuture<DataFrame> send(byte[] data);
Broadcasts the data to the remote end-point set.
Params: - recipients –
- data –
/**
* <p>
* Broadcasts the data to the remote end-point set.
* </p>
*
* @param recipients
* @param data
*/
void broadcast(final Iterable<? extends WebSocket> recipients, String data);
Broadcasts the data to the remote end-point set.
Params: - recipients –
- data –
/**
* <p>
* Broadcasts the data to the remote end-point set.
* </p>
*
* @param recipients
* @param data
*/
void broadcast(final Iterable<? extends WebSocket> recipients, byte[] data);
Broadcasts the data fragment to the remote end-point set.
Params: - recipients –
- data –
/**
* <p>
* Broadcasts the data fragment to the remote end-point set.
* </p>
*
* @param recipients
* @param data
*/
void broadcastFragment(final Iterable<? extends WebSocket> recipients,
String data, boolean last);
Broadcasts the data fragment to the remote end-point set.
Params: - recipients –
- data –
/**
* <p>
* Broadcasts the data fragment to the remote end-point set.
* </p>
*
* @param recipients
* @param data
*/
void broadcastFragment(final Iterable<? extends WebSocket> recipients,
byte[] data, boolean last);
Sends a ping
frame with the specified payload (if any).
Params: - data – optional payload. Note that payload length is restricted
to 125 bytes or less.
Returns: GrizzlyFuture
which could be used to control/check the sending completion state.Since: 2.1.9
/**
* Sends a <code>ping</code> frame with the specified payload (if any).
* </p>
*
* @param data optional payload. Note that payload length is restricted
* to 125 bytes or less.
*
* @return {@link GrizzlyFuture} which could be used to control/check the sending completion state.
*
* @since 2.1.9
*/
GrizzlyFuture<DataFrame> sendPing(byte[] data);
Sends a ping
frame with the specified payload (if any).
It may seem odd to send a pong frame, however, RFC-6455 states:
"A Pong frame MAY be sent unsolicited. This serves as a
unidirectional heartbeat. A response to an unsolicited Pong frame is
not expected."
Params: - data – optional payload. Note that payload length is restricted
to 125 bytes or less.
Returns: GrizzlyFuture
which could be used to control/check the sending completion state.Since: 2.1.9
/**
* <p>
* Sends a <code>ping</code> frame with the specified payload (if any).
* </p>
*
* <p>It may seem odd to send a pong frame, however, RFC-6455 states:</p>
*
* <p>
* "A Pong frame MAY be sent unsolicited. This serves as a
* unidirectional heartbeat. A response to an unsolicited Pong frame is
* not expected."
* </p>
*
* @param data optional payload. Note that payload length is restricted
* to 125 bytes or less.
*
* @return {@link GrizzlyFuture} which could be used to control/check the sending completion state.
*
* @since 2.1.9
*/
GrizzlyFuture<DataFrame> sendPong(byte[] data);
Sends a fragment of a complete message.
Params: - last – boolean indicating if this message fragment is the last.
- fragment – the textual fragment to send.
Returns: GrizzlyFuture
which could be used to control/check the sending completion state.
/**
* <p>
* Sends a fragment of a complete message.
* </p>
*
* @param last boolean indicating if this message fragment is the last.
* @param fragment the textual fragment to send.
*
* @return {@link GrizzlyFuture} which could be used to control/check the sending completion state.
*/
GrizzlyFuture<DataFrame> stream(boolean last, String fragment);
Sends a fragment of a complete message.
Params: - last – boolean indicating if this message fragment is the last.
- fragment – the binary fragment to send.
- off – the offset within the fragment to send.
- len – the number of bytes of the fragment to send.
Returns: GrizzlyFuture
which could be used to control/check the sending completion state.
/**
* <p>
* Sends a fragment of a complete message.
* </p>
*
* @param last boolean indicating if this message fragment is the last.
* @param fragment the binary fragment to send.
* @param off the offset within the fragment to send.
* @param len the number of bytes of the fragment to send.
*
* @return {@link GrizzlyFuture} which could be used to control/check the sending completion state.
*/
GrizzlyFuture<DataFrame> stream(boolean last, byte[] fragment, int off, int len);
Closes this WebSocket
.
/**
* <p>
* Closes this {@link WebSocket}.
* </p>
*/
void close();
Closes this WebSocket
using the specified status code.
Params: - code – the closing status code.
/**
* <p>
* Closes this {@link WebSocket} using the specified status code.
* </p>
*
* @param code the closing status code.
*/
void close(int code);
Closes this WebSocket
using the specified status code and reason.
Params: - code – the closing status code.
- reason – the reason, if any.
/**
* <p>
* Closes this {@link WebSocket} using the specified status code and
* reason.
* </p>
*
* @param code the closing status code.
* @param reason the reason, if any.
*/
void close(int code, String reason);
Convenience method to determine if this WebSocket
is connected.
Returns: true
if the WebSocket
is connected, otherwise false
/**
* <p>
* Convenience method to determine if this {@link WebSocket} is connected.
* </p>
*
* @return <code>true</code> if the {@link WebSocket} is connected, otherwise
* <code>false</code>
*/
boolean isConnected();
This callback will be invoked when the opening handshake between both
endpoints has been completed.
/**
* <p>
* This callback will be invoked when the opening handshake between both
* endpoints has been completed.
* </p>
*/
void onConnect();
This callback will be invoked when a text message has been received.
Params: - text – the text received from the remote end-point.
/**
* <p>
* This callback will be invoked when a text message has been received.
* </p>
*
* @param text the text received from the remote end-point.
*/
void onMessage(String text);
This callback will be invoked when a binary message has been received.
Params: - data – the binary data received from the remote end-point.
/**
* <p>
* This callback will be invoked when a binary message has been received.
* </p>
*
* @param data the binary data received from the remote end-point.
*/
void onMessage(byte[] data);
This callback will be invoked when a fragmented textual message has
been received.
Params: - last – flag indicating whether or not the payload received is the
final fragment of a message.
- payload – the text received from the remote end-point.
/**
* <p>
* This callback will be invoked when a fragmented textual message has
* been received.
* </p>
*
* @param last flag indicating whether or not the payload received is the
* final fragment of a message.
* @param payload the text received from the remote end-point.
*/
void onFragment(boolean last, String payload);
This callback will be invoked when a fragmented binary message has
been received.
Params: - last – flag indicating whether or not the payload received is the
final fragment of a message.
- payload – the binary data received from the remote end-point.
/**
* <p>
* This callback will be invoked when a fragmented binary message has
* been received.
* </p>
*
* @param last flag indicating whether or not the payload received is the
* final fragment of a message.
* @param payload the binary data received from the remote end-point.
*/
void onFragment(boolean last, byte[] payload);
This callback will be invoked when the remote end-point sent a closing
frame.
Params: - frame – the close frame from the remote end-point.
See Also:
/**
* <p>
* This callback will be invoked when the remote end-point sent a closing
* frame.
* </p>
*
* @param frame the close frame from the remote end-point.
*
* @see DataFrame
*/
void onClose(DataFrame frame);
This callback will be invoked when the remote end-point has sent a ping
frame.
Params: - frame – the ping frame from the remote end-point.
See Also:
/**
* <p>
* This callback will be invoked when the remote end-point has sent a ping
* frame.
* </p>
*
* @param frame the ping frame from the remote end-point.
*
* @see DataFrame
*/
void onPing(DataFrame frame);
This callback will be invoked when the remote end-point has sent a pong
frame.
Params: - frame – the pong frame from the remote end-point.
See Also:
/**
* <p>
* This callback will be invoked when the remote end-point has sent a pong
* frame.
* </p>
*
* @param frame the pong frame from the remote end-point.
*
* @see DataFrame
*/
void onPong(DataFrame frame);
Adds a WebSocketListener
to be notified of events of interest. Params: - listener – the
WebSocketListener
to add.
See Also: Returns: true
if the listener was added, otherwise
false
/**
* Adds a {@link WebSocketListener} to be notified of events of interest.
*
* @param listener the {@link WebSocketListener} to add.
*
* @return <code>true</code> if the listener was added, otherwise
* <code>false</code>
*
* @see WebSocketListener
*/
boolean add(WebSocketListener listener);
Removes the specified WebSocketListener
as a target of event notification. Params: - listener – the
WebSocketListener
to remote.
See Also: Returns: true
if the listener was removed, otherwise
false
/**
* Removes the specified {@link WebSocketListener} as a target of event
* notification.
*
* @param listener the {@link WebSocketListener} to remote.
*
* @return <code>true</code> if the listener was removed, otherwise
* <code>false</code>
*
* @see WebSocketListener
*/
boolean remove(WebSocketListener listener);
}