| @@ 250-262 (lines=13) @@ | ||
| 247 | * @param string $out_of_band |
|
| 248 | * @return mixed |
|
| 249 | */ |
|
| 250 | protected function x_open($out_of_band = '') |
|
| 251 | { |
|
| 252 | if ($this->is_open) { |
|
| 253 | return null; |
|
| 254 | } |
|
| 255 | ||
| 256 | list($class_id, $method_id, $args) = $this->protocolWriter->channelOpen($out_of_band); |
|
| 257 | $this->send_method_frame(array($class_id, $method_id), $args); |
|
| 258 | ||
| 259 | return $this->wait(array( |
|
| 260 | $this->waitHelper->get_wait('channel.open_ok') |
|
| 261 | )); |
|
| 262 | } |
|
| 263 | ||
| 264 | /** |
|
| 265 | * @param AMQPReader $args |
|
| @@ 1312-1324 (lines=13) @@ | ||
| 1309 | * |
|
| 1310 | * @param bool $nowait |
|
| 1311 | */ |
|
| 1312 | public function confirm_select($nowait = false) |
|
| 1313 | { |
|
| 1314 | list($class_id, $method_id, $args) = $this->protocolWriter->confirmSelect($nowait); |
|
| 1315 | ||
| 1316 | $this->send_method_frame(array($class_id, $method_id), $args); |
|
| 1317 | ||
| 1318 | if ($nowait) { |
|
| 1319 | return null; |
|
| 1320 | } |
|
| 1321 | ||
| 1322 | $this->wait(array($this->waitHelper->get_wait('confirm.select_ok'))); |
|
| 1323 | $this->next_delivery_tag = 1; |
|
| 1324 | } |
|
| 1325 | ||
| 1326 | /** |
|
| 1327 | * Confirms a selection |
|