@@ 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(), |