Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
.subscribe((request: TopicMessage) => {
const appSymbolicName = request.headers.get(MessageHeaders.AppSymbolicName);
Beans.get(ManifestRegistry).registerIntents(appSymbolicName, [request.body.intent]);
});
}
.pipe(mergeMap((request: TopicMessage) => {
const manifestRegistry = Beans.get(ManifestRegistry);
const replyTo = request.headers.get(MessageHeaders.ReplyTo);
const appSymbolicName = request.headers.get(MessageHeaders.AppSymbolicName);
return merge(of(null), manifestRegistry.intentChange$)
.pipe(
map(() => manifestRegistry.getIntentsByApplication(appSymbolicName)),
switchMap(intents => Beans.get(MessageClient).publish$(replyTo, intents)),
takeUntilUnsubscribe(replyTo),
);
}),
takeUntil(this._destroy$),