bind close event

prophet777 · prophet777 · commit 05a833734256 · 2015-08-03T22:21:27.000+02:00
diff --git a/src/Consumer.php b/src/Consumer.php
@@ -82,6 +82,8 @@ public function __invoke()
                 return;
             }
         }
+
+        $this->on('close_amqp_consumer', [$this, 'close']);
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -82,6 +82,8 @@ public function __invoke()`
`82`	`82`	`return;`
`83`	`83`	`}`
`84`	`84`	`}`
	`85`	`+`
	`86`	`+ $this->on('close_amqp_consumer', [$this, 'close']);`
`85`	`87`	`}`
`86`	`88`
`87`	`89`	`/**`