public class SimpleHTTPPostProcessor extends Object implements StreamsProcessor
Modifier and Type | Field and Description |
---|---|
protected String |
authHeader |
protected HttpProcessorConfiguration |
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 and Description |
---|
SimpleHTTPPostProcessor() |
SimpleHTTPPostProcessor(HttpProcessorConfiguration processorConfiguration) |
Modifier and Type | Method and Description |
---|---|
void |
cleanUp() |
protected ActivityObject |
getEntityToExtend(com.fasterxml.jackson.databind.node.ObjectNode rootDocument)
Override this to place result in non-standard location on document
|
String |
getId() |
protected com.fasterxml.jackson.databind.node.ObjectNode |
getRootDocument(StreamsDatum datum)
Override this to place result in non-standard location on document
|
void |
prepare(Object configurationObject) |
protected com.fasterxml.jackson.databind.node.ObjectNode |
prepareExtensionFragment(String entityString)
Override this to store a result other than exact json representation of response
|
org.apache.http.client.methods.HttpPost |
prepareHttpPost(URI uri,
org.apache.http.HttpEntity entity) |
protected Map<String,String> |
prepareParams(StreamsDatum entry)
Override this to add parameters to the request
|
protected org.apache.http.HttpEntity |
preparePayload(StreamsDatum entry)
Override this to add parameters to the request
|
List<StreamsDatum> |
process(StreamsDatum entry) |
protected com.fasterxml.jackson.databind.node.ObjectNode |
setEntityToExtend(com.fasterxml.jackson.databind.node.ObjectNode rootDocument,
ActivityObject activityObject)
Override this to place result in non-standard location on document
|
protected com.fasterxml.jackson.databind.ObjectMapper mapper
protected org.apache.http.client.utils.URIBuilder uriBuilder
protected org.apache.http.impl.client.CloseableHttpClient httpclient
protected HttpProcessorConfiguration configuration
protected String authHeader
public SimpleHTTPPostProcessor()
public SimpleHTTPPostProcessor(HttpProcessorConfiguration processorConfiguration)
public String getId()
getId
in interface StreamsOperation
protected com.fasterxml.jackson.databind.node.ObjectNode prepareExtensionFragment(String entityString)
protected com.fasterxml.jackson.databind.node.ObjectNode getRootDocument(StreamsDatum datum)
protected ActivityObject getEntityToExtend(com.fasterxml.jackson.databind.node.ObjectNode rootDocument)
protected com.fasterxml.jackson.databind.node.ObjectNode setEntityToExtend(com.fasterxml.jackson.databind.node.ObjectNode rootDocument, ActivityObject activityObject)
public List<StreamsDatum> process(StreamsDatum entry)
process
in interface StreamsProcessor
protected Map<String,String> prepareParams(StreamsDatum entry)
protected org.apache.http.HttpEntity preparePayload(StreamsDatum entry)
public org.apache.http.client.methods.HttpPost prepareHttpPost(URI uri, org.apache.http.HttpEntity entity)
public void prepare(Object configurationObject)
prepare
in interface StreamsOperation
public void cleanUp()
cleanUp
in interface StreamsOperation
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.