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