001package org.xbib.elasticsearch.http.netty.client;
002
003import org.elasticsearch.common.xcontent.XContentBuilder;
004import org.xbib.elasticsearch.websocket.client.WebSocketClient;
005import org.xbib.elasticsearch.websocket.client.WebSocketClientBulkRequest;
006import org.xbib.elasticsearch.http.netty.NettyInteractiveRequest;
007import org.xbib.elasticsearch.http.netty.NettyInteractiveResponse;
008
009import java.io.IOException;
010
011/**
012 * Netty bulk request convenience class.
013 */
014public class NettyWebSocketBulkRequest
015        extends NettyInteractiveRequest
016        implements WebSocketClientBulkRequest {
017
018    public NettyWebSocketBulkRequest(String type) {
019        super.type(type);
020    }
021
022    @Override
023    public NettyWebSocketBulkRequest data(XContentBuilder builder) {
024        super.data(builder);
025        return this;
026    }
027
028    @Override
029    public void send(WebSocketClient client) throws IOException {
030        client.send(new NettyInteractiveResponse(super.type, super.builder).response());
031    }
032
033}