Update regarding ActorReservedTag

Author: relvaner

actor4j-data/src/main/java/io/actor4j/core/reactive/streams/ReactiveStreamsTag.java renamed to actor4j-data/src/main/java/io/actor4j/core/reactive/streams/ActorReactiveStreamsTag.java

@@ -17,7 +17,7 @@
 
 import static io.actor4j.core.messages.ActorReservedTag.*;
 
-public final class ReactiveStreamsTag {
+public final class ActorReactiveStreamsTag {
 	public static final int SUBSCRIPTION_REQUEST       = RESERVED_REACTIVE_STREAMS_SUBSCRIPTION_REQUEST;
 	public static final int SUBSCRIPTION_REQUEST_RESET = RESERVED_REACTIVE_STREAMS_SUBSCRIPTION_REQUEST_RESET;
 	public static final int SUBSCRIPTION_CANCEL        = RESERVED_REACTIVE_STREAMS_SUBSCRIPTION_CANCEL;

actor4j-data/src/main/java/io/actor4j/core/reactive/streams/PublisherImpl.java

@@ -15,7 +15,7 @@
  */
 package io.actor4j.core.reactive.streams;
 
-import static io.actor4j.core.reactive.streams.ReactiveStreamsTag.*;
+import static io.actor4j.core.reactive.streams.ActorReactiveStreamsTag.*;
 
 import java.util.HashMap;
 import java.util.Iterator;

actor4j-data/src/main/java/io/actor4j/core/reactive/streams/SubscriberImpl.java

@@ -19,7 +19,7 @@
 import io.actor4j.core.function.Procedure;
 import io.actor4j.core.messages.ActorMessage;
 
-import static io.actor4j.core.reactive.streams.ReactiveStreamsTag.*;
+import static io.actor4j.core.reactive.streams.ActorReactiveStreamsTag.*;
 
 import java.util.HashMap;
 import java.util.Map;

actor4j-streams/src/main/java/io/actor4j/streams/core/ActorStreamManager.java

@@ -15,7 +15,7 @@
  */
 package io.actor4j.streams.core;
 
-import static io.actor4j.streams.core.runtime.ActorMessageTag.DATA;
+import static io.actor4j.streams.core.runtime.ActorStreamsTag.DATA;
 
 import java.util.Arrays;
 import java.util.List;

actor4j-streams/src/main/java/io/actor4j/streams/core/runtime/ActorMessageTag.java renamed to actor4j-streams/src/main/java/io/actor4j/streams/core/runtime/ActorStreamsTag.java

@@ -15,10 +15,12 @@
  */
 package io.actor4j.streams.core.runtime;
 
-public final class ActorMessageTag {
-	public static final int DATA     = 1;
-	public static final int TASK     = 2;
-	public static final int REDUCE   = 3;
-	public static final int RESULT   = 4;
-	public static final int SHUTDOWN = 5;
+import static io.actor4j.core.messages.ActorReservedTag.*;
+
+public final class ActorStreamsTag {
+	public static final int DATA     = RESERVED_STREAMS_DATA;
+	public static final int TASK     = RESERVED_STREAMS_TASK;
+	public static final int REDUCE   = RESERVED_STREAMS_REDUCE;
+	public static final int RESULT   = RESERVED_STREAMS_RESULT;
+	public static final int SHUTDOWN = RESERVED_STREAMS_SHUTDOWN;
 }

actor4j-streams/src/main/java/io/actor4j/streams/core/runtime/StreamDecompActor.java

@@ -35,7 +35,7 @@
 import io.actor4j.streams.core.exceptions.ActorStreamDataException;
 
 import static io.actor4j.core.utils.CommPattern.*;
-import static io.actor4j.streams.core.runtime.ActorMessageTag.*;
+import static io.actor4j.streams.core.runtime.ActorStreamsTag.*;
 
 public class StreamDecompActor<T, R> extends Actor {
 	protected final ActorStreamDecompNode<T, R> node;

actor4j-streams/src/main/java/io/actor4j/streams/core/runtime/StreamMapReduceTaskActor.java

@@ -26,7 +26,7 @@
 import io.actor4j.core.utils.ActorGroupList;
 
 import static io.actor4j.core.utils.CommPattern.*;
-import static io.actor4j.streams.core.runtime.ActorMessageTag.*;
+import static io.actor4j.streams.core.runtime.ActorStreamsTag.*;
 //import static io.actor4j.core.logging.ActorLogger.*;
 
 public class StreamMapReduceTaskActor<T, R> extends StreamDecompTaskActor<T, R> {

actor4j-streams/src/main/java/io/actor4j/streams/core/runtime/StreamRecursiveTaskActor.java

@@ -16,8 +16,8 @@
 package io.actor4j.streams.core.runtime;
 
 import static io.actor4j.core.utils.CommPattern.broadcast;
-import static io.actor4j.streams.core.runtime.ActorMessageTag.TASK;
-import static io.actor4j.streams.core.runtime.ActorMessageTag.RESULT;
+import static io.actor4j.streams.core.runtime.ActorStreamsTag.TASK;
+import static io.actor4j.streams.core.runtime.ActorStreamsTag.RESULT;
 
 import java.util.ArrayList;
 import java.util.HashSet;

actor4j-web/actor4j-web-amqp/src/main/java/io/actor4j/web/amqp/AMQPResourceActor.java

@@ -31,15 +31,16 @@
 
 import io.actor4j.core.actors.ResourceActor;
 import io.actor4j.core.messages.ActorMessage;
+import static io.actor4j.core.messages.ActorReservedTag.*;
 
 /*
  *  MQTT compatible implementation (MQTT topics use a topic exchange (amq.topic by default))
  * 	@See https://www.rabbitmq.com/mqtt.html 
  */
 public abstract class AMQPResourceActor extends ResourceActor {
-	public static final int PUBLISH     = 1;
-	public static final int SUBSCRIBE   = 2;
-	public static final int UNSUBSCRIBE = 3;
+	public static final int PUBLISH     = RESERVED_PUBSUB_PUBLISH;
+	public static final int SUBSCRIBE   = RESERVED_PUBSUB_SUBSCRIBE;
+	public static final int UNSUBSCRIBE = RESERVED_PUBSUB_UNSUBSCRIBE;
 
 	protected volatile Connection connection;
 	protected final String host;

actor4j-web/actor4j-web-mqtt/src/main/java/io/actor4j/web/mqtt/MQTTResourceActor.java

@@ -27,11 +27,12 @@
 
 import io.actor4j.core.actors.ResourceActor;
 import io.actor4j.core.messages.ActorMessage;
+import static io.actor4j.core.messages.ActorReservedTag.*;
 
 public abstract class MQTTResourceActor extends ResourceActor {
-	public static final int PUBLISH     = 1;
-	public static final int SUBSCRIBE   = 2;
-	public static final int UNSUBSCRIBE = 3;
+	public static final int PUBLISH     = RESERVED_PUBSUB_PUBLISH;
+	public static final int SUBSCRIBE   = RESERVED_PUBSUB_SUBSCRIBE;
+	public static final int UNSUBSCRIBE = RESERVED_PUBSUB_UNSUBSCRIBE;
 
 	protected volatile MqttClient client;
 	protected final String broker;