The AMQP client sender throws an NPE when processing an acknowledgeme…

…nt as it assumes the delivery remote state is never null.

The sender is modified to handle the null case and report it as an unknown message state.

src/main/generated/io/vertx/amqp/AmqpClientOptionsConverter.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright (c) 2018-2019 The original author or authors
+ *
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * and Apache License v2.0 which accompanies this distribution.
+ *
+ *        The Eclipse Public License is available at
+ *        http://www.eclipse.org/legal/epl-v10.html
+ *
+ *        The Apache License v2.0 is available at
+ *        http://www.opensource.org/licenses/apache2.0.php
+ *
+ * You may elect to redistribute this code under either of these licenses.
+ */
 package io.vertx.amqp;
 
 import io.vertx.core.json.JsonObject;

src/main/generated/io/vertx/amqp/AmqpReceiverOptionsConverter.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright (c) 2018-2019 The original author or authors
+ *
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * and Apache License v2.0 which accompanies this distribution.
+ *
+ *        The Eclipse Public License is available at
+ *        http://www.eclipse.org/legal/epl-v10.html
+ *
+ *        The Apache License v2.0 is available at
+ *        http://www.opensource.org/licenses/apache2.0.php
+ *
+ * You may elect to redistribute this code under either of these licenses.
+ */
 package io.vertx.amqp;
 
 import io.vertx.core.json.JsonObject;

src/main/generated/io/vertx/amqp/AmqpSenderOptionsConverter.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright (c) 2018-2019 The original author or authors
+ *
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * and Apache License v2.0 which accompanies this distribution.
+ *
+ *        The Eclipse Public License is available at
+ *        http://www.eclipse.org/legal/epl-v10.html
+ *
+ *        The Apache License v2.0 is available at
+ *        http://www.opensource.org/licenses/apache2.0.php
+ *
+ * You may elect to redistribute this code under either of these licenses.
+ */
 package io.vertx.amqp;
 
 import io.vertx.core.json.JsonObject;

src/test/java/io/vertx/amqp/SenderUnknownAckStateTest.java

@@ -41,8 +41,9 @@ public void init() throws Exception {
     AtomicReference<AmqpConnection> reference = new AtomicReference<>();
     client = AmqpClient.create(vertx, new AmqpClientOptions()
       .setHost("localhost")
-      .setPort(server.actualPort()))
-      .connect(connection -> {
+      .setPort(server.actualPort()));
+    client.connect()
+      .onComplete(connection -> {
         reference.set(connection.result());
         if (connection.failed()) {
           connection.cause().printStackTrace();
@@ -64,14 +65,14 @@ public void tearDown() throws InterruptedException {
 
   @Test(timeout = 10000)
   public void test(TestContext context) throws Exception {
-    connection.createSender(address, context.asyncAssertSuccess(sender -> {
-      AmqpMessage msg = AmqpMessage.create().withBooleanAsBody(true).build();
-      sender
-        .write(msg)
-        .onComplete(context.asyncAssertFailure(expected -> {
+    connection.createSender(address)
+      .compose(sender -> {
+        AmqpMessage msg = AmqpMessage.create().withBooleanAsBody(true).build();
+        return sender
+          .write(msg);
+      }).onComplete(context.asyncAssertFailure(expected -> {
         // Expected
       }));
-    }));
   }
 
   private MockServer setupMockServer() throws Exception {