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