Class JMSSendTaskWorkItemHandler

    • Constructor Detail

      • JMSSendTaskWorkItemHandler

        public JMSSendTaskWorkItemHandler()
      • JMSSendTaskWorkItemHandler

        public JMSSendTaskWorkItemHandler​(String connectionFactoryName,
                                          String destinationName)
      • JMSSendTaskWorkItemHandler

        public JMSSendTaskWorkItemHandler​(javax.jms.ConnectionFactory connectionFactory,
                                          javax.jms.Destination destination)
      • JMSSendTaskWorkItemHandler

        public JMSSendTaskWorkItemHandler​(String connectionFactoryName,
                                          String destinationName,
                                          boolean transacted)
      • JMSSendTaskWorkItemHandler

        public JMSSendTaskWorkItemHandler​(javax.jms.ConnectionFactory connectionFactory,
                                          javax.jms.Destination destination,
                                          boolean transacted)
      • JMSSendTaskWorkItemHandler

        public JMSSendTaskWorkItemHandler​(javax.jms.ConnectionFactory connectionFactory,
                                          javax.jms.Destination destination,
                                          boolean transacted,
                                          boolean doInit)
    • Method Detail

      • init

        protected void init()
      • createMessage

        protected javax.jms.Message createMessage​(org.kie.api.runtime.process.WorkItem workItem,
                                                  javax.jms.Session session)
                                           throws javax.jms.JMSException
        Throws:
        javax.jms.JMSException
      • executeWorkItem

        public void executeWorkItem​(org.kie.api.runtime.process.WorkItem workItem,
                                    org.kie.api.runtime.process.WorkItemManager manager)
        Specified by:
        executeWorkItem in interface org.kie.api.runtime.process.WorkItemHandler
      • abortWorkItem

        public void abortWorkItem​(org.kie.api.runtime.process.WorkItem workItem,
                                  org.kie.api.runtime.process.WorkItemManager manager)
        Specified by:
        abortWorkItem in interface org.kie.api.runtime.process.WorkItemHandler
      • close

        public void close()
        Specified by:
        close in interface org.kie.internal.runtime.Cacheable
      • addPropertyIfExists

        protected void addPropertyIfExists​(String propertyName,
                                           Object properyValue,
                                           javax.jms.Message msg)
                                    throws javax.jms.JMSException
        Throws:
        javax.jms.JMSException