diff --git a/src/main/generated/io/vertx/amqp/AmqpClientOptionsConverter.java b/src/main/generated/io/vertx/amqp/AmqpClientOptionsConverter.java
index 11a86db..55c5800 100644
--- a/src/main/generated/io/vertx/amqp/AmqpClientOptionsConverter.java
+++ b/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;
diff --git a/src/main/generated/io/vertx/amqp/AmqpReceiverOptionsConverter.java b/src/main/generated/io/vertx/amqp/AmqpReceiverOptionsConverter.java
index bd96a00..b82ff2c 100644
--- a/src/main/generated/io/vertx/amqp/AmqpReceiverOptionsConverter.java
+++ b/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;
diff --git a/src/main/generated/io/vertx/amqp/AmqpSenderOptionsConverter.java b/src/main/generated/io/vertx/amqp/AmqpSenderOptionsConverter.java
index b229494..cc9dc2c 100644
--- a/src/main/generated/io/vertx/amqp/AmqpSenderOptionsConverter.java
+++ b/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;
diff --git a/src/test/java/io/vertx/amqp/SenderUnknownAckStateTest.java b/src/test/java/io/vertx/amqp/SenderUnknownAckStateTest.java
index b7267e0..87ac109 100644
--- a/src/test/java/io/vertx/amqp/SenderUnknownAckStateTest.java
+++ b/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 {