Class ConsumerRouter

Example

import { DIContainer } from '@famir/common'
import { CONSUMER_ROUTER, ConsumerRouter } from '@famir/consumer'
import { ANALYZE_QUEUE_NAME } from '@famir/producer'

// Get container singleton
const container = DIContainer.getInstance()

// Register in DI container
ConsumerRouter.register(container)

// Resolve from DI container
const router = container.resolve<ConsumerRouter>(CONSUMER_ROUTER)

// Add queue
router.addQueue()

// Add custom processor
router.addProcessor(ANALYZE_QUEUE_NAME, async (data) => {
  // Worker logic here..
  console.log(data)

  return true
})

// Activate router
router.activate()
Copy