org.apache.streams.neo4j.http

Class Neo4jHttpPersistWriter

java.lang.Object

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

org.apache.streams.neo4j.http.Neo4jHttpPersistWriter

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsPersistWriter

public class Neo4jHttpPersistWriter
extends SimpleHTTPPostPersistWriter

Adds activityobjects as vertices and activities as edges to a graph database with an http rest endpoint (such as neo4j).

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected ReadWriteLock	lock
static String	STREAMS_ID

Fields inherited from class org.apache.streams.components.http.persist.SimpleHTTPPostPersistWriter

authHeader, httpclient, uriBuilder

Constructor Summary

Constructors

Constructor and Description
Neo4jHttpPersistWriter() GraphHttpPersistWriter constructor - resolve GraphHttpConfiguration from JVM 'graph'.
Neo4jHttpPersistWriter(Neo4jConfiguration configuration) GraphHttpPersistWriter constructor - use supplied GraphHttpConfiguration.

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)
void	prepare(Object configurationObject)
protected com.fasterxml.jackson.databind.node.ObjectNode	preparePayload(StreamsDatum entry)

Methods inherited from class org.apache.streams.components.http.persist.SimpleHTTPPostPersistWriter

getId, prepareHttpPost, prepareParams, prepareURI, write

Methods inherited from class java.lang.Object

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

Field Detail

STREAMS_ID

public static final String STREAMS_ID

lock

protected final ReadWriteLock lock

Constructor Detail

Neo4jHttpPersistWriter

public Neo4jHttpPersistWriter()

GraphHttpPersistWriter constructor - resolve GraphHttpConfiguration from JVM 'graph'.

Neo4jHttpPersistWriter

public Neo4jHttpPersistWriter(Neo4jConfiguration configuration)

GraphHttpPersistWriter constructor - use supplied GraphHttpConfiguration.

Parameters:

configuration - GraphHttpConfiguration

Method Detail

preparePayload

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

Overrides:

preparePayload in class SimpleHTTPPostPersistWriter

Throws:

Exception

executePost

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

Overrides:

executePost in class SimpleHTTPPostPersistWriter

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface StreamsOperation

Overrides:

prepare in class SimpleHTTPPostPersistWriter

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation

Overrides:

cleanUp in class SimpleHTTPPostPersistWriter