Module messaging-plugin/src

Example

import { MessagingPlugin } from '@setu-ts/messaging-plugin';
import { CAPABILITIES } from '@setu-ts/common';

// GCP Pub/Sub
app.register(MessagingPlugin({
  broker: 'pubsub',
  projectId: 'my-project',
}));

// Azure Service Bus
app.register(MessagingPlugin({
  broker: 'service-bus',
  connectionString: 'Endpoint=sb://...',
}));

// Custom broker
app.register(MessagingPlugin({
  broker: 'custom',
  instance: myBroker,
}));
Copy