@@ 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 |