stop() for mmb
This commit is contained in:
@@ -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
|
* Callback on an server request
|
||||||
* @param request Request
|
* @param request Request
|
||||||
|
|||||||
Reference in New Issue
Block a user