@@ 60-69 (lines=10) @@ | ||
57 | * @param CmobiAMQPChannel $channel |
|
58 | * @return bool |
|
59 | */ |
|
60 | public function queueHasExists(CmobiAMQPChannel $channel) |
|
61 | { |
|
62 | try { |
|
63 | $channel->queue_declare($this->queueName, true); |
|
64 | } catch (\Exception $e) { |
|
65 | return false; |
|
66 | } |
|
67 | ||
68 | return true; |
|
69 | } |
|
70 | ||
71 | /** |
|
72 | * @return string |
@@ 123-132 (lines=10) @@ | ||
120 | * @param CmobiAMQPChannel $channel |
|
121 | * @return bool |
|
122 | */ |
|
123 | public function queueHasExists(CmobiAMQPChannel $channel) |
|
124 | { |
|
125 | try { |
|
126 | $channel->queue_declare($this->queueName, true); |
|
127 | } catch (\Exception $e) { |
|
128 | return false; |
|
129 | } |
|
130 | ||
131 | return true; |
|
132 | } |
|
133 | ||
134 | /** |
|
135 | * @return string |