org.htmlunit.websocket

Class JettyWebSocketAdapter

java.lang.Object

org.htmlunit.websocket.JettyWebSocketAdapter

All Implemented Interfaces:

WebSocketAdapter

public final class JettyWebSocketAdapter
extends Object
implements WebSocketAdapter

Jetty9 based impl of the WebSocketAdapter. To avoid conflicts with other jetty versions used by projects, we use our own shaded version of jetty9 (https://github.com/HtmlUnit/htmlunit-websocket-client).

Author:

Ronald Brill

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JettyWebSocketAdapter.JettyWebSocketAdapterFactory Our WebSocketAdapterFactory.

Constructor Summary

Constructors

Constructor and Description
JettyWebSocketAdapter(WebClient webClient, WebSocketListener listener) Ctor.

Method Summary

Modifier and Type	Method and Description
void	closeClient() Close the client.
void	closeIncommingSession() Close the incomming session.
void	closeOutgoingSession() Close the outgoing session.
void	connect(URI url) Connects to the given URI.
void	send(Object content) Sends the provided content.
void	start() Starts the client.

Methods inherited from class java.lang.Object

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

Constructor Detail

JettyWebSocketAdapter

public JettyWebSocketAdapter(WebClient webClient,
                             WebSocketListener listener)

Ctor.

Parameters:

webClient - the WebClient

listener - the WebSocketListener

Method Detail

start

public void start()
           throws Exception

Starts the client.

Specified by:

start in interface WebSocketAdapter

Throws:

Exception - in case of error

connect

public void connect(URI url)
             throws Exception

Connects to the given URI.

Specified by:

connect in interface WebSocketAdapter

Parameters:

url - the target url

Throws:

Exception - in case of error

send

public void send(Object content)
          throws IOException

Sends the provided content.

Specified by:

send in interface WebSocketAdapter

Parameters:

content - the content to be sent

Throws:

IOException - in case of error

closeIncommingSession

public void closeIncommingSession()

Close the incomming session.

Specified by:

closeIncommingSession in interface WebSocketAdapter

closeOutgoingSession

public void closeOutgoingSession()

Close the outgoing session.

Specified by:

closeOutgoingSession in interface WebSocketAdapter

closeClient

public void closeClient()
                 throws Exception

Close the client.

Specified by:

closeClient in interface WebSocketAdapter

Throws:

Exception - in case of error