Merge remote-tracking branch 'origin/dev'

estantevirtual · Mar 17, 2017 · fb48731 · fb48731
2 parents f52bb20 + 887981f
commit fb48731
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 12 deletions.
diff --git a/Gemfile.lock b/Gemfile.lock
@@ -1,20 +1,19 @@
 PATH
   remote: .
   specs:
-    event-pub-sub (2.0.0)
+    event-pub-sub (3.0.0)
       activesupport
       bunny (= 2.3.0)
 
 GEM
   remote: https://rubygems.org/
   specs:
-    activesupport (4.2.5.2)
+    activesupport (5.0.2)
+      concurrent-ruby (~> 1.0, >= 1.0.2)
       i18n (~> 0.7)
-      json (~> 1.7, >= 1.7.7)
       minitest (~> 5.1)
-      thread_safe (~> 0.3, >= 0.3.4)
       tzinfo (~> 1.1)
-    amq-protocol (2.0.1)
+    amq-protocol (2.1.0)
     ast (2.2.0)
     astrolabe (1.3.1)
       parser (~> 2.2)
@@ -26,6 +25,7 @@ GEM
     childprocess (0.5.9)
       ffi (~> 1.0, >= 1.0.11)
     coderay (1.1.0)
+    concurrent-ruby (1.0.5)
     diff-lcs (1.2.5)
     ffi (1.9.6)
     formatador (0.2.5)
@@ -44,16 +44,15 @@ GEM
       guard-compat (~> 1.1)
       rspec (>= 2.99.0, < 4.0)
     hitimes (1.2.2)
-    i18n (0.7.0)
+    i18n (0.8.1)
     iniparse (1.4.2)
-    json (1.8.3)
     listen (2.8.5)
       celluloid (>= 0.15.2)
       rb-fsevent (>= 0.9.3)
       rb-inotify (>= 0.9)
     lumberjack (1.0.9)
     method_source (0.8.2)
-    minitest (5.8.4)
+    minitest (5.10.1)
     nenv (0.2.0)
     notiffany (0.0.3)
       nenv (~> 0.1)
@@ -97,7 +96,7 @@ GEM
     shellany (0.0.1)
     slop (3.6.0)
     thor (0.19.1)
-    thread_safe (0.3.5)
+    thread_safe (0.3.6)
     timers (4.0.1)
       hitimes
     tins (1.6.0)
@@ -118,4 +117,4 @@ DEPENDENCIES
   rubocop (= 0.35.1)
 
 BUNDLED WITH
-   1.11.2
+   1.13.7
diff --git a/README.md b/README.md
@@ -158,6 +158,8 @@ Basta descomentar e seguir como no exemplo. Imaginando que queremos registrar o
 
 **Observação:** Como este arquivo setup_events.rb é carregado na inicialização da aplicação, toda vez que você registrar um evento novo vai precisar reinicar a app.
 
+**Observação:** Atualmente, o producer só consegue enviar mensagens caso haja um consumer.
+
 
 ## Contributing
 1. Fork it ( https://github.com/[my-github-username]/event/fork )

diff --git a/lib/event_pub_sub/broker_handler.rb b/lib/event_pub_sub/broker_handler.rb
@@ -37,7 +37,7 @@ def subscribe(consumer_name, params={ack: true, block: false}, &block)
           block.call(delivery_info, properties, payload)
           channel.ack(delivery_info.delivery_tag)
         rescue => e
-          channel.nack(delivery_info.delivery_tag, false, true)
+          channel.nack(delivery_info.delivery_tag, false, false)
           raise e
         end
       end

diff --git a/lib/event_pub_sub/version.rb b/lib/event_pub_sub/version.rb
@@ -1,3 +1,3 @@
 module EventPubSub
-  VERSION = '2.0.1'
+  VERSION = '3.0.0'.freeze
 end