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