skelmen / nestjs-azure-service-bus Goto Github PK

AzureServiceBusModule.forRootAsync([
  {
    name: 'provider_name_1',
    useFactory: (configService: ConfigService) => ({
      connectionString: configService.get('connectionString1'),
      options: {} // Azure service bus client options
    }),
    inject: [ConfigService],
  },
  {
    name: 'provider_name_2',
    useFactory: () => ({
      connectionString: 'connectionString2',
      options: {} // Azure service bus client options
    }),
    inject: [],
  },
]),

@Injectable()
export class AppService {

  constructor(
    @Inject('provider_name_1') private readonly serviceBusClient: AzureServiceBusClient,
  ) { }

  getData(){
    const options = {}; // Azure options for configuring tracing and the abortSignal
    const payload = {
      body: {
        id: '39219'
      }
    };
    this.serviceBusClient.emit({ payload, options });
  }

  scheduleData(){
    const options = {};
    const payload = {
      body: {
        id: '39219'
      }
    };
    // (Optional) For scheduling messages
    const updateTime = new Date('2023-02-20 13:26:00+02');
    this.serviceBusClient.emit({ payload, options, updateTime });
  }
}

@Subscribe('service-bus-queue-name')
async handler(data) {
  console.log(data);
}