Class AsyncAuditLogProducer

  • All Implemented Interfaces:
    EventListener, org.kie.api.event.process.ProcessEventListener

    public class AsyncAuditLogProducer
    extends AbstractAuditLogger
    Asynchronous log producer that puts audit log events into JMS queue. It expects to have following objects available before it is fully operational:
    • ConnectionFactory - used to create jMS objects required to send a message
    • Queue - JMS destination where messages should be placed
    It sends TextMessages with content of *Log classes (ProcessInstanceLog, NodeInstanceLog, VaraiableInstanceLog) serialized by Xstream. Such serialization allows:
    • use of message selectors to filter which types of events should be processed by different consumer
    • use any consumer to process messages - does not have to be default one
    • use content based routing in more advanced scenarios
    Default receiver is AsyncAuditLogReceiver class
    • Constructor Detail

      • AsyncAuditLogProducer

        public AsyncAuditLogProducer()
      • AsyncAuditLogProducer

        public AsyncAuditLogProducer​(org.kie.api.runtime.KieSession session,
                                     boolean transacted)
    • Method Detail

      • getConnectionFactory

        public javax.jms.ConnectionFactory getConnectionFactory()
      • setConnectionFactory

        public void setConnectionFactory​(javax.jms.ConnectionFactory connectionFactory)
      • getQueue

        public javax.jms.Queue getQueue()
      • setQueue

        public void setQueue​(javax.jms.Queue queue)
      • isTransacted

        public boolean isTransacted()
      • setTransacted

        public void setTransacted​(boolean transacted)
      • beforeNodeTriggered

        public void beforeNodeTriggered​(org.kie.api.event.process.ProcessNodeTriggeredEvent event)
      • onAsyncNodeScheduledEvent

        public void onAsyncNodeScheduledEvent​(org.kie.api.event.process.ProcessAsyncNodeScheduledEvent event)
      • afterNodeLeft

        public void afterNodeLeft​(org.kie.api.event.process.ProcessNodeLeftEvent event)
      • afterVariableChanged

        public void afterVariableChanged​(org.kie.api.event.process.ProcessVariableChangedEvent event)
      • beforeProcessStarted

        public void beforeProcessStarted​(org.kie.api.event.process.ProcessStartedEvent event)
      • afterProcessCompleted

        public void afterProcessCompleted​(org.kie.api.event.process.ProcessCompletedEvent event)
      • afterNodeTriggered

        public void afterNodeTriggered​(org.kie.api.event.process.ProcessNodeTriggeredEvent event)
      • beforeNodeLeft

        public void beforeNodeLeft​(org.kie.api.event.process.ProcessNodeLeftEvent event)
      • beforeVariableChanged

        public void beforeVariableChanged​(org.kie.api.event.process.ProcessVariableChangedEvent event)
      • afterProcessStarted

        public void afterProcessStarted​(org.kie.api.event.process.ProcessStartedEvent event)
      • beforeProcessCompleted

        public void beforeProcessCompleted​(org.kie.api.event.process.ProcessCompletedEvent event)
      • sendMessage

        protected void sendMessage​(Object messageContent,
                                   Integer eventType,
                                   int priority)