Class AbstractEventProducer

  • Direct Known Subclasses:
    TransactionAwareEventProducer

    public abstract class AbstractEventProducer
    extends java.lang.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 Description
      protected java.lang.String endpoint  
      protected static java.lang.String ERROR_SENDING  
      protected com.fasterxml.jackson.databind.ObjectMapper objectMapper  
      protected org.apache.camel.ProducerTemplate producer  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void send​(java.lang.String endpointUri, java.lang.Object event)  
      void send​(java.lang.String endpointUri, java.lang.Object event, java.util.Map<java.lang.String,​java.lang.Object> headers)  
      void setEndpoint​(java.lang.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

      • producer

        protected org.apache.camel.ProducerTemplate producer
      • endpoint

        protected java.lang.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​(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)