public final class WebSocketUtils extends Object
Modifier and Type | Field and Description |
---|---|
static Charset |
UTF_8
UTF-8
Charset which is used to encode Strings in WebSockets |
Modifier and Type | Method and Description |
---|---|
static void |
echoFrame(WebSocketChannel channel,
StreamSourceFrameChannel ws)
Echo back the frame to the sender
|
static ByteBuffer |
fromUtf8String(CharSequence utfString)
Create a
ByteBuffer which holds the UTF8 encoded bytes for the
given String . |
static <I extends org.xnio.channels.StreamSourceChannel,O extends org.xnio.channels.StreamSinkChannel> |
initiateTransfer(I source,
O sink,
org.xnio.ChannelListener<? super I> sourceListener,
org.xnio.ChannelListener<? super O> sinkListener,
org.xnio.ChannelExceptionHandler<? super I> readExceptionHandler,
org.xnio.ChannelExceptionHandler<? super O> writeExceptionHandler,
org.xnio.Pool<ByteBuffer> pool)
Initiate a low-copy transfer between two stream channels.
|
static ByteBuffer |
md5(ByteBuffer buffer)
Generate the MD5 hash out of the given
ByteBuffer |
static String |
toUtf8String(ByteBuffer... buffers) |
static String |
toUtf8String(ByteBuffer buffer) |
static long |
transfer(ReadableByteChannel source,
long count,
ByteBuffer throughBuffer,
WritableByteChannel sink)
Transfer the data from the source to the sink using the given through buffer to pass data through.
|
public static ByteBuffer md5(ByteBuffer buffer)
ByteBuffer
public static ByteBuffer fromUtf8String(CharSequence utfString)
ByteBuffer
which holds the UTF8 encoded bytes for the
given String
.utfString
- The String
to convertByteBuffer
which was createdpublic static String toUtf8String(ByteBuffer buffer)
public static String toUtf8String(ByteBuffer... buffers)
public static long transfer(ReadableByteChannel source, long count, ByteBuffer throughBuffer, WritableByteChannel sink) throws IOException
IOException
public static void echoFrame(WebSocketChannel channel, StreamSourceFrameChannel ws) throws IOException
IOException
public static <I extends org.xnio.channels.StreamSourceChannel,O extends org.xnio.channels.StreamSinkChannel> void initiateTransfer(I source, O sink, org.xnio.ChannelListener<? super I> sourceListener, org.xnio.ChannelListener<? super O> sinkListener, org.xnio.ChannelExceptionHandler<? super I> readExceptionHandler, org.xnio.ChannelExceptionHandler<? super O> writeExceptionHandler, org.xnio.Pool<ByteBuffer> pool)
source
- the source channelsink
- the target channelsourceListener
- the source listener to set and call when the transfer is complete, or null
to clear the listener at that timesinkListener
- the target listener to set and call when the transfer is complete, or null
to clear the listener at that timereadExceptionHandler
- the read exception handler to call if an error occurs during a read operationwriteExceptionHandler
- the write exception handler to call if an error occurs during a write operationpool
- the pool from which the transfer buffer should be allocatedCopyright © 2014 JBoss by Red Hat. All rights reserved.