import { RabbitMQBroker, event } from '@bitspacerlabs/rabbit-relay'

const broker = new RabbitMQBroker('scheduler_service')

await broker
  .queue('scheduler_publish_queue')
  .exchange('scheduler_exchange', {
    exchangeType: 'topic',
    publisherConfirms: true
  })
  .publish(event('scheduler.scheduleTask', {
    id: 'task_123',
    when: Date.now()
  }))