Add Avro RPC

pom.xml

@@ -29,6 +29,8 @@
                         <phase>generate-sources</phase>
                         <goals>
                             <goal>schema</goal>
+                            <goal>protocol</goal>
+                            <goal>idl-protocol</goal>
                         </goals>
                         <configuration>
                             <sourceDirectory>${project.basedir}/src/main/avro/</sourceDirectory>
@@ -277,6 +279,12 @@
             </exclusions>
         </dependency>
 
+        <dependency>
+            <groupId>org.apache.avro</groupId>
+            <artifactId>avro-ipc</artifactId>
+            <version>1.8.2</version>
+        </dependency>
+
 
     </dependencies>
 

src/main/avro/avro_rpc.avpr

@@ -0,0 +1,20 @@
+{"namespace": "com.politrons.avro.rpc",
+ "protocol": "CustomAvroRPC",
+
+ "types": [
+     {"name": "Message", "type": "record",
+      "fields": [
+          {"name": "to",   "type": "string"},
+          {"name": "from", "type": "string"},
+          {"name": "body", "type": "string"}
+      ]
+     }
+ ],
+
+ "messages": {
+     "send": {
+         "request": [{"name": "message", "type": "Message"}],
+         "response": "string"
+     }
+ }
+}

src/main/java/com/politrons/avro/DeserializeAvro.java

@@ -29,9 +29,9 @@ public static void fromFile() {
     public static AvroPerson fromByteArray(byte[] avroPersonData) {
         AvroPerson avroPerson = null;
         try {
-            DatumReader<AvroPerson> employeeReader = new SpecificDatumReader<>(AvroPerson.class);
+            DatumReader<AvroPerson> personReader = new SpecificDatumReader<>(AvroPerson.class);
             Decoder binaryDecoder = DecoderFactory.get().binaryDecoder(avroPersonData, null);
-            avroPerson = employeeReader.read(null, binaryDecoder);
+            avroPerson = personReader.read(null, binaryDecoder);
         } catch (IOException e) {
             e.printStackTrace();
         }

src/main/java/com/politrons/avro/rpc/ClientAvroRPC.java

@@ -0,0 +1,38 @@
+package com.politrons.avro.rpc;
+
+import org.apache.avro.ipc.NettyTransceiver;
+import org.apache.avro.ipc.specific.SpecificRequestor;
+
+import java.io.IOException;
+import java.net.InetSocketAddress;
+
+import static com.politrons.avro.rpc.ServerAvroRPC.startServer;
+
+
+/**
+ * Start a server, attach a client, and send a message.
+ */
+public class ClientAvroRPC {
+
+    public static void main(String[] args) throws IOException {
+        // usually this would be another app, but for simplicity
+        startServer();
+
+        NettyTransceiver client = new NettyTransceiver(new InetSocketAddress(65111));
+        // client code - attach to the server and send a message
+        CustomAvroRPC proxy = SpecificRequestor.getClient(CustomAvroRPC.class, client);
+        System.out.println("Client built, got proxy");
+
+        // fill in the Message record and send it
+        Message message = new Message();
+        message.setTo("Receiver");
+        message.setFrom("Sender");
+        message.setBody("Body message");
+        System.out.println("Calling proxy.send with message:  " + message.toString());
+        System.out.println("Result: " + proxy.send(message));
+
+        // cleanup
+        client.close();
+        ServerAvroRPC.server.close();
+    }
+}

src/main/java/com/politrons/avro/rpc/CustomAvroRPC.java

@@ -0,0 +1,24 @@
+/**
+ * Autogenerated by Avro
+ *
+ * DO NOT EDIT DIRECTLY
+ */
+package com.politrons.avro.rpc;
+
+@SuppressWarnings("all")
+@org.apache.avro.specific.AvroGenerated
+public interface CustomAvroRPC {
+  public static final org.apache.avro.Protocol PROTOCOL = org.apache.avro.Protocol.parse("{\"protocol\":\"CustomAvroRPC\",\"namespace\":\"com.politrons.avro.rpc\",\"types\":[{\"type\":\"record\",\"name\":\"Message\",\"fields\":[{\"name\":\"to\",\"type\":\"string\"},{\"name\":\"from\",\"type\":\"string\"},{\"name\":\"body\",\"type\":\"string\"}]}],\"messages\":{\"send\":{\"request\":[{\"name\":\"message\",\"type\":\"Message\"}],\"response\":\"string\"}}}");
+  /**
+   */
+  java.lang.CharSequence send(com.politrons.avro.rpc.Message message) throws org.apache.avro.AvroRemoteException;
+
+  @SuppressWarnings("all")
+  public interface Callback extends CustomAvroRPC {
+    public static final org.apache.avro.Protocol PROTOCOL = com.politrons.avro.rpc.CustomAvroRPC.PROTOCOL;
+    /**
+     * @throws java.io.IOException The async call could not be completed.
+     */
+    void send(com.politrons.avro.rpc.Message message, org.apache.avro.ipc.Callback<java.lang.CharSequence> callback) throws java.io.IOException;
+  }
+}