Package org.jbpm.process.workitem.kafka
Class KafkaWorkItemHandler
- java.lang.Object
-
- org.jbpm.process.workitem.core.AbstractLogOrThrowWorkItemHandler
-
- org.jbpm.process.workitem.kafka.KafkaWorkItemHandler
-
- All Implemented Interfaces:
org.kie.api.runtime.process.WorkItemHandler
,org.kie.internal.runtime.Cacheable
@Wid(widfile="KafkaWorkItem.wid",name="KafkaPublishMessages",displayName="KafkaPublishMessages",defaultHandler="mvel: new org.jbpm.process.workitem.kafka.KafkaWorkItemHandler(\"bootstrapServers\", \"clientId\", \"keySerializerClass\", \"valueSerializerClass\")",documentation="kafka-workitem/index.html",category="kafka-workitem",icon="KafkaPublishMessages.png",parameters={@WidParameter(name="Topic",required=true),@WidParameter(name="Key",required=true),@WidParameter(name="Value",required=true)},results=@WidResult(name="Result"),mavenDepends=@WidMavenDepends(group="org.jbpm.contrib",artifact="kafka-workitem",version="7.71.0-SNAPSHOT"),serviceInfo=@WidService(category="Kafka",description="publish kafka messages from a process",keywords="kafka,publish,message,topic",action=@WidAction(title="Publish message to a kafka topic"),authinfo=@WidAuth(required=true,params={"bootstrapServers","clientId","keySerializerClass","valueSerializerClass"},paramsdescription={"Bootstrap Servers","Client ID","Key Serializer class","Value Serializer class"},referencesite="https://red.ht/kafka-wih-params"))) public class KafkaWorkItemHandler extends org.jbpm.process.workitem.core.AbstractLogOrThrowWorkItemHandler implements org.kie.internal.runtime.Cacheable
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
KafkaWorkItemHandler.KafkaWorkItemHandlerProducerCommand
-
Constructor Summary
Constructors Constructor Description KafkaWorkItemHandler()
KafkaWorkItemHandler(ClassLoader classLoader)
KafkaWorkItemHandler(ClassLoader classLoader, org.kie.internal.runtime.manager.InternalRuntimeManager runtimeManager)
KafkaWorkItemHandler(String bootstrapServers, String clientId, String keySerializerClass, String valueSerializerClass)
KafkaWorkItemHandler(String bootstrapServers, String clientId, String keySerializerClass, String valueSerializerClass, ClassLoader classLoader)
KafkaWorkItemHandler(String bootstrapServers, String clientId, String keySerializerClass, String valueSerializerClass, ClassLoader classLoader, org.kie.internal.runtime.manager.InternalRuntimeManager runtimeManager)
KafkaWorkItemHandler(Properties properties, org.apache.kafka.clients.producer.Producer producer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
abortWorkItem(org.kie.api.runtime.process.WorkItem workItem, org.kie.api.runtime.process.WorkItemManager manager)
void
close()
void
executeWorkItem(org.kie.api.runtime.process.WorkItem workItem, org.kie.api.runtime.process.WorkItemManager manager)
protected long
getProcessInstanceId(org.kie.api.runtime.process.WorkItem workItem)
boolean
isEmpty(String val)
-
-
-
Constructor Detail
-
KafkaWorkItemHandler
public KafkaWorkItemHandler(Properties properties, org.apache.kafka.clients.producer.Producer producer)
-
KafkaWorkItemHandler
public KafkaWorkItemHandler()
-
KafkaWorkItemHandler
public KafkaWorkItemHandler(ClassLoader classLoader)
-
KafkaWorkItemHandler
public KafkaWorkItemHandler(ClassLoader classLoader, org.kie.internal.runtime.manager.InternalRuntimeManager runtimeManager)
-
KafkaWorkItemHandler
public KafkaWorkItemHandler(String bootstrapServers, String clientId, String keySerializerClass, String valueSerializerClass)
-
KafkaWorkItemHandler
public KafkaWorkItemHandler(String bootstrapServers, String clientId, String keySerializerClass, String valueSerializerClass, ClassLoader classLoader)
-
KafkaWorkItemHandler
public KafkaWorkItemHandler(String bootstrapServers, String clientId, String keySerializerClass, String valueSerializerClass, ClassLoader classLoader, org.kie.internal.runtime.manager.InternalRuntimeManager runtimeManager)
-
-
Method Detail
-
isEmpty
public boolean isEmpty(String val)
-
executeWorkItem
public void executeWorkItem(org.kie.api.runtime.process.WorkItem workItem, org.kie.api.runtime.process.WorkItemManager manager)
- Specified by:
executeWorkItem
in interfaceorg.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 interfaceorg.kie.api.runtime.process.WorkItemHandler
-
close
public void close()
- Specified by:
close
in interfaceorg.kie.internal.runtime.Cacheable
-
getProcessInstanceId
protected long getProcessInstanceId(org.kie.api.runtime.process.WorkItem workItem)
-
-