Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
elguardian committed Aug 8, 2024
1 parent dca5ba5 commit 7ccdcf5
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -179,7 +179,7 @@ public <S> void send(Signal<S> signal) {
UnitOfWorkExecutor.<Void> executeInUnitOfWork(services.getUnitOfWorkManager(), () -> {
// this allows to register the external listeners (we don't have event table yet)
List<AbstractProcessInstance> instances = instances().stream(ProcessInstanceReadMode.MUTABLE).map(AbstractProcessInstance.class::cast).toList();
instances.stream().forEach(AbstractProcessInstance::reconnect);
// instances.stream().forEach(AbstractProcessInstance::reconnect);

getProcessRuntime().signalEvent(signal.channel(), signal.payload());
instances.stream().forEach(pi -> {
Expand Down

0 comments on commit 7ccdcf5

Please sign in to comment.