com.caucho.distcache.websocket

Class WebSocketBareClient

java.lang.Object

com.caucho.distcache.websocket.WebSocketBareClient

All Implemented Interfaces:

WebSocketConstants, WebSocketContext

public class WebSocketBareClient
extends java.lang.Object
implements WebSocketContext, WebSocketConstants

WebSocketClient

Field Summary

Fields inherited from interface com.caucho.remote.websocket.WebSocketConstants

CLOSE_ERROR, CLOSE_MESSAGE_TOO_BIG, CLOSE_OK, CLOSE_UTF8, FLAG_FIN, FLAG_MASK, MASK_OPCODE, OP_BINARY, OP_CLOSE, OP_CONT, OP_PING, OP_PONG, OP_TEXT, VERSION

Constructor Summary

Constructors

Constructor and Description
WebSocketBareClient(java.lang.String address, int port, int extensionId, WebSocketEndpoint endpoint)

Method Summary

Modifier and Type	Method and Description
void	close() gracefully close the connection, waiting for unread messages.
void	close(int code, java.lang.String msg) gracefully close the connection, waiting for unread messages.
void	connect()
void	connect(java.lang.String userName, java.lang.String password)
protected void	connectImpl(java.lang.String userName, java.lang.String password)
<T> java.util.concurrent.BlockingQueue<T>	createOutputQueue(WebSocketEncoder<T> encoder) Creates a thread-safe queue, which applications can send objects to be marshaled.
void	disconnect() Disconnect the connection.
void	flush() flushes the output stream
java.io.InputStream	getInputStream()
protected java.lang.String	getProtocolHeader()
long	getTimeout() Gets the read timeout.
boolean	isAutoFlush() returns the current flush mode.
boolean	isClosed()
void	onClose(int closeCode, java.lang.String closeMessage)
void	pong(byte[] message) sends a pong message
void	setAutoFlush(boolean isAutoFlush) auto-flush after each message is sent.
void	setConnectTimeout(long timeout)
void	setEndpoint(WebSocketEndpoint endpoint)
void	setProtocolHeader(java.lang.String header)
void	setTimeout(long timeout) Sets the read timeout.
java.io.OutputStream	startBinaryMessage() Returns the output stream for a binary message.
java.io.PrintWriter	startTextMessage() Returns the output stream for a binary message.
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

WebSocketBareClient

public WebSocketBareClient(java.lang.String address,
                           int port,
                           int extensionId,
                           WebSocketEndpoint endpoint)

Method Detail

setConnectTimeout

public void setConnectTimeout(long timeout)

setProtocolHeader

public void setProtocolHeader(java.lang.String header)

setEndpoint

public void setEndpoint(WebSocketEndpoint endpoint)

getProtocolHeader

protected java.lang.String getProtocolHeader()

connect

public void connect()
             throws java.io.IOException

Throws:

java.io.IOException

connect

public void connect(java.lang.String userName,
                    java.lang.String password)
             throws java.io.IOException

Throws:

java.io.IOException

connectImpl

protected void connectImpl(java.lang.String userName,
                           java.lang.String password)
                    throws java.io.IOException

Throws:

java.io.IOException

disconnect

public void disconnect()

Description copied from interface: WebSocketContext

Disconnect the connection.

Specified by:

disconnect in interface WebSocketContext

createOutputQueue

public <T> java.util.concurrent.BlockingQueue<T> createOutputQueue(WebSocketEncoder<T> encoder)

Description copied from interface: WebSocketContext

Creates a thread-safe queue, which applications can send objects to be marshaled.

Specified by:

createOutputQueue in interface WebSocketContext

setAutoFlush

public void setAutoFlush(boolean isAutoFlush)

Description copied from interface: WebSocketContext

auto-flush after each message is sent.

Specified by:

setAutoFlush in interface WebSocketContext

isAutoFlush

public boolean isAutoFlush()

Description copied from interface: WebSocketContext

returns the current flush mode.

Specified by:

isAutoFlush in interface WebSocketContext

flush

public void flush()
           throws java.io.IOException

Description copied from interface: WebSocketContext

flushes the output stream

Specified by:

flush in interface WebSocketContext

Throws:

java.io.IOException

isClosed

public boolean isClosed()

close

public void close()

Description copied from interface: WebSocketContext

gracefully close the connection, waiting for unread messages.

Specified by:

close in interface WebSocketContext

close

public void close(int code,
                  java.lang.String msg)

Description copied from interface: WebSocketContext

gracefully close the connection, waiting for unread messages.

Specified by:

close in interface WebSocketContext

getInputStream

public java.io.InputStream getInputStream()

startBinaryMessage

public java.io.OutputStream startBinaryMessage()
                                        throws java.io.IOException

Description copied from interface: WebSocketContext

Returns the output stream for a binary message. The message will complete when the OutputStream is closed.

Specified by:

startBinaryMessage in interface WebSocketContext

Throws:

java.io.IOException

startTextMessage

public java.io.PrintWriter startTextMessage()

Description copied from interface: WebSocketContext

Returns the output stream for a binary message. The message will complete when the Writer is closed.

Specified by:

startTextMessage in interface WebSocketContext

getTimeout

public long getTimeout()

Description copied from interface: WebSocketContext

Gets the read timeout.

Specified by:

getTimeout in interface WebSocketContext

setTimeout

public void setTimeout(long timeout)

Description copied from interface: WebSocketContext

Sets the read timeout.

Specified by:

setTimeout in interface WebSocketContext

pong

public void pong(byte[] message)
          throws java.io.IOException

Description copied from interface: WebSocketContext

sends a pong message

Specified by:

pong in interface WebSocketContext

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

onClose

public void onClose(int closeCode,
                    java.lang.String closeMessage)

Specified by:

onClose in interface WebSocketContext