Skip to content

Commit fe23d9e

Browse files
committed
Add protoc generated classes
1 parent 6623a2c commit fe23d9e

File tree

3 files changed

+20050
-3
lines changed

3 files changed

+20050
-3
lines changed

src/alice/dip/kafka/BeamModeEventsKafkaProducer.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
import alice.dip.AliDip2BK;
2020
import alice.dip.LhcInfoObj;
2121
import alice.dip.kafka.events.Events;
22+
import alice.dip.kafka.events.Common;
2223

2324
/**
2425
* Kafka producer for LHC Beam Mode events, serialized using Protocol Buffers.
@@ -43,16 +44,16 @@ public BeamModeEventsKafkaProducer(String bootstrapServers) {
4344
* @param timestamp - event timestamp at which the beam mode change event was received from DIP
4445
*/
4546
public void sendEvent(Integer fillNumber, LhcInfoObj fill, long timestamp) {
46-
Events.BeamInfo beamInfo = Events.BeamInfo.newBuilder()
47+
Common.BeamInfo beamInfo = Common.BeamInfo.newBuilder()
4748
.setStableBeamsStart(fill.getStableBeamStart())
4849
.setStableBeamsEnd(fill.getStableBeamStop())
4950
.setFillNumber(fill.fillNo)
5051
.setFillingSchemeName(fill.LHCFillingSchemeName)
51-
.setBeamType(Events.BeamType.valueOf(fill.beamType))
52+
.setBeamMode(Common.BeamMode.valueOf(fill.getBeamMode()))
53+
.setBeamType(fill.beamType)
5254
.build();
5355

5456
Events.Ev_BeamModeEvent event = Events.Ev_BeamModeEvent.newBuilder()
55-
.setBeamMode(fill.getBeamMode())
5657
.setTimestamp(timestamp)
5758
.setBeamInfo(beamInfo)
5859
.build();

0 commit comments

Comments
 (0)