README

简介

此包基于https://github.com/Phobetor/rabbitmq-supervisor-bundle，并增加了对https://github.com/ricbra/rabbitmq-cli-consumer的支持。为了更有效地避免运行时缓存。

安装

使用composer要求此包及其依赖

$ composer require myonlinestore/rabbitmq-manager-bundle

将包注册到您的app/AppKernel.php

public function registerBundles()
{
    $bundles = [
        new MyOnlineStore\Bundle\RabbitMqManagerBundle\RabbitMqManagerBundle(),
    ];
}

使用

所有配置选项都是可选的。

完整默认配置

rabbit_mq_manager:
    path: "%kernel.root_dir%/../var/supervisor/%kernel.name%"
    commands: # console commands to execute for specific worker types
      cli_consumer_invoker: "rabbitmq-manager:consumer" # this will use the rabbitmq-cli-consumer invoker, defined within this package.
      consumers: "rabbitmq:consumer" # OldSoundRabbitMqBundle default consumer command
      rpc_servers: "rabbitmq:rpc-server" # OldSoundRabbitMqBundle default rpc-server command
    consumers:
      general:
        processor: "bundle" # either "bundle" or "cli-consumer"
        messages: 0 # amount of messages to process before restarting the consumer (only applicable for processor "bundle")
        compression: true # use compression (only applicable for processor "cli-consumer")
        worker: # http://supervisord.org/configuration.html#program-x-section-values
          count: 1
          startsecs: 0
          autorestart: true
          stopsignal: "INT"
          stopasgroup: true
          stopwaitsecs: 60
      individual:
        # my_consumer:
          # see general configuration
    rpc_servers: # see consumers

示例配置

rabbit_mq_manager:
    consumers:
      general:
        processor: "bundle"
        messages: 1 # only consume 1 message before quiting/restarting
        worker: # http://supervisord.org/configuration.html#program-x-section-values
          count: 1
      individual:
        my_consumer:
          messages: 0 # don't restart "my_consumer" after consuming messages
          worker:
              count: 8 # start 8 listeners/processors for "my_consumer"
        my_other_consumer:
          processor: "cli-consumer"
          compression: true
          worker:
            count: 4