org.xbib.elasticsearch.plugin.jdbc.state

Class RiverStateService.RiverStateRequest

java.lang.Object

org.elasticsearch.cluster.ack.ClusterStateUpdateRequest<RiverStateService.RiverStateRequest>

org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService.RiverStateRequest

All Implemented Interfaces:

org.elasticsearch.cluster.ack.AckedRequest

Enclosing class:

RiverStateService

public static class RiverStateService.RiverStateRequest
extends org.elasticsearch.cluster.ack.ClusterStateUpdateRequest<RiverStateService.RiverStateRequest>

Constructor Summary

Constructors

Constructor and Description
RiverStateService.RiverStateRequest(String cause, RiverState riverState) Constructs new register river request

Method Summary

Methods inherited from class org.elasticsearch.cluster.ack.ClusterStateUpdateRequest

ackTimeout, ackTimeout, masterNodeTimeout, masterNodeTimeout

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RiverStateService.RiverStateRequest

public RiverStateService.RiverStateRequest(String cause,
                                   RiverState riverState)

Constructs new register river request

Parameters:

cause - river registration cause

riverState - river state