|
@@ 107-115 (lines=9) @@
|
| 104 |
|
$dispatchMessage = DispatchMessage::fromBytes($this->serializer, $data[1]); |
| 105 |
|
$self = $this; |
| 106 |
|
|
| 107 |
|
$successCallback = function ($result) use ($dispatchMessage, $self) { |
| 108 |
|
$message = new ReplyMessage( |
| 109 |
|
$dispatchMessage->getCommandIdentifier(), |
| 110 |
|
$self->serializer, |
| 111 |
|
$result |
| 112 |
|
); |
| 113 |
|
|
| 114 |
|
$self->template->writeCommandReply($dispatchMessage->getCommandIdentifier(), $message->toBytes()); |
| 115 |
|
}; |
| 116 |
|
|
| 117 |
|
$failureCallback = function (\Exception $cause) use ($dispatchMessage, $self) { |
| 118 |
|
$message = new ReplyMessage( |
|
@@ 117-126 (lines=10) @@
|
| 114 |
|
$self->template->writeCommandReply($dispatchMessage->getCommandIdentifier(), $message->toBytes()); |
| 115 |
|
}; |
| 116 |
|
|
| 117 |
|
$failureCallback = function (\Exception $cause) use ($dispatchMessage, $self) { |
| 118 |
|
$message = new ReplyMessage( |
| 119 |
|
$dispatchMessage->getCommandIdentifier(), |
| 120 |
|
$self->serializer, |
| 121 |
|
$cause, |
| 122 |
|
false |
| 123 |
|
); |
| 124 |
|
|
| 125 |
|
$self->template->writeCommandReply($dispatchMessage->getCommandIdentifier(), $message->toBytes()); |
| 126 |
|
}; |
| 127 |
|
|
| 128 |
|
$this->localSegment->dispatch( |
| 129 |
|
$dispatchMessage->getCommandMessage(), |