org.xbib.elasticsearch.action.websocket.pubsub

Class PublishAction

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.PublishAction

All Implemented Interfaces:

InteractiveHandler

public class PublishAction
extends PublishSubscribe

Publish action

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
PublishAction(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

PublishAction

@Inject
public PublishAction(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)