@@ 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 |
@@ 121-130 (lines=10) @@ | ||
118 | * @param CmobiAMQPChannel $channel |
|
119 | * @return bool |
|
120 | */ |
|
121 | public function queueHasExists(CmobiAMQPChannel $channel) |
|
122 | { |
|
123 | try { |
|
124 | $channel->queue_declare($this->queueName, true); |
|
125 | } catch (\Exception $e) { |
|
126 | return false; |
|
127 | } |
|
128 | ||
129 | return true; |
|
130 | } |
|
131 | ||
132 | /** |
|
133 | * @return string |