001/* 002 * Copyright (C) 2014 Jörg Prante 003 * 004 * Licensed under the Apache License, Version 2.0 (the "License"); 005 * you may not use this file except in compliance with the License. 006 * You may obtain a copy of the License at 007 * 008 * http://www.apache.org/licenses/LICENSE-2.0 009 * 010 * Unless required by applicable law or agreed to in writing, software 011 * distributed under the License is distributed on an "AS IS" BASIS, 012 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 013 * See the License for the specific language governing permissions and 014 * limitations under the License. 015 */ 016package org.xbib.elasticsearch.action.plugin.jdbc.state.put; 017 018import org.elasticsearch.action.ActionListener; 019import org.elasticsearch.action.support.master.AcknowledgedRequestBuilder; 020import org.elasticsearch.client.ClusterAdminClient; 021import org.xbib.elasticsearch.plugin.jdbc.state.RiverState; 022 023public class PutRiverStateRequestBuilder extends AcknowledgedRequestBuilder<PutRiverStateRequest, PutRiverStateResponse, PutRiverStateRequestBuilder, ClusterAdminClient> { 024 025 public PutRiverStateRequestBuilder(ClusterAdminClient client) { 026 super(client, new PutRiverStateRequest()); 027 } 028 029 public PutRiverStateRequestBuilder setRiverName(String riverName) { 030 request.setRiverName(riverName); 031 return this; 032 } 033 034 public PutRiverStateRequestBuilder setRiverType(String riverType) { 035 request.setRiverType(riverType); 036 return this; 037 } 038 039 public PutRiverStateRequestBuilder setRiverState(RiverState riverState) { 040 request.setRiverState(riverState); 041 return this; 042 } 043 044 @Override 045 protected void doExecute(ActionListener<PutRiverStateResponse> listener) { 046 client.execute(PutRiverStateAction.INSTANCE, request, listener); 047 } 048}