Add amqp extension parsing to dump command (#723)

Author: attilakreiner

incubator/binding-amqp/src/main/java/io/aklivity/zilla/runtime/binding/amqp/internal/AmqpBinding.java

@@ -19,6 +19,7 @@
 
 import io.aklivity.zilla.runtime.engine.EngineContext;
 import io.aklivity.zilla.runtime.engine.binding.Binding;
+import io.aklivity.zilla.runtime.engine.config.KindConfig;
 
 public final class AmqpBinding implements Binding
 {
@@ -44,6 +45,20 @@ public URL type()
         return getClass().getResource("schema/amqp.schema.patch.json");
     }
 
+    @Override
+    public String originType(
+        KindConfig kind)
+    {
+        return kind == KindConfig.CLIENT ? NAME : null;
+    }
+
+    @Override
+    public String routedType(
+        KindConfig kind)
+    {
+        return kind == KindConfig.SERVER ? NAME : null;
+    }
+
     @Override
     public AmqpBindingContext supply(
         EngineContext context)

incubator/command-dump/pom.xml

@@ -97,6 +97,12 @@
       <version>${project.version}</version>
       <scope>test</scope>
     </dependency>
+    <dependency>
+      <groupId>io.aklivity.zilla</groupId>
+      <artifactId>binding-amqp.spec</artifactId>
+      <version>${project.version}</version>
+      <scope>test</scope>
+    </dependency>
     <dependency>
       <groupId>org.junit.jupiter</groupId>
       <artifactId>junit-jupiter-engine</artifactId>

incubator/command-dump/src/main/resources/io/aklivity/zilla/runtime/command/dump/internal/airline/zilla.lua

@@ -89,7 +89,7 @@ public void shouldMatchExpectedOutput() throws Exception
         String expectedText = Files.readString(resourceToPath("expected_dump.txt"));
 
         // WHEN
-        String protocols = "zilla,http,http2,tls,mqtt,kafka";
+        String protocols = "zilla,http,http2,tls,mqtt,kafka,amqp";
         Container.ExecResult result = tshark.execInContainer("tshark", "-O", protocols, "-r", containerPath);
 
         // THEN

incubator/command-dump/src/test/java/io/aklivity/zilla/runtime/command/dump/internal/airline/WiresharkIT.java

@@ -33,3 +33,6 @@ east_http_filesystem_mapping
 east_filesystem_server
 north_mqtt_server
 north_mqtt_kafka_mapping
+amqp
+north_amqp_server
+north_fan_server