com.englishtown.vertx.solr.streams.impl

Class SolrPump

java.lang.Object

com.englishtown.vertx.solr.streams.impl.SolrPump

public class SolrPump
extends Object

A Solr implementation of the vertx Pump using JsonObjects instead of Buffers

Method Summary

Modifier and Type	Method and Description
static SolrPump	createPump(ReadJsonStream<?> rs, WriteJsonStream<?> ws) Pumps data from a ReadJsonStream to a WriteJsonStream and performs flow control where necessary to prevent the write stream buffer from getting overfull.
static SolrPump	createPump(ReadJsonStream<?> rs, WriteJsonStream<?> ws, int writeQueueMaxSize) Create a new SolrDataPump with the given ReadJsonStream and WriteJsonStream and writeQueueMaxSize
int	objectsPumped() Return the total number of Json objects pumped by this pump.
SolrPump	setWriteQueueMaxSize(int maxSize) Set the write queue max size to writeQueueMaxSize
SolrPump	start() Start the Pump.
SolrPump	stop() Stop the SolrDataPump.

Methods inherited from class java.lang.Object

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

Method Detail

createPump

public static SolrPump createPump(ReadJsonStream<?> rs,
                                  WriteJsonStream<?> ws)

Pumps data from a ReadJsonStream to a WriteJsonStream and performs flow control where necessary to prevent the write stream buffer from getting overfull.

Instances of this class read bytes from a ReadJsonStream and write them to a WriteJsonStream. This class can be used to pump from any ReadJsonStream to any WriteJsonStream, e.g. from an OffsetReadJsonStream to an WriteJsonStreamBase,

Instances of this class are not thread-safe.

private final WriteJsonStream writeStream; private final ReadJsonStream readJsonStream; private int pumped;

/** Create a new SolrDataPump with the given ReadJsonStream and WriteJsonStream

Parameters:

rs - ReadStream

ws - WriteStream

Returns:

Returns this

createPump

public static SolrPump createPump(ReadJsonStream<?> rs,
                                  WriteJsonStream<?> ws,
                                  int writeQueueMaxSize)

Create a new SolrDataPump with the given ReadJsonStream and WriteJsonStream and writeQueueMaxSize

Parameters:

rs - ReadStream

ws - WriteStream

writeQueueMaxSize - Maximum allowed size of the write queue

Returns:

Returns this

setWriteQueueMaxSize

public SolrPump setWriteQueueMaxSize(int maxSize)

Set the write queue max size to writeQueueMaxSize

Parameters:

maxSize - Maximum size to set for the write queue

Returns:

Returns this

start

public SolrPump start()

Start the Pump. The Pump can be started and stopped multiple times.

Returns:

Returns this

stop

public SolrPump stop()

Stop the SolrDataPump. The SolrDataPump can be started and stopped multiple times.

Returns:

Returns this

objectsPumped

public int objectsPumped()

Return the total number of Json objects pumped by this pump.

Returns:

Returns this