Skip to content
Snippets Groups Projects
Commit c21924d6 authored by Florian Fittkau's avatar Florian Fittkau
Browse files

minor

parent 0e9641e2
Branches
Tags
No related merge requests found
...@@ -275,10 +275,10 @@ public class MessageDistributer implements EventHandler<ByteArrayEvent> { ...@@ -275,10 +275,10 @@ public class MessageDistributer implements EventHandler<ByteArrayEvent> {
private void putInRingBuffer(final IRecord record) { private void putInRingBuffer(final IRecord record) {
counter.inputObjects(record); counter.inputObjects(record);
final long hiseq = ringBuffer.next(); // final long hiseq = ringBuffer.next();
final RecordEvent valueEvent = ringBuffer.get(hiseq); // final RecordEvent valueEvent = ringBuffer.get(hiseq);
valueEvent.setValue(record); // valueEvent.setValue(record);
ringBuffer.publish(hiseq); // ringBuffer.publish(hiseq);
} }
public void addToRegistry(final int key, final String value) { public void addToRegistry(final int key, final String value) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment