org.xbib.elasticsearch.http.netty

Class NettyWebSocketServerTransport

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.common.component.AbstractLifecycleComponent<HttpServerTransport>

org.xbib.elasticsearch.http.netty.NettyWebSocketServerTransport

All Implemented Interfaces:

org.elasticsearch.common.component.CloseableComponent, org.elasticsearch.common.component.LifecycleComponent<HttpServerTransport>, HttpServerTransport

public class NettyWebSocketServerTransport
extends org.elasticsearch.common.component.AbstractLifecycleComponent<HttpServerTransport>
implements HttpServerTransport

WebSocket server transport. Based on HttpServerTransport. Extended for channel lookup and message forwarding.

Field Summary

Fields

Modifier and Type	Field and Description
protected OpenChannelsHandler	serverOpenChannels

Fields inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

lifecycle

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
NettyWebSocketServerTransport(org.elasticsearch.common.settings.Settings settings, org.elasticsearch.common.network.NetworkService networkService, org.elasticsearch.common.util.BigArrays bigArrays)

Method Summary

Methods

Modifier and Type	Method and Description
org.elasticsearch.common.transport.BoundTransportAddress	boundAddress() Return the bound transport addess
org.jboss.netty.channel.Channel	channel(Integer id) Returns a channel if it is in the server open channel table, given by ID.
protected void	doClose()
protected void	doStart()
protected void	doStop()
void	forward(String websocketNodeAddress, Integer channelId, org.elasticsearch.common.xcontent.XContentBuilder builder) Forward a message to another node with websockets for delivery.
void	httpServerAdapter(HttpServerAdapter httpServerAdapter) Set HTTP server adapter
HttpInfo	info()
org.elasticsearch.common.settings.Settings	settings()
HttpStats	stats() Get HTTP statistics
void	webSocketServerAdapter(WebSocketServerAdapter webSocketServerAdapter) Set WebSocket server adapter

Methods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.common.component.LifecycleComponent

addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from interface org.elasticsearch.common.component.CloseableComponent

close

Field Detail

serverOpenChannels

protected OpenChannelsHandler serverOpenChannels

Constructor Detail

NettyWebSocketServerTransport

@Inject
public NettyWebSocketServerTransport(org.elasticsearch.common.settings.Settings settings,
                                    org.elasticsearch.common.network.NetworkService networkService,
                                    org.elasticsearch.common.util.BigArrays bigArrays)

Method Detail

settings

public org.elasticsearch.common.settings.Settings settings()

httpServerAdapter

public void httpServerAdapter(HttpServerAdapter httpServerAdapter)

Description copied from interface: HttpServerTransport

Set HTTP server adapter

Specified by:

httpServerAdapter in interface HttpServerTransport

webSocketServerAdapter

public void webSocketServerAdapter(WebSocketServerAdapter webSocketServerAdapter)

Description copied from interface: HttpServerTransport

Set WebSocket server adapter

Specified by:

webSocketServerAdapter in interface HttpServerTransport

doStart

protected void doStart()
                throws org.elasticsearch.ElasticsearchException

Specified by:

doStart in class org.elasticsearch.common.component.AbstractLifecycleComponent<HttpServerTransport>

Throws:

org.elasticsearch.ElasticsearchException

doStop

protected void doStop()
               throws org.elasticsearch.ElasticsearchException

Specified by:

doStop in class org.elasticsearch.common.component.AbstractLifecycleComponent<HttpServerTransport>

Throws:

org.elasticsearch.ElasticsearchException

doClose

protected void doClose()
                throws org.elasticsearch.ElasticsearchException

Specified by:

doClose in class org.elasticsearch.common.component.AbstractLifecycleComponent<HttpServerTransport>

Throws:

org.elasticsearch.ElasticsearchException

boundAddress

public org.elasticsearch.common.transport.BoundTransportAddress boundAddress()

Description copied from interface: HttpServerTransport

Return the bound transport addess

Specified by:

boundAddress in interface HttpServerTransport

Returns:

the bound transport addess

info

public HttpInfo info()

Specified by:

info in interface HttpServerTransport

stats

public HttpStats stats()

Description copied from interface: HttpServerTransport

Get HTTP statistics

Specified by:

stats in interface HttpServerTransport

Returns:

a statistics object

channel

public org.jboss.netty.channel.Channel channel(Integer id)

Returns a channel if it is in the server open channel table, given by ID.

Specified by:

channel in interface HttpServerTransport

Parameters:

id - the channel ID

Returns:

the channel if open or null if not present.

forward

public void forward(String websocketNodeAddress,
           Integer channelId,
           org.elasticsearch.common.xcontent.XContentBuilder builder)

Forward a message to another node with websockets for delivery.

Specified by:

forward in interface HttpServerTransport

Parameters:

websocketNodeAddress - the websocket address of the other node, e.g. "/10.0.0.1:9400"

channelId - the channel ID on the other node for delivering the message

builder - the builder for the message