Releasing 1.3.1

eandersson · May 3, 2016 · 6d622aa · 6d622aa
1 parent b36dd75
commit 6d622aa
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 2 deletions.
diff --git a/CHANGELOG b/CHANGELOG
@@ -1,8 +1,12 @@
 # Changelog
 
 ### Version 1.3.1
+- Fixed SSL bug that could trigger an exceptions when running multiple threads. [#14]
+
 - Fixed bug when using channel.basic.get to retrieve large payloads.
 
+- Improved code documentation.
+
 - Reduced default RPC timeout from 360s to 120s.
 
 ### Version 1.3.0

diff --git a/examples/scalable_consumer.py b/examples/scalable_consumer.py
@@ -52,7 +52,8 @@ def increase_consumers(self):
 
         :return:
         """
-        self.number_of_consumers += 1
+        if self.number_of_consumers <= 20:
+            self.number_of_consumers += 1
 
     def decrease_consumers(self):
         """Stop one consumer.

diff --git a/examples/scalable_rpc_server.py b/examples/scalable_rpc_server.py
@@ -62,7 +62,8 @@ def increase_consumers(self):
 
         :return:
         """
-        self.number_of_consumers += 1
+        if self.number_of_consumers <= 20:
+            self.number_of_consumers += 1
 
     def decrease_consumers(self):
         """Stop one consumer.