org.xbib.elasticsearch.action.websocket.pubsub

Class Checkpointer

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

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

org.xbib.elasticsearch.action.websocket.pubsub.Checkpointer

All Implemented Interfaces:

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

public class Checkpointer
extends org.elasticsearch.common.component.AbstractLifecycleComponent<Checkpointer>

Field Summary

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

lifecycle

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

componentSettings, settings

Constructor Summary

Constructors

Constructor and Description
Checkpointer(org.elasticsearch.common.settings.Settings settings, org.elasticsearch.client.Client client)

Method Summary

Methods

Modifier and Type	Method and Description
void	checkpoint(String id) Checkpointing a topic or a subscriber.
Long	checkpointedAt(String id)
void	deleteBulk(org.elasticsearch.action.delete.DeleteRequest request, InteractiveChannel channel) Perform bulk delete
protected void	doClose()
protected void	doStart()
protected void	doStop()
void	flushBulk(InteractiveChannel channel) Flush bulk
void	flushCheckpoint()
void	indexBulk(org.elasticsearch.action.index.IndexRequest request, InteractiveChannel channel) Perform bulk indexing

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

Constructor Detail

Checkpointer

@Inject
public Checkpointer(org.elasticsearch.common.settings.Settings settings,
                   org.elasticsearch.client.Client client)

Method Detail

doStart

protected void doStart()
                throws org.elasticsearch.ElasticsearchException

Specified by:

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

Throws:

org.elasticsearch.ElasticsearchException

doStop

protected void doStop()
               throws org.elasticsearch.ElasticsearchException

Specified by:

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

Throws:

org.elasticsearch.ElasticsearchException

doClose

protected void doClose()
                throws org.elasticsearch.ElasticsearchException

Specified by:

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

Throws:

org.elasticsearch.ElasticsearchException

checkpoint

public void checkpoint(String id)
                throws IOException

Checkpointing a topic or a subscriber. The current timestamp is written to the checkpoint index type. Note that bulk index requests are used by checkpointing and flushCheckpoint() needs to be called after all is done.

Parameters:

id - topic or subscriber

Throws:

IOException

flushCheckpoint

public void flushCheckpoint()
                     throws IOException

Throws:

IOException

checkpointedAt

public Long checkpointedAt(String id)
                    throws IOException

Throws:

IOException

indexBulk

public void indexBulk(org.elasticsearch.action.index.IndexRequest request,
             InteractiveChannel channel)
               throws IOException

Perform bulk indexing

Parameters:

request - the index request

channel - the interactive channel

Throws:

IOException

deleteBulk

public void deleteBulk(org.elasticsearch.action.delete.DeleteRequest request,
              InteractiveChannel channel)
                throws IOException

Perform bulk delete

Parameters:

request - the delete request

channel - the interactive channel

Throws:

IOException

flushBulk

public void flushBulk(InteractiveChannel channel)
               throws IOException

Flush bulk

Parameters:

channel - the interactive channel

Throws:

IOException