Releasing 3.3.0

javadevmtl · Jun 23, 2016 · 308ff43 · 308ff43
1 parent a9ab9c0
commit 308ff43
Show file tree

Hide file tree

Showing 6 changed files with 21 additions and 109 deletions.
diff --git a/pom.xml b/pom.xml
@@ -12,10 +12,10 @@
   <modelVersion>4.0.0</modelVersion>
 
   <artifactId>vertx-rabbitmq-client</artifactId>
-  <version>3.3.0-SNAPSHOT</version>
+  <version>3.3.0</version>
 
   <properties>
-    <stack.version>3.3.0-SNAPSHOT</stack.version>
+    <stack.version>3.3.0</stack.version>
     <rabbitmq.client.version>3.6.2</rabbitmq.client.version>
   </properties>
 

diff --git a/src/main/asciidoc/groovy/index.adoc b/src/main/asciidoc/groovy/index.adoc
@@ -15,7 +15,7 @@ Add the following dependency to your maven project
 <dependency>
   <groupId>io.vertx</groupId>
   <artifactId>vertx-rabbitmq-client</artifactId>
-  <version>3.3.0.CR2</version>
+  <version>3.3.0</version>
 </dependency>
 ----
 
@@ -26,7 +26,7 @@ Add the following dependency to your gradle project
 [source,groovy,subs="+attributes"]
 ----
 dependencies {
-  compile 'io.vertx:vertx-rabbitmq-client:3.3.0.CR2'
+  compile 'io.vertx:vertx-rabbitmq-client:3.3.0'
 }
 ----
 

diff --git a/src/main/asciidoc/java/index.adoc b/src/main/asciidoc/java/index.adoc
@@ -15,7 +15,7 @@ Add the following dependency to your maven project
 <dependency>
   <groupId>io.vertx</groupId>
   <artifactId>vertx-rabbitmq-client</artifactId>
-  <version>3.3.0.CR2</version>
+  <version>3.3.0</version>
 </dependency>
 ----
 
@@ -26,7 +26,7 @@ Add the following dependency to your gradle project
 [source,groovy,subs="+attributes"]
 ----
 dependencies {
-  compile 'io.vertx:vertx-rabbitmq-client:3.3.0.CR2'
+  compile 'io.vertx:vertx-rabbitmq-client:3.3.0'
 }
 ----
 

diff --git a/src/main/asciidoc/js/index.adoc b/src/main/asciidoc/js/index.adoc
@@ -15,7 +15,7 @@ Add the following dependency to your maven project
 <dependency>
   <groupId>io.vertx</groupId>
   <artifactId>vertx-rabbitmq-client</artifactId>
-  <version>3.3.0.CR2</version>
+  <version>3.3.0</version>
 </dependency>
 ----
 
@@ -26,7 +26,7 @@ Add the following dependency to your gradle project
 [source,groovy,subs="+attributes"]
 ----
 dependencies {
-  compile 'io.vertx:vertx-rabbitmq-client:3.3.0.CR2'
+  compile 'io.vertx:vertx-rabbitmq-client:3.3.0'
 }
 ----
 

diff --git a/src/main/asciidoc/ruby/index.adoc b/src/main/asciidoc/ruby/index.adoc
@@ -15,7 +15,7 @@ Add the following dependency to your maven project
 <dependency>
   <groupId>io.vertx</groupId>
   <artifactId>vertx-rabbitmq-client</artifactId>
-  <version>3.3.0.CR2</version>
+  <version>3.3.0</version>
 </dependency>
 ----
 
@@ -26,7 +26,7 @@ Add the following dependency to your gradle project
 [source,groovy,subs="+attributes"]
 ----
 dependencies {
-  compile 'io.vertx:vertx-rabbitmq-client:3.3.0.CR2'
+  compile 'io.vertx:vertx-rabbitmq-client:3.3.0'
 }
 ----
 

diff --git a/src/main/generated/io/vertx/rxjava/rabbitmq/RabbitMQClient.java b/src/main/generated/io/vertx/rxjava/rabbitmq/RabbitMQClient.java
@@ -124,15 +124,7 @@ public Observable<JsonObject> basicGetObservable(String queue, boolean autoAck)
    * @param resultHandler 
    */
   public void basicConsume(String queue, String address, Handler<AsyncResult<Void>> resultHandler) { 
-    delegate.basicConsume(queue, address, new Handler<AsyncResult<java.lang.Void>>() {
-      public void handle(AsyncResult<java.lang.Void> ar) {
-        if (ar.succeeded()) {
-          resultHandler.handle(io.vertx.core.Future.succeededFuture(ar.result()));
-        } else {
-          resultHandler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
-        }
-      }
-    });
+    delegate.basicConsume(queue, address, resultHandler);
   }
 
   /**
@@ -155,15 +147,7 @@ public Observable<Void> basicConsumeObservable(String queue, String address) {
    * @param resultHandler 
    */
   public void basicConsume(String queue, String address, boolean autoAck, Handler<AsyncResult<Void>> resultHandler) { 
-    delegate.basicConsume(queue, address, autoAck, new Handler<AsyncResult<java.lang.Void>>() {
-      public void handle(AsyncResult<java.lang.Void> ar) {
-        if (ar.succeeded()) {
-          resultHandler.handle(io.vertx.core.Future.succeededFuture(ar.result()));
-        } else {
-          resultHandler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
-        }
-      }
-    });
+    delegate.basicConsume(queue, address, autoAck, resultHandler);
   }
 
   /**
@@ -188,15 +172,7 @@ public Observable<Void> basicConsumeObservable(String queue, String address, boo
    * @param resultHandler 
    */
   public void basicPublish(String exchange, String routingKey, JsonObject message, Handler<AsyncResult<Void>> resultHandler) { 
-    delegate.basicPublish(exchange, routingKey, message, new Handler<AsyncResult<java.lang.Void>>() {
-      public void handle(AsyncResult<java.lang.Void> ar) {
-        if (ar.succeeded()) {
-          resultHandler.handle(io.vertx.core.Future.succeededFuture(ar.result()));
-        } else {
-          resultHandler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
-        }
-      }
-    });
+    delegate.basicPublish(exchange, routingKey, message, resultHandler);
   }
 
   /**
@@ -220,15 +196,7 @@ public Observable<Void> basicPublishObservable(String exchange, String routingKe
    * @param resultHandler 
    */
   public void basicQos(int prefetchCount, Handler<AsyncResult<Void>> resultHandler) { 
-    delegate.basicQos(prefetchCount, new Handler<AsyncResult<java.lang.Void>>() {
-      public void handle(AsyncResult<java.lang.Void> ar) {
-        if (ar.succeeded()) {
-          resultHandler.handle(io.vertx.core.Future.succeededFuture(ar.result()));
-        } else {
-          resultHandler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
-        }
-      }
-    });
+    delegate.basicQos(prefetchCount, resultHandler);
   }
 
   /**
@@ -252,15 +220,7 @@ public Observable<Void> basicQosObservable(int prefetchCount) {
    * @param resultHandler 
    */
   public void exchangeDeclare(String exchange, String type, boolean durable, boolean autoDelete, Handler<AsyncResult<Void>> resultHandler) { 
-    delegate.exchangeDeclare(exchange, type, durable, autoDelete, new Handler<AsyncResult<java.lang.Void>>() {
-      public void handle(AsyncResult<java.lang.Void> ar) {
-        if (ar.succeeded()) {
-          resultHandler.handle(io.vertx.core.Future.succeededFuture(ar.result()));
-        } else {
-          resultHandler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
-        }
-      }
-    });
+    delegate.exchangeDeclare(exchange, type, durable, autoDelete, resultHandler);
   }
 
   /**
@@ -283,15 +243,7 @@ public Observable<Void> exchangeDeclareObservable(String exchange, String type,
    * @param resultHandler 
    */
   public void exchangeDelete(String exchange, Handler<AsyncResult<Void>> resultHandler) { 
-    delegate.exchangeDelete(exchange, new Handler<AsyncResult<java.lang.Void>>() {
-      public void handle(AsyncResult<java.lang.Void> ar) {
-        if (ar.succeeded()) {
-          resultHandler.handle(io.vertx.core.Future.succeededFuture(ar.result()));
-        } else {
-          resultHandler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
-        }
-      }
-    });
+    delegate.exchangeDelete(exchange, resultHandler);
   }
 
   /**
@@ -313,15 +265,7 @@ public Observable<Void> exchangeDeleteObservable(String exchange) {
    * @param resultHandler 
    */
   public void exchangeBind(String destination, String source, String routingKey, Handler<AsyncResult<Void>> resultHandler) { 
-    delegate.exchangeBind(destination, source, routingKey, new Handler<AsyncResult<java.lang.Void>>() {
-      public void handle(AsyncResult<java.lang.Void> ar) {
-        if (ar.succeeded()) {
-          resultHandler.handle(io.vertx.core.Future.succeededFuture(ar.result()));
-        } else {
-          resultHandler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
-        }
-      }
-    });
+    delegate.exchangeBind(destination, source, routingKey, resultHandler);
   }
 
   /**
@@ -345,15 +289,7 @@ public Observable<Void> exchangeBindObservable(String destination, String source
    * @param resultHandler 
    */
   public void exchangeUnbind(String destination, String source, String routingKey, Handler<AsyncResult<Void>> resultHandler) { 
-    delegate.exchangeUnbind(destination, source, routingKey, new Handler<AsyncResult<java.lang.Void>>() {
-      public void handle(AsyncResult<java.lang.Void> ar) {
-        if (ar.succeeded()) {
-          resultHandler.handle(io.vertx.core.Future.succeededFuture(ar.result()));
-        } else {
-          resultHandler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
-        }
-      }
-    });
+    delegate.exchangeUnbind(destination, source, routingKey, resultHandler);
   }
 
   /**
@@ -465,15 +401,7 @@ public Observable<JsonObject> queueDeleteIfObservable(String queue, boolean ifUn
    * @param resultHandler 
    */
   public void queueBind(String queue, String exchange, String routingKey, Handler<AsyncResult<Void>> resultHandler) { 
-    delegate.queueBind(queue, exchange, routingKey, new Handler<AsyncResult<java.lang.Void>>() {
-      public void handle(AsyncResult<java.lang.Void> ar) {
-        if (ar.succeeded()) {
-          resultHandler.handle(io.vertx.core.Future.succeededFuture(ar.result()));
-        } else {
-          resultHandler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
-        }
-      }
-    });
+    delegate.queueBind(queue, exchange, routingKey, resultHandler);
   }
 
   /**
@@ -514,15 +442,7 @@ public Observable<JsonObject> messageCountObservable(String queue) {
    * @param resultHandler 
    */
   public void start(Handler<AsyncResult<Void>> resultHandler) { 
-    delegate.start(new Handler<AsyncResult<java.lang.Void>>() {
-      public void handle(AsyncResult<java.lang.Void> ar) {
-        if (ar.succeeded()) {
-          resultHandler.handle(io.vertx.core.Future.succeededFuture(ar.result()));
-        } else {
-          resultHandler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
-        }
-      }
-    });
+    delegate.start(resultHandler);
   }
 
   /**
@@ -540,15 +460,7 @@ public Observable<Void> startObservable() {
    * @param resultHandler 
    */
   public void stop(Handler<AsyncResult<Void>> resultHandler) { 
-    delegate.stop(new Handler<AsyncResult<java.lang.Void>>() {
-      public void handle(AsyncResult<java.lang.Void> ar) {
-        if (ar.succeeded()) {
-          resultHandler.handle(io.vertx.core.Future.succeededFuture(ar.result()));
-        } else {
-          resultHandler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
-        }
-      }
-    });
+    delegate.stop(resultHandler);
   }
 
   /**