org.xbib.elasticsearch.action.websocket.pubsub

Class SubscribeAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.xbib.elasticsearch.websocket.BaseInteractiveHandler

org.xbib.elasticsearch.action.websocket.pubsub.PublishSubscribe

org.xbib.elasticsearch.action.websocket.pubsub.SubscribeAction

All Implemented Interfaces:

InteractiveHandler

public class SubscribeAction
extends PublishSubscribe

Subscribe action. It performs the subscription of a client to the pubsub index under a given topic.

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	TYPE

Fields inherited from class org.xbib.elasticsearch.action.websocket.pubsub.PublishSubscribe

pubSubIndexName, scrollSize, scrollTimeout, service, transport

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
SubscribeAction(org.elasticsearch.common.settings.Settings settings, org.elasticsearch.client.Client client, HttpServerTransport transport, InteractiveController controller, Checkpointer service)

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

Field Detail

TYPE

protected static final String TYPE

See Also:

Constant Field Values

Constructor Detail

SubscribeAction

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

Method Detail

handleRequest

public void handleRequest(InteractiveRequest request,
                 InteractiveChannel channel)