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