public class JMSSendTaskWorkItemHandler extends AbstractLogOrThrowWorkItemHandler implements org.kie.internal.runtime.Cacheable
logThrownException
Constructor and Description |
---|
JMSSendTaskWorkItemHandler() |
JMSSendTaskWorkItemHandler(javax.jms.ConnectionFactory connectionFactory,
javax.jms.Destination destination) |
JMSSendTaskWorkItemHandler(javax.jms.ConnectionFactory connectionFactory,
javax.jms.Destination destination,
boolean transacted) |
JMSSendTaskWorkItemHandler(javax.jms.ConnectionFactory connectionFactory,
javax.jms.Destination destination,
boolean transacted,
boolean doInit) |
JMSSendTaskWorkItemHandler(String connectionFactoryName,
String destinationName) |
JMSSendTaskWorkItemHandler(String connectionFactoryName,
String destinationName,
boolean transacted) |
Modifier and Type | Method and Description |
---|---|
void |
abortWorkItem(org.kie.api.runtime.process.WorkItem workItem,
org.kie.api.runtime.process.WorkItemManager manager) |
protected void |
addPropertyIfExists(String propertyName,
Object properyValue,
javax.jms.Message msg) |
void |
close() |
protected javax.jms.Message |
createMessage(org.kie.api.runtime.process.WorkItem workItem,
javax.jms.Session session) |
void |
executeWorkItem(org.kie.api.runtime.process.WorkItem workItem,
org.kie.api.runtime.process.WorkItemManager manager) |
protected void |
init() |
findNodeInstance, handleException, handleException, setLogThrownException
public JMSSendTaskWorkItemHandler()
public JMSSendTaskWorkItemHandler(String connectionFactoryName, String destinationName)
public JMSSendTaskWorkItemHandler(javax.jms.ConnectionFactory connectionFactory, javax.jms.Destination destination)
public JMSSendTaskWorkItemHandler(String connectionFactoryName, String destinationName, boolean transacted)
public JMSSendTaskWorkItemHandler(javax.jms.ConnectionFactory connectionFactory, javax.jms.Destination destination, boolean transacted)
public JMSSendTaskWorkItemHandler(javax.jms.ConnectionFactory connectionFactory, javax.jms.Destination destination, boolean transacted, boolean doInit)
protected void init()
protected javax.jms.Message createMessage(org.kie.api.runtime.process.WorkItem workItem, javax.jms.Session session) throws javax.jms.JMSException
javax.jms.JMSException
public void executeWorkItem(org.kie.api.runtime.process.WorkItem workItem, org.kie.api.runtime.process.WorkItemManager manager)
executeWorkItem
in interface org.kie.api.runtime.process.WorkItemHandler
public void abortWorkItem(org.kie.api.runtime.process.WorkItem workItem, org.kie.api.runtime.process.WorkItemManager manager)
abortWorkItem
in interface org.kie.api.runtime.process.WorkItemHandler
public void close()
close
in interface org.kie.internal.runtime.Cacheable
Copyright © 2001–2018 JBoss by Red Hat. All rights reserved.