Package org.alfresco.repo.rawevents
Class AbstractEventProducer
- java.lang.Object
-
- org.alfresco.repo.rawevents.AbstractEventProducer
-
- Direct Known Subclasses:
TransactionAwareEventProducer
public abstract class AbstractEventProducer extends java.lang.ObjectAbstract helper to send events to an endpoint. TheAbstractEventProduceracts as a wrapper that provides marshalling for a CamelProducerTemplate.
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 anObjectMapperthat will be used to marshal basic POJOs (Plain Old Java Objects) to JSON before sending the event.
-
-
Field Summary
Fields Modifier and Type Field Description protected java.lang.Stringendpointprotected static java.lang.StringERROR_SENDINGprotected com.fasterxml.jackson.databind.ObjectMapperobjectMapperprotected org.apache.camel.ProducerTemplateproducer
-
Constructor Summary
Constructors Constructor Description AbstractEventProducer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidsend(java.lang.String endpointUri, java.lang.Object event)voidsend(java.lang.String endpointUri, java.lang.Object event, java.util.Map<java.lang.String,java.lang.Object> headers)voidsetEndpoint(java.lang.String endpoint)voidsetObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)voidsetProducer(org.apache.camel.ProducerTemplate producer)
-
-
-
Field Detail
-
ERROR_SENDING
protected static final java.lang.String ERROR_SENDING
- See Also:
- Constant Field Values
-
producer
protected org.apache.camel.ProducerTemplate producer
-
endpoint
protected java.lang.String endpoint
-
objectMapper
protected com.fasterxml.jackson.databind.ObjectMapper objectMapper
-
-
Method Detail
-
setProducer
public void setProducer(org.apache.camel.ProducerTemplate producer)
-
setEndpoint
public void setEndpoint(java.lang.String endpoint)
-
setObjectMapper
public void setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
-
send
public void send(java.lang.String endpointUri, java.lang.Object event)
-
send
public void send(java.lang.String endpointUri, java.lang.Object event, java.util.Map<java.lang.String,java.lang.Object> headers)
-
-