Package com.opencqrs.esdb.client.jackson

Class JacksonMarshaller

java.lang.Object

com.opencqrs.esdb.client.jackson.JacksonMarshaller

All Implemented Interfaces:

Marshaller

public class JacksonMarshaller
extends Object
implements Marshaller

ObjectMapper based Marshaller implementation.

Nested Class Summary

Nested classes/interfaces inherited from interface com.opencqrs.esdb.client.Marshaller

Marshaller.QueryResponseElement, Marshaller.ResponseElement

Constructor Summary

Constructors

Constructor	Description
JacksonMarshaller(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method	Description
Health	fromHealthResponse(String response)	Used by EsdbClient.health() to transform the HTTP response body to a Health.
Map<String,Object>	fromJsonResponse(String response)	Used by EsdbClient operations to transform any generic HTTP JSON response.
Marshaller.QueryResponseElement	fromQueryResponseLine(String line)	Used by EsdbClient to transform an ND-JSON line from the HTTP response stream to a Marshaller.QueryResponseElement.
Marshaller.ResponseElement	fromReadOrObserveResponseLine(String line)	Used by EsdbClient to transform an ND-JSON line from the HTTP response stream to a Marshaller.ResponseElement.
List<Event>	fromWriteEventsResponse(String response)	Used by EsdbClient.write(List, List) to transform the HTTP response body to a list of Events.
String	toQueryRequest(String query)	Used by EsdbClient to transform the given parameters into a valid HTTP request body to be sent to the event store for query operations.
String	toReadOrObserveEventsRequest(String subject, Set<Option> options)	Used by EsdbClient to transform the given parameters into a valid HTTP request body toe be sent to the event store for read or observe operations.
String	toWriteEventsRequest(List<EventCandidate> eventCandidates, List<Precondition> preconditions)	Used by EsdbClient.write(List, List) to transform the given EventCandidates and Preconditions to a valid HTTP request body to be sent to the event store.

Methods inherited from class java.lang.Object

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

Constructor Details

JacksonMarshaller

public JacksonMarshaller(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Details

fromJsonResponse

public Map<String,Object> fromJsonResponse(String response)

Description copied from interface: Marshaller

Used by EsdbClient operations to transform any generic HTTP JSON response.

Specified by:

fromJsonResponse in interface Marshaller

Parameters:

response - the JSON HTTP response body as string

Returns:

a map representing the JSON response content

fromHealthResponse

public Health fromHealthResponse(String response)

Description copied from interface: Marshaller

Used by EsdbClient.health() to transform the HTTP response body to a Health.

Specified by:

fromHealthResponse in interface Marshaller

Parameters:

response - the JSON HTTP response body as string

Returns:

the Health

toWriteEventsRequest

public String toWriteEventsRequest(List<EventCandidate> eventCandidates,
 List<Precondition> preconditions)

Description copied from interface: Marshaller

Used by EsdbClient.write(List, List) to transform the given EventCandidates and Preconditions to a valid HTTP request body to be sent to the event store.

Specified by:

toWriteEventsRequest in interface Marshaller

Parameters:

eventCandidates - the list of event candidates to include within the request body

preconditions - the preconditions to include within the request body

Returns:

the JSON HTTP request body as string

fromWriteEventsResponse

public List<Event> fromWriteEventsResponse(String response)

Description copied from interface: Marshaller

Used by EsdbClient.write(List, List) to transform the HTTP response body to a list of Events.

Specified by:

fromWriteEventsResponse in interface Marshaller

Parameters:

response - the JSON HTTP response body as string

Returns:

the list of unmarshalled Events

toReadOrObserveEventsRequest

public String toReadOrObserveEventsRequest(String subject,
 Set<Option> options)

Description copied from interface: Marshaller

Used by EsdbClient to transform the given parameters into a valid HTTP request body toe be sent to the event store for read or observe operations.

Specified by:

toReadOrObserveEventsRequest in interface Marshaller

Parameters:

subject - the subject to include within the request body

options - the options to include within the request body

Returns:

the JSON HTTP request body as string

See Also:

• EsdbClient.read(String, Set, Consumer)
• EsdbClient.read(String, Set)
• EsdbClient.observe(String, Set, Consumer)

fromReadOrObserveResponseLine

public Marshaller.ResponseElement fromReadOrObserveResponseLine(String line)

Description copied from interface: Marshaller

Used by EsdbClient to transform an ND-JSON line from the HTTP response stream to a Marshaller.ResponseElement.

Specified by:

fromReadOrObserveResponseLine in interface Marshaller

Parameters:

line - the ND-JSON element as string

Returns:

an unmarshalled Marshaller.ResponseElement

toQueryRequest

public String toQueryRequest(String query)

Description copied from interface: Marshaller

Used by EsdbClient to transform the given parameters into a valid HTTP request body to be sent to the event store for query operations.

Specified by:

toQueryRequest in interface Marshaller

Parameters:

query - the query as string

Returns:

the JSON HTTP request body as string

See Also:

• EsdbClient.query(EventQuery, EventQueryRowHandler, EventQueryErrorHandler)

fromQueryResponseLine

public Marshaller.QueryResponseElement fromQueryResponseLine(String line)

Description copied from interface: Marshaller

Used by EsdbClient to transform an ND-JSON line from the HTTP response stream to a Marshaller.QueryResponseElement.

Specified by:

fromQueryResponseLine in interface Marshaller

Parameters:

line - the ND-JSON element as string

Returns:

an unmarshalled Marshaller.QueryResponseElement