From a4e302e08e139997a76fabb84707e01f2a9d0d89 Mon Sep 17 00:00:00 2001 From: Daniel Kluge Date: Thu, 21 Dec 2023 13:38:46 +0100 Subject: [PATCH] stop() for mmb --- lib/src/multimessageBroker.ts | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/lib/src/multimessageBroker.ts b/lib/src/multimessageBroker.ts index 229fc6a..beeeff2 100644 --- a/lib/src/multimessageBroker.ts +++ b/lib/src/multimessageBroker.ts @@ -158,6 +158,16 @@ export default class MultiMessageBroker { } } + /** + * Stop the broker. + */ + public stop(): void { + for (const registration of this.aasRegistrations) { + registration.serverInstances?.forEach(server => server?.stop()); + registration.connectorInterfaces.forEach(connector => connector.disconnect()); + } + } + /** * Callback on an server request * @param request Request