Add messaging service/interfaces.

core/src/main/java/io/atomix/messaging/Endpoint.java

@@ -13,30 +13,28 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.onosproject.store.cluster.messaging;
+package io.atomix.messaging;
 
-import static com.google.common.base.Preconditions.checkNotNull;
+import com.google.common.base.MoreObjects;
 
+import java.net.InetAddress;
 import java.util.Objects;
 
-import org.onlab.packet.IpAddress;
-
-import com.google.common.base.MoreObjects;
+import static com.google.common.base.Preconditions.checkNotNull;
 
 /**
  * Representation of a TCP/UDP communication end point.
  */
 public final class Endpoint {
-
     private final int port;
-    private final IpAddress ip;
+    private final InetAddress ip;
 
-    public Endpoint(IpAddress host, int port) {
+    public Endpoint(InetAddress host, int port) {
         this.ip = checkNotNull(host);
         this.port = port;
     }
 
-    public IpAddress host() {
+    public InetAddress host() {
         return ip;
     }
 
@@ -70,6 +68,6 @@ public boolean equals(Object obj) {
         }
         Endpoint that = (Endpoint) obj;
         return this.port == that.port &&
-               Objects.equals(this.ip, that.ip);
+                Objects.equals(this.ip, that.ip);
     }
 }

core/src/main/java/io/atomix/messaging/MessageSubject.java

@@ -13,12 +13,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.onosproject.store.cluster.messaging;
-
-import static com.google.common.base.Preconditions.checkNotNull;
+package io.atomix.messaging;
 
 import java.util.Objects;
 
+import static com.google.common.base.Preconditions.checkNotNull;
+
 /**
  * Representation of a message subject.
  * Cluster messages have associated subjects that dictate how they get handled

core/src/main/java/io/atomix/messaging/MessagingException.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.onosproject.store.cluster.messaging;
+package io.atomix.messaging;
 
 import java.io.IOException;
 

core/src/main/java/io/atomix/messaging/MessagingService.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.onosproject.store.cluster.messaging;
+package io.atomix.messaging;
 
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.Executor;
@@ -28,57 +28,64 @@ public interface MessagingService {
     /**
      * Sends a message asynchronously to the specified communication end point.
      * The message is specified using the type and payload.
-     * @param ep end point to send the message to.
-     * @param type type of message.
+     *
+     * @param ep      end point to send the message to.
+     * @param type    type of message.
      * @param payload message payload bytes.
      * @return future that is completed when the message is sent
      */
     CompletableFuture<Void> sendAsync(Endpoint ep, String type, byte[] payload);
 
     /**
      * Sends a message asynchronously and expects a response.
-     * @param ep end point to send the message to.
-     * @param type type of message.
+     *
+     * @param ep      end point to send the message to.
+     * @param type    type of message.
      * @param payload message payload.
      * @return a response future
      */
     CompletableFuture<byte[]> sendAndReceive(Endpoint ep, String type, byte[] payload);
 
     /**
      * Sends a message synchronously and expects a response.
-     * @param ep end point to send the message to.
-     * @param type type of message.
-     * @param payload message payload.
+     *
+     * @param ep       end point to send the message to.
+     * @param type     type of message.
+     * @param payload  message payload.
      * @param executor executor over which any follow up actions after completion will be executed.
      * @return a response future
      */
     CompletableFuture<byte[]> sendAndReceive(Endpoint ep, String type, byte[] payload, Executor executor);
 
     /**
      * Registers a new message handler for message type.
-     * @param type message type.
-     * @param handler message handler
+     *
+     * @param type     message type.
+     * @param handler  message handler
      * @param executor executor to use for running message handler logic.
      */
     void registerHandler(String type, BiConsumer<Endpoint, byte[]> handler, Executor executor);
 
     /**
      * Registers a new message handler for message type.
-     * @param type message type.
-     * @param handler message handler
+     *
+     * @param type     message type.
+     * @param handler  message handler
      * @param executor executor to use for running message handler logic.
      */
     void registerHandler(String type, BiFunction<Endpoint, byte[], byte[]> handler, Executor executor);
 
     /**
      * Registers a new message handler for message type.
-     * @param type message type.
+     *
+     * @param type    message type.
      * @param handler message handler
      */
     void registerHandler(String type, BiFunction<Endpoint, byte[], CompletableFuture<byte[]>> handler);
 
     /**
      * Unregister current handler, if one exists for message type.
+     *
      * @param type message type
      */
     void unregisterHandler(String type);