Skip to content

Commit 463d04a

Browse files
abhijithumbeabhijithumbe
authored andcommitted
[DBACLD-205665] Multiple process-events are pushed into kafka topics if process has wait state
1 parent 440bdad commit 463d04a

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

jbpm-persistence/jbpm-persistence-api/src/main/java/org/jbpm/persistence/api/integration/base/TransactionalPersistenceEventManager.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@ public class TransactionalPersistenceEventManager implements PersistenceEventMan
3939

4040
private static final Logger logger = LoggerFactory.getLogger(TransactionalPersistenceEventManager.class);
4141
private static final String EVENT_COLLECTION = "org.jbpm.integration.events";
42+
protected boolean sendUpdateEvents = Boolean.parseBoolean(System.getProperty("org.kie.jbpm.event.emitters.send-update-events", "true"));
4243

4344
protected TransactionManager tm;
4445
private EventEmitter emitter;
@@ -73,7 +74,7 @@ public void create(InstanceView<?> item) {
7374

7475
@Override
7576
public void update(InstanceView<?> item) {
76-
if (!isActive()) {
77+
if (!isActive()|| !sendUpdateEvents) {
7778
return;
7879
}
7980
EventCollection collection = getCollection();

0 commit comments

Comments
 (0)