Class TransactionAwareEventForwarder

  • All Implemented Interfaces:
    EventForwarder, org.springframework.beans.factory.InitializingBean

    public class TransactionAwareEventForwarder
    extends java.lang.Object
    implements EventForwarder, org.springframework.beans.factory.InitializingBean

    TransactionAwareEventForwarder class.

    Author:
    Mathew Brozowski, DJ Gregor
    • Constructor Detail

      • TransactionAwareEventForwarder

        public TransactionAwareEventForwarder()
      • TransactionAwareEventForwarder

        public TransactionAwareEventForwarder​(EventForwarder forwarder)
                                       throws java.lang.Exception
        Throws:
        java.lang.Exception
    • Method Detail

      • setEventForwarder

        public void setEventForwarder​(EventForwarder eventForwarder)
      • afterPropertiesSet

        public void afterPropertiesSet()
                                throws java.lang.Exception
        Specified by:
        afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean
        Throws:
        java.lang.Exception
      • sendNow

        public void sendNow​(Event event)
        Asynchronously sends an event to eventd.
        Specified by:
        sendNow in interface EventForwarder
        Parameters:
        event - a Event object.
      • sendNow

        public void sendNow​(Log eventLog)
        Description copied from interface: EventForwarder
        Asynchronously sends a set of events to eventd.
        Specified by:
        sendNow in interface EventForwarder
        Parameters:
        eventLog - a Log object.
      • sendNowSync

        public void sendNowSync​(Log eventLog)
        Description copied from interface: EventForwarder
        Synchronously sends a set of events to eventd.
        Specified by:
        sendNowSync in interface EventForwarder
        Parameters:
        eventLog - a Log object.
      • requestPendingEventsList

        public java.util.List<Log> requestPendingEventsList()
      • releasePendingEventsList

        public void releasePendingEventsList​(java.util.List<Log> pendingEvents)