|
@@ 258-268 (lines=11) @@
|
| 255 |
|
* |
| 256 |
|
* @throws UnknownProcedureException if the procedure is unknown |
| 257 |
|
*/ |
| 258 |
|
public function confirmRegistration($procedureName, $requestId = 1, $registrationId = 1) |
| 259 |
|
{ |
| 260 |
|
if (!isset($this->registrations[$procedureName])) { |
| 261 |
|
throw new UnknownProcedureException($procedureName); |
| 262 |
|
} |
| 263 |
|
|
| 264 |
|
$futureResult = $this->registrations[$procedureName]; |
| 265 |
|
$result = new RegisteredMessage($requestId, $registrationId); |
| 266 |
|
|
| 267 |
|
$futureResult->resolve($result); |
| 268 |
|
} |
| 269 |
|
|
| 270 |
|
/** |
| 271 |
|
* Triggers a call to a registered procedure and returns its result. |
|
@@ 317-327 (lines=11) @@
|
| 314 |
|
* |
| 315 |
|
* @throws UnknownProcedureException |
| 316 |
|
*/ |
| 317 |
|
public function confirmUnregistration($procedureName, $requestId = 1) |
| 318 |
|
{ |
| 319 |
|
if (!isset($this->unregistrations[$procedureName])) { |
| 320 |
|
throw new UnknownProcedureException($procedureName); |
| 321 |
|
} |
| 322 |
|
|
| 323 |
|
$futureResult = $this->unregistrations[$procedureName]; |
| 324 |
|
$result = new UnregisteredMessage($requestId); |
| 325 |
|
|
| 326 |
|
$futureResult->resolve($result); |
| 327 |
|
} |
| 328 |
|
|
| 329 |
|
/** |
| 330 |
|
* Call. |