Skip to content

Commit f6615fc

Browse files
committed
Small fix - broadcastReceiver.receive first time
1 parent bfb7b04 commit f6615fc

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

metrics/src/main/java/io/scalecube/metrics/MetricsReaderAgent.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -145,6 +145,10 @@ private int init() {
145145
new BroadcastReceiver(
146146
new UnsafeBuffer(metricsByteBuffer, headerLength, metricsBufferLength)),
147147
new UnsafeBuffer(scratchBuffer));
148+
broadcastReceiver.receive(
149+
(msgTypeId, buffer, index, length) -> {
150+
// no-op
151+
});
148152

149153
state(State.RUNNING);
150154
LOGGER.info("[{}] Initialized, now running", roleName());

0 commit comments

Comments
 (0)