Packages

rabbitex

0.1.1
0.1.1 retired 0.1.0 retired

rabbitex contains a set of tools that make working with RabbitMQ consume/produce pipelines easier

Retired package: Deprecated - Please use rabbit_mq_ex package instead
HexDocs

Current section

Files

Jump to
Readme
2 Versions
3 Dependencies
Dependants
Files
Activity
rabbitex lib __examples application.ex
Raw

lib/__examples/application.ex 

defmodule Examples.Application do

  alias Examples.Processors.{AuditLogProcessor, LogProcessor}

  alias Examples.Producers.{AuditLogProducer, LogProducer}

  alias MQ.Supervisor



  use Application



  def start(_type, _args) do

    opts = [

      consumers: [

        {AuditLogProcessor, workers: 1, queue: "audit_log_queue/#/example"},

        {LogProcessor, workers: 1, queue: "log_queue/#/example"}

      ],

      producers: [

        {AuditLogProducer, workers: 1},

        {LogProducer, workers: 1}

      ]

    ]



    Supervisor.start_link(opts)

  end

end