org.xbib.elasticsearch.action.websocket.pubsub

Class PublishSubscribe

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.xbib.elasticsearch.websocket.BaseInteractiveHandler

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

All Implemented Interfaces:

InteractiveHandler

Direct Known Subclasses:

PublishAction, SubscribeAction

public abstract class PublishSubscribe
extends BaseInteractiveHandler

Base class for Publish/Subscribe actions

Field Summary

Fields

Modifier and Type	Field and Description
protected String	pubSubIndexName
protected int	scrollSize
protected org.elasticsearch.common.unit.TimeValue	scrollTimeout
protected Checkpointer	service
protected HttpServerTransport	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
PublishSubscribe(org.elasticsearch.common.settings.Settings settings, org.elasticsearch.client.Client client, HttpServerTransport transport, InteractiveController controller, Checkpointer service)

Method Summary

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.xbib.elasticsearch.websocket.InteractiveHandler

handleRequest

Field Detail

pubSubIndexName

protected final String pubSubIndexName

transport

protected final HttpServerTransport transport

service

protected final Checkpointer service

scrollTimeout

protected final org.elasticsearch.common.unit.TimeValue scrollTimeout

scrollSize

protected final int scrollSize

See Also:

Constant Field Values

Constructor Detail

PublishSubscribe

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