Start implementing Promises

Changes

@@ -1,5 +1,8 @@
 {{$NEXT}}
-
+  - Start implementing Mojo::Promise, drop support for Mojolicious <7.53
+  - Implement DEBUG on Client as suggested in #11
+  - Fix query parameter naming in Publisher
+  - Fix missing imports in Publisher #15
 0.0.9 2017-02-18T11:07:56Z
   - Proper implementation of URI parser PR#8 & #9
   - Support for query parameter with aliases

cpanfile

@@ -1,5 +1,5 @@
 requires 'perl', '5.010';
-requires 'Mojolicious', '6.10';
+requires 'Mojolicious', '7.53';
 requires 'Net::AMQP', '0.06';
 requires 'File::ShareDir';
 requires 'List::Util', '1.33';

lib/Mojo/RabbitMQ/Client/Channel.pm

@@ -1,5 +1,6 @@
 package Mojo::RabbitMQ::Client::Channel;
 use Mojo::Base 'Mojo::EventEmitter';
+use Mojo::Promise;
 
 use Mojo::RabbitMQ::Client::LocalQueue;
 use Mojo::RabbitMQ::Client::Method;
@@ -195,6 +196,16 @@ sub declare_exchange {
   );
 }
 
+sub declare_exchange_p {
+  my $self = shift;
+
+  my $promise = Mojo::Promise->new;
+  my $method = $self->declare_exchange(@_);
+  $method->on('success' => sub { shift; $promise->resolve(@_) })
+  $method->on('error' => sub { shift; $promise->reject(@_) })
+  $method->deliver;
+}
+
 sub delete_exchange {
   my $self = shift;
 
@@ -209,6 +220,16 @@ sub delete_exchange {
   );
 }
 
+sub delete_exchange_p {
+  my $self = shift;
+
+  my $promise = Mojo::Promise->new;
+  my $method = $self->delete_exchange(@_);
+  $method->on('success' => sub { shift; $promise->resolve(@_) })
+  $method->on('error' => sub { shift; $promise->reject(@_) })
+  $method->deliver;
+}
+
 sub declare_queue {
   my $self = shift;
 
@@ -228,6 +249,16 @@ sub declare_queue {
   );
 }
 
+sub declare_queue_p {
+  my $self = shift;
+
+  my $promise = Mojo::Promise->new;
+  my $method = $self->declare_queue(@_);
+  $method->on('success' => sub { shift; $promise->resolve(@_) })
+  $method->on('error' => sub { shift; $promise->reject(@_) })
+  $method->deliver;
+}
+
 sub bind_queue {
   my $self = shift;
 
@@ -241,6 +272,16 @@ sub bind_queue {
   );
 }
 
+sub bind_queue_p {
+  my $self = shift;
+
+  my $promise = Mojo::Promise->new;
+  my $method = $self->bind_queue(@_);
+  $method->on('success' => sub { shift; $promise->resolve(@_) })
+  $method->on('error' => sub { shift; $promise->reject(@_) })
+  $method->deliver;
+}
+
 sub unbind_queue {
   my $self = shift;
 
@@ -253,6 +294,16 @@ sub unbind_queue {
   );
 }
 
+sub unbind_queue_p {
+  my $self = shift;
+
+  my $promise = Mojo::Promise->new;
+  my $method = $self->unbind_queue(@_);
+  $method->on('success' => sub { shift; $promise->resolve(@_) })
+  $method->on('error' => sub { shift; $promise->reject(@_) })
+  $method->deliver;
+}
+
 sub purge_queue {
   my $self = shift;
 
@@ -266,6 +317,16 @@ sub purge_queue {
   );
 }
 
+sub purge_queue_p {
+  my $self = shift;
+
+  my $promise = Mojo::Promise->new;
+  my $method = $self->purge_queue(@_);
+  $method->on('success' => sub { shift; $promise->resolve(@_) })
+  $method->on('error' => sub { shift; $promise->reject(@_) })
+  $method->deliver;
+}
+
 sub delete_queue {
   my $self = shift;
 
@@ -281,6 +342,16 @@ sub delete_queue {
   );
 }
 
+sub delete_queue_p {
+  my $self = shift;
+
+  my $promise = Mojo::Promise->new;
+  my $method = $self->delete_queue(@_);
+  $method->on('success' => sub { shift; $promise->resolve(@_) })
+  $method->on('error' => sub { shift; $promise->reject(@_) })
+  $method->deliver;
+}
+
 sub publish {
   my $self = shift;