org.xbib.elasticsearch.http.netty.client

Class NettyWebSocketClientFactory

java.lang.Object

org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientFactory

All Implemented Interfaces:

WebSocketClientFactory

public class NettyWebSocketClientFactory
extends Object
implements WebSocketClientFactory

A factory for creating Websocket clients. The entry point for creating and connecting a client. Can and should be used to create multiple instances.

Extended for Websocket client request methods.

Constructor Summary

Constructors

Constructor and Description
NettyWebSocketClientFactory()

Method Summary

Methods

Modifier and Type	Method and Description
WebSocketClientBulkRequest	deleteRequest()
WebSocketClientRequest	flushRequest()
WebSocketClientBulkRequest	indexRequest()
WebSocketClient	newClient(URI url, WebSocketActionListener listener) Create a new WebSocket client
WebSocketClientRequest	newRequest()
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyWebSocketClientFactory

public NettyWebSocketClientFactory()

Method Detail

newClient

public WebSocketClient newClient(URI url,
                        WebSocketActionListener listener)

Create a new WebSocket client

Specified by:

newClient in interface WebSocketClientFactory

Parameters:

url - URL to connect to.

listener - Callback interface to receive events

Returns:

A WebSocket client. Call WebSocketClient.connect() to connect.

shutdown

public void shutdown()

Specified by:

shutdown in interface WebSocketClientFactory

newRequest

public WebSocketClientRequest newRequest()

Specified by:

newRequest in interface WebSocketClientFactory

indexRequest

public WebSocketClientBulkRequest indexRequest()

Specified by:

indexRequest in interface WebSocketClientFactory

deleteRequest

public WebSocketClientBulkRequest deleteRequest()

Specified by:

deleteRequest in interface WebSocketClientFactory

flushRequest

public WebSocketClientRequest flushRequest()

Specified by:

flushRequest in interface WebSocketClientFactory