org.apache.streams.components.http.persist

Class SimpleHTTPPostPersistWriter

java.lang.Object

org.apache.streams.components.http.persist.SimpleHTTPPostPersistWriter

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsPersistWriter

public class SimpleHTTPPostPersistWriter
extends Object
implements StreamsPersistWriter

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected String	authHeader
protected HttpPersistWriterConfiguration	configuration
protected org.apache.http.impl.client.CloseableHttpClient	httpclient
protected com.fasterxml.jackson.databind.ObjectMapper	mapper
protected org.apache.http.client.utils.URIBuilder	uriBuilder

Constructor Summary

Constructors

Constructor and Description
SimpleHTTPPostPersistWriter()
SimpleHTTPPostPersistWriter(HttpPersistWriterConfiguration configuration)

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
protected com.fasterxml.jackson.databind.node.ObjectNode	executePost(org.apache.http.client.methods.HttpPost httpPost)
String	getId()
void	prepare(Object configurationObject)
org.apache.http.client.methods.HttpPost	prepareHttpPost(URI uri, com.fasterxml.jackson.databind.node.ObjectNode payload) Override this to add headers to the request.
protected Map<String,String>	prepareParams(StreamsDatum entry) Override this to add parameters to the request.
protected com.fasterxml.jackson.databind.node.ObjectNode	preparePayload(StreamsDatum entry) Override this to alter json payload on to the request.
protected URI	prepareURI(Map<String,String> params) Override this to alter request URI.
void	write(StreamsDatum entry)

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 HttpPersistWriterConfiguration configuration

authHeader

protected String authHeader

Constructor Detail

SimpleHTTPPostPersistWriter

public SimpleHTTPPostPersistWriter()

SimpleHTTPPostPersistWriter

public SimpleHTTPPostPersistWriter(HttpPersistWriterConfiguration configuration)

Method Detail

getId

public String getId()

Specified by:

getId in interface StreamsOperation

write

public void write(StreamsDatum entry)

Specified by:

write in interface StreamsPersistWriter

prepareURI

protected URI prepareURI(Map<String,String> params)

Override this to alter request URI.

prepareParams

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

Override this to add parameters to the request.

preparePayload

protected com.fasterxml.jackson.databind.node.ObjectNode preparePayload(StreamsDatum entry)
                                                                 throws Exception

Override this to alter json payload on to the request.

Throws:

Exception

prepareHttpPost

public org.apache.http.client.methods.HttpPost prepareHttpPost(URI uri,
                                                               com.fasterxml.jackson.databind.node.ObjectNode payload)

Override this to add headers to the request.

executePost

protected com.fasterxml.jackson.databind.node.ObjectNode executePost(org.apache.http.client.methods.HttpPost httpPost)

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface StreamsOperation

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation