org.alfresco.repo.rawevents

Class AbstractEventProducer

java.lang.Object

org.alfresco.repo.rawevents.AbstractEventProducer

Direct Known Subclasses:

TransactionAwareEventProducer

public abstract class AbstractEventProducer
extends Object

Abstract helper to send events to an endpoint. The AbstractEventProducer acts as a wrapper that provides marshalling for a Camel ProducerTemplate.

A client has the option of creating an event producer without supplying an endpoint. In this case, a endpoint must be provided with every send operation.

A client also has the option to provide an ObjectMapper that will be used to marshal basic POJOs (Plain Old Java Objects) to JSON before sending the event.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	endpoint
protected static String	ERROR_SENDING
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper
protected org.apache.camel.ProducerTemplate	producer

Constructor Summary

Constructors

Constructor and Description
AbstractEventProducer()

Method Summary

Modifier and Type	Method and Description
void	send(String endpointUri, Object event)
void	send(String endpointUri, Object event, Map<String,Object> headers)
void	setEndpoint(String endpoint)
void	setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
void	setProducer(org.apache.camel.ProducerTemplate producer)

Methods inherited from class java.lang.Object

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

Field Detail

ERROR_SENDING

protected static final String ERROR_SENDING

See Also:

Constant Field Values

producer

protected org.apache.camel.ProducerTemplate producer

endpoint

protected String endpoint

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

Constructor Detail

AbstractEventProducer

public AbstractEventProducer()

Method Detail

setProducer

public void setProducer(org.apache.camel.ProducerTemplate producer)

setEndpoint

public void setEndpoint(String endpoint)

setObjectMapper

public void setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

send

public void send(String endpointUri,
                 Object event)

send

public void send(String endpointUri,
                 Object event,
                 Map<String,Object> headers)