org.apache.streams.components.http.provider

Class SimpleHttpProvider

java.lang.Object

org.apache.streams.components.http.provider.SimpleHttpProvider

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsProvider

public class SimpleHttpProvider
extends Object
implements StreamsProvider

Provider retrieves contents from an known set of urls and passes all resulting objects downstream.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected HttpProviderConfiguration	configuration
protected org.apache.http.impl.client.CloseableHttpClient	httpclient
protected ReadWriteLock	lock
protected com.fasterxml.jackson.databind.ObjectMapper	mapper
protected Queue<StreamsDatum>	providerQueue
protected org.apache.http.client.utils.URIBuilder	uriBuilder

Constructor Summary

Constructors

Constructor and Description
SimpleHttpProvider() SimpleHttpProvider constructor - resolves HttpProcessorConfiguration from JVM 'http'.
SimpleHttpProvider(HttpProviderConfiguration providerConfiguration) SimpleHttpProvider constructor - uses provided HttpProviderConfiguration.

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
String	getId()
boolean	isRunning()
protected List<com.fasterxml.jackson.databind.node.ObjectNode>	parse(com.fasterxml.jackson.databind.JsonNode jsonNode) Override this to change how entity gets converted to objects.
void	prepare(Object configurationObject)
org.apache.http.client.methods.HttpRequestBase	prepareHttpRequest(URI uri) prepareHttpRequest
protected Map<String,String>	prepareParams(StreamsDatum entry) Override this to add parameters to the request.
StreamsResultSet	readCurrent()
StreamsResultSet	readNew(BigInteger sequence)
StreamsResultSet	readRange(org.joda.time.DateTime start, org.joda.time.DateTime end)
protected void	shutdownAndAwaitTermination(ExecutorService pool)
void	startStream()

Methods inherited from class java.lang.Object

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

Field Detail

mapper

protected com.fasterxml.jackson.databind.ObjectMapper mapper

uriBuilder

protected org.apache.http.client.utils.URIBuilder uriBuilder

httpclient

protected org.apache.http.impl.client.CloseableHttpClient httpclient

configuration

protected HttpProviderConfiguration configuration

providerQueue

protected volatile Queue<StreamsDatum> providerQueue

lock

protected final ReadWriteLock lock

Constructor Detail

SimpleHttpProvider

public SimpleHttpProvider()

SimpleHttpProvider constructor - resolves HttpProcessorConfiguration from JVM 'http'.

SimpleHttpProvider

public SimpleHttpProvider(HttpProviderConfiguration providerConfiguration)

SimpleHttpProvider constructor - uses provided HttpProviderConfiguration.

Method Detail

getId

public String getId()

Specified by:

getId in interface StreamsOperation

prepareParams

protected Map<String,String> prepareParams(StreamsDatum entry)

Override this to add parameters to the request.

prepareHttpRequest

public org.apache.http.client.methods.HttpRequestBase prepareHttpRequest(URI uri)

prepareHttpRequest

Parameters:

uri - uri

Returns:

result

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface StreamsOperation

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation

startStream

public void startStream()

Specified by:

startStream in interface StreamsProvider

readCurrent

public StreamsResultSet readCurrent()

Specified by:

readCurrent in interface StreamsProvider

parse

protected List<com.fasterxml.jackson.databind.node.ObjectNode> parse(com.fasterxml.jackson.databind.JsonNode jsonNode)

Override this to change how entity gets converted to objects.

readNew

public StreamsResultSet readNew(BigInteger sequence)

Specified by:

readNew in interface StreamsProvider

readRange

public StreamsResultSet readRange(org.joda.time.DateTime start,
                                  org.joda.time.DateTime end)

Specified by:

readRange in interface StreamsProvider

isRunning

public boolean isRunning()

Specified by:

isRunning in interface StreamsProvider

shutdownAndAwaitTermination

protected void shutdownAndAwaitTermination(ExecutorService pool)