Skip to content

Commit 92bb339

Browse files
committed
Add event for each new beam mode received
1 parent d3827a8 commit 92bb339

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/alice/dip/DipMessagesProcessor.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -589,6 +589,9 @@ public void newBeamMode(long date, String BeamMode) {
589589

590590
if (currentFill != null) {
591591
currentFill.setBeamMode(date, BeamMode);
592+
if (this.beamModeEventsKafkaProducer != null) {
593+
this.beamModeEventsKafkaProducer.sendEvent(currentFill.fillNo, currentFill, date);
594+
}
592595

593596
int mc = -1;
594597
for (int i = 0; i < AliDip2BK.endFillCases.length; i++) {

0 commit comments

Comments
 (0)