From 41f11a14e36628fb0b74850b7335acf46bf8ec2a Mon Sep 17 00:00:00 2001 From: "selva.andre" Date: Sun, 2 Sep 2012 17:03:04 +0200 Subject: [PATCH] Missed from prev commit --- .../messaging/spi/impl/ValueEvent.java | 29 +++++++++++++++++++ 1 file changed, 29 insertions(+) create mode 100644 parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/ValueEvent.java diff --git a/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/ValueEvent.java b/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/ValueEvent.java new file mode 100644 index 00000000..1ec5d6cb --- /dev/null +++ b/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/ValueEvent.java @@ -0,0 +1,29 @@ +package org.dna.mqtt.moquette.messaging.spi.impl; + +import com.lmax.disruptor.EventFactory; +import org.dna.mqtt.moquette.messaging.spi.impl.events.MessagingEvent; + +/** + * Carrier value object for the RingBuffer. + * + * @author andrea + */ +public final class ValueEvent { + + private MessagingEvent m_event; + + public MessagingEvent getEvent() { + return m_event; + } + + public void setEvent(MessagingEvent event) { + m_event = event; + } + + public final static EventFactory EVENT_FACTORY = new EventFactory() { + + public ValueEvent newInstance() { + return new ValueEvent(); + } + }; +}