From 7b0ac3a373847bd1ecf16d08ffea66b53c6ba026 Mon Sep 17 00:00:00 2001 From: andrea Date: Sat, 18 Aug 2012 17:31:24 +0200 Subject: [PATCH] Added trivial messageID generator on client side --- .../dna/mqtt/commons/MessageIDGenerator.java | 20 +++++++++++++++++++ 1 file changed, 20 insertions(+) create mode 100644 parser/src/main/java/org/dna/mqtt/commons/MessageIDGenerator.java diff --git a/parser/src/main/java/org/dna/mqtt/commons/MessageIDGenerator.java b/parser/src/main/java/org/dna/mqtt/commons/MessageIDGenerator.java new file mode 100644 index 00000000..5a36570a --- /dev/null +++ b/parser/src/main/java/org/dna/mqtt/commons/MessageIDGenerator.java @@ -0,0 +1,20 @@ +package org.dna.mqtt.commons; + +import java.util.concurrent.atomic.AtomicInteger; + +/** + * + * @author andrea + */ +public class MessageIDGenerator { + private AtomicInteger m_current; + + public MessageIDGenerator() { + //NB we start at -1 because the first incAndGet has to return 0 + m_current = new AtomicInteger(-1); + } + + public int next() { + return m_current.incrementAndGet(); + } +}