| @@ 311-319 (lines=9) @@ | ||
| 308 | * @override |
|
| 309 | * @inheritDoc |
|
| 310 | */ |
|
| 311 | public function send($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0) |
|
| 312 | { |
|
| 313 | if ($success !== null || $failure !== null || $cancel !== null) |
|
| 314 | { |
|
| 315 | return $this->sendRequest($name, $message, $flags, $success, $failure, $cancel, $timeout); |
|
| 316 | } |
|
| 317 | ||
| 318 | return $this->sendAsync($name, $message, $flags); |
|
| 319 | } |
|
| 320 | ||
| 321 | /** |
|
| 322 | * @override |
|
| @@ 325-333 (lines=9) @@ | ||
| 322 | * @override |
|
| 323 | * @inheritDoc |
|
| 324 | */ |
|
| 325 | public function push($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0) |
|
| 326 | { |
|
| 327 | if ($success !== null || $failure !== null || $cancel !== null) |
|
| 328 | { |
|
| 329 | return $this->pushRequest($name, $message, $flags, $success, $failure, $cancel, $timeout); |
|
| 330 | } |
|
| 331 | ||
| 332 | return $this->pushAsync($name, $message, $flags); |
|
| 333 | } |
|
| 334 | ||
| 335 | /** |
|
| 336 | * @override |
|
| @@ 326-334 (lines=9) @@ | ||
| 323 | * @override |
|
| 324 | * @inheritDoc |
|
| 325 | */ |
|
| 326 | public function send($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0) |
|
| 327 | { |
|
| 328 | if ($success !== null || $failure !== null || $cancel !== null) |
|
| 329 | { |
|
| 330 | return $this->sendRequest($name, $message, $flags, $success, $failure, $cancel, $timeout); |
|
| 331 | } |
|
| 332 | ||
| 333 | return $this->sendAsync($name, $message, $flags); |
|
| 334 | } |
|
| 335 | ||
| 336 | /** |
|
| 337 | * @override |
|
| @@ 340-348 (lines=9) @@ | ||
| 337 | * @override |
|
| 338 | * @inheritDoc |
|
| 339 | */ |
|
| 340 | public function push($name, $message, $flags = Channel::MODE_DEFAULT, callable $success = null, callable $failure = null, callable $cancel = null, $timeout = 0.0) |
|
| 341 | { |
|
| 342 | if ($success !== null || $failure !== null || $cancel !== null) |
|
| 343 | { |
|
| 344 | return $this->pushRequest($name, $message, $flags, $success, $failure, $cancel, $timeout); |
|
| 345 | } |
|
| 346 | ||
| 347 | return $this->pushAsync($name, $message, $flags); |
|
| 348 | } |
|
| 349 | ||
| 350 | /** |
|
| 351 | * @override |
|