@@ 105-114 (lines=10) @@ | ||
102 | /** |
|
103 | * @return bool |
|
104 | */ |
|
105 | public function queueHasExists() |
|
106 | { |
|
107 | try { |
|
108 | $this->getChannel()->queue_declare($this->queueName, true); |
|
109 | } catch (\Exception $e) { |
|
110 | return false; |
|
111 | } |
|
112 | ||
113 | return true; |
|
114 | } |
|
115 | ||
116 | /** |
|
117 | * @return string |
@@ 58-67 (lines=10) @@ | ||
55 | /** |
|
56 | * @return bool |
|
57 | */ |
|
58 | public function queueHasExists() |
|
59 | { |
|
60 | try { |
|
61 | $this->getChannel()->queue_declare($this->queueName, true); |
|
62 | } catch (\Exception $e) { |
|
63 | return false; |
|
64 | } |
|
65 | ||
66 | return true; |
|
67 | } |
|
68 | ||
69 | /** |
|
70 | * @return CmobiAMQPChannel |