org.xbib.elasticsearch.action.websocket.pubsub

Class ForwardAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.xbib.elasticsearch.websocket.BaseInteractiveHandler

org.xbib.elasticsearch.action.websocket.pubsub.ForwardAction

All Implemented Interfaces:

InteractiveHandler

public class ForwardAction
extends BaseInteractiveHandler

Forwarding a message to a destination.

Field Summary

Fields inherited from class org.xbib.elasticsearch.websocket.BaseInteractiveHandler

client

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

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
ForwardAction(org.elasticsearch.common.settings.Settings settings, org.elasticsearch.client.Client client, HttpServerTransport transport, InteractiveController controller)

Method Summary

Methods

Modifier and Type	Method and Description
void	handleRequest(InteractiveRequest request, InteractiveChannel channel)

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

Constructor Detail

ForwardAction

@Inject
public ForwardAction(org.elasticsearch.common.settings.Settings settings,
                    org.elasticsearch.client.Client client,
                    HttpServerTransport transport,
                    InteractiveController controller)

Method Detail

handleRequest

public void handleRequest(InteractiveRequest request,
                 InteractiveChannel channel)