- fix scheduler

- thread-safe scheduler
- work on voting

1 files changed, 7 insertions, 0 deletions

diff --git a/src/main/java/org/gnunet/construct/MessageIdAnnotationProcessor.java b/src/main/java/org/gnunet/construct/MessageIdAnnotationProcessor.java
index ab80be3..88ed11d 100644
--- a/src/main/java/org/gnunet/construct/MessageIdAnnotationProcessor.java
+++ b/src/main/java/org/gnunet/construct/MessageIdAnnotationProcessor.java
@@ -105,6 +105,13 @@ public class MessageIdAnnotationProcessor extends AbstractProcessor {
                     return false;
                 }
                 String unionName = getClassName(types.asElement(unionInterface));
+                if (idToMember.contains(unionName, ann.value())) {
+                    String existingName = idToMember.get(unionName, ann.value());
+                    processingEnv.getMessager().printMessage(Diagnostic.Kind.ERROR, String.format(
+                            "duplicate message id %s for union '%s: '%s' and '%s'", ann.value(), unionName,
+                            getClassName(e), existingName));
+                    return false;
+                }
                 idToMember.put(unionName, ann.value(), getClassName(e));
             }
         }