Advertisement
Guest User

bino_rbmq_config

a guest
May 21st, 2012
110
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Erlang 7.40 KB | None | 0 0
  1. [
  2.     {mnesia, [{dump_log_write_threshold, 100}
  3.              ]},
  4.     {rabbit, [{vm_memory_high_watermark, 0.4}
  5.              ]},
  6.     {rabbitmq_shovel,
  7.        [{shovels,
  8.          [
  9.             {myshovel,
  10.                [{sources, [
  11.                     {broker, "amqp://guest:guest@localhost"},
  12.                     {declarations, [
  13.                         {'exchange.declare', [{exchange, <<"source_exchange">>}, {type, <<"direct">>}, durable]},
  14.                         {'queue.declare', [{queue, <<"task_queue">>}, durable]},
  15.                         {'queue.bind', [{exchange, <<"source_exchange">>}, {queue, <<"task_queue">>}]}
  16.                     ]}
  17.                 ]},
  18.                 {destinations, [
  19.                     {broker, "amqp://bino01:123@192.168.10.241/bino01"},
  20.                     {declarations, [
  21.                         {'exchange.declare', [{exchange, <<"destination_exchange">>}, {type, <<"direct">>}, durable]},
  22.                         {'queue.declare', [{queue, <<"bino01q1">>}, durable]},
  23.                         {'queue.bind', [{exchange, <<"destination_exchange">>}, {queue, <<"bino01q1">>}]}
  24.                     ]}
  25.                 ]},
  26.                 {queue, <<"task_queue">>},
  27.                 {publish_fields, [
  28.                     {exchange, <<"destination_exchange">>}
  29.                 ]},
  30.                 {reconnect_delay, 5}
  31.                ]},
  32.             {fleet_shovel1,
  33.                [{sources, [
  34.                     {broker, "amqp://guest:guest@localhost"},
  35.                     {declarations, [
  36.                         {'exchange.declare', [{exchange, <<"fleet_exchange">>}, {type, <<"direct">>}, durable]},
  37.                         {'queue.declare', [{queue, <<"fleet_queue">>}, durable]},
  38.                         {'queue.bind', [{exchange, <<"fleet_exchange">>}, {queue, <<"fleet_queue">>}]}
  39.                     ]}
  40.                 ]},
  41.                 {destinations, [
  42.                     {broker, "amqp://fleet_bot:fleet123@rbmq.myownserver.bno/vh_fleet"},
  43.                     {declarations, [
  44.                         {'exchange.declare', [{exchange, <<"fleet_exchange">>}, {type, <<"direct">>}, durable]},
  45.                         {'queue.declare', [{queue, <<"fleet_queue">>}, durable]},
  46.                         {'queue.bind', [{exchange, <<"fleet_exchange">>}, {queue, <<"fleet_queue">>}]}
  47.                     ]}
  48.                 ]},
  49.                 {queue, <<"fleet_queue">>},
  50.                 {publish_fields, [
  51.                     {exchange, <<"fleet_exchange">>}
  52.                 ]},
  53.                 {reconnect_delay, 5}
  54.                ]},
  55.             {fleet_shovel2,
  56.                [{sources, [
  57.                     {broker, "amqp://guest:guest@localhost"},
  58.                     {declarations, [
  59.                         {'exchange.declare', [{exchange, <<"fleet_exchange">>}, {type, <<"direct">>}, durable]},
  60.                         {'queue.declare', [{queue, <<"fleet_queue">>}, durable]},
  61.                         {'queue.bind', [{exchange, <<"fleet_exchange">>}, {queue, <<"fleet_queue">>}]}
  62.                     ]}
  63.                 ]},
  64.                 {destinations, [
  65.                     {broker, "amqp://fleet_bot:fleet123@rbmq.myownserver.bno/vh_fleet"},
  66.                     {declarations, [
  67.                         {'exchange.declare', [{exchange, <<"fleet_exchange">>}, {type, <<"direct">>}, durable]},
  68.                         {'queue.declare', [{queue, <<"fleet_queue">>}, durable]},
  69.                         {'queue.bind', [{exchange, <<"fleet_exchange">>}, {queue, <<"fleet_queue">>}]}
  70.                     ]}
  71.                 ]},
  72.                 {queue, <<"fleet_queue">>},
  73.                 {publish_fields, [
  74.                     {exchange, <<"fleet_exchange">>}
  75.                 ]},
  76.                 {reconnect_delay, 5}
  77.                ]},
  78.             {fleet_shovel3,
  79.                [{sources, [
  80.                     {broker, "amqp://guest:guest@localhost"},
  81.                     {declarations, [
  82.                         {'exchange.declare', [{exchange, <<"fleet_exchange">>}, {type, <<"direct">>}, durable]},
  83.                         {'queue.declare', [{queue, <<"fleet_queue">>}, durable]},
  84.                         {'queue.bind', [{exchange, <<"fleet_exchange">>}, {queue, <<"fleet_queue">>}]}
  85.                     ]}
  86.                 ]},
  87.                 {destinations, [
  88.                     {broker, "amqp://fleet_bot:fleet123@rbmq.myownserver.bno/vh_fleet"},
  89.                     {declarations, [
  90.                         {'exchange.declare', [{exchange, <<"fleet_exchange">>}, {type, <<"direct">>}, durable]},
  91.                         {'queue.declare', [{queue, <<"fleet_queue">>}, durable]},
  92.                         {'queue.bind', [{exchange, <<"fleet_exchange">>}, {queue, <<"fleet_queue">>}]}
  93.                     ]}
  94.                 ]},
  95.                 {queue, <<"fleet_queue">>},
  96.                 {publish_fields, [
  97.                     {exchange, <<"fleet_exchange">>}
  98.                 ]},
  99.                 {reconnect_delay, 5}
  100.                ]},
  101.             {fleet_shovel4,
  102.                [{sources, [
  103.                     {broker, "amqp://guest:guest@localhost"},
  104.                     {declarations, [
  105.                         {'exchange.declare', [{exchange, <<"fleet_exchange">>}, {type, <<"direct">>}, durable]},
  106.                         {'queue.declare', [{queue, <<"fleet_queue">>}, durable]},
  107.                         {'queue.bind', [{exchange, <<"fleet_exchange">>}, {queue, <<"fleet_queue">>}]}
  108.                     ]}
  109.                 ]},
  110.                 {destinations, [
  111.                     {broker, "amqp://fleet_bot:fleet123@rbmq.myownserver.bno/vh_fleet"},
  112.                     {declarations, [
  113.                         {'exchange.declare', [{exchange, <<"fleet_exchange">>}, {type, <<"direct">>}, durable]},
  114.                         {'queue.declare', [{queue, <<"fleet_queue">>}, durable]},
  115.                         {'queue.bind', [{exchange, <<"fleet_exchange">>}, {queue, <<"fleet_queue">>}]}
  116.                     ]}
  117.                 ]},
  118.                 {queue, <<"fleet_queue">>},
  119.                 {publish_fields, [
  120.                     {exchange, <<"fleet_exchange">>}
  121.                 ]},
  122.                 {reconnect_delay, 5}
  123.                ]},
  124.             {fleet_shovel5,
  125.                [{sources, [
  126.                     {broker, "amqp://guest:guest@localhost"},
  127.                     {declarations, [
  128.                         {'exchange.declare', [{exchange, <<"fleet_exchange">>}, {type, <<"direct">>}, durable]},
  129.                         {'queue.declare', [{queue, <<"fleet_queue">>}, durable]},
  130.                         {'queue.bind', [{exchange, <<"fleet_exchange">>}, {queue, <<"fleet_queue">>}]}
  131.                     ]}
  132.                 ]},
  133.                 {destinations, [
  134.                     {broker, "amqp://fleet_bot:fleet123@rbmq.myownserver.bno/vh_fleet"},
  135.                     {declarations, [
  136.                         {'exchange.declare', [{exchange, <<"fleet_exchange">>}, {type, <<"direct">>}, durable]},
  137.                         {'queue.declare', [{queue, <<"fleet_queue">>}, durable]},
  138.                         {'queue.bind', [{exchange, <<"fleet_exchange">>}, {queue, <<"fleet_queue">>}]}
  139.                     ]}
  140.                 ]},
  141.                 {queue, <<"fleet_queue">>},
  142.                 {publish_fields, [
  143.                     {exchange, <<"fleet_exchange">>}
  144.                 ]},
  145.                 {reconnect_delay, 5}
  146.                ]}
  147.           ]
  148.         }]
  149.      }
  150. ].
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement