RabbitMQ limitado a um escravo

1

Estou tendo um problema estranho com o rabbitmq ao implantar na AWS.

Quando eu giro um mestre e conecto um escravo a ele tudo vai bem e eu tenho dois servidores no cluster. Quando eu vou adicionar o segundo escravo ao mestre ele simplesmente fica no join_cluster e irá esperar indefinidamente sem lançar nenhum erro. Assim que eu parar o primeiro escravo, o segundo irá se juntar instantaneamente. Não consigo encontrar mais ninguém com esse problema ou qualquer configuração que limite o número de escravos.

este é o passo que eu corro em ambos os servidores escravos depois de adicionar uma entrada ao arquivo host que aponta um ip para mestre

rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster rabbit@master
rabbitmqctl start_app

este é o meu arquivo rabbitmq.config.

    [
 {rabbit,
  [
   {tcp_listeners, [{{ rabbitmq_amqp_port }}]},

   %% SSL listeners are configured in the same fashion as TCP listeners,
   %% including the option to control the choice of interface.
   %%
   %% {ssl_listeners, [5671]},

   %% Maximum time for AMQP 0-8/0-9/0-9-1 handshake (after socket connection
   %% and SSL handshake), in milliseconds.
   %%
   %% {handshake_timeout, 10000},

    {log_levels, [{connection, info}]},
    {loopback_users, [<<"{{ rabbitmq_loopback_user }}">>]},

   %% Configuring SSL.
   %% See http://www.rabbitmq.com/ssl.html for full documentation.
   %%
   %% {ssl_options, [{cacertfile,           "/path/to/testca/cacert.pem"},
   %%                {certfile,             "/path/to/server/cert.pem"},
   %%                {keyfile,              "/path/to/server/key.pem"},
   %%                {verify,               verify_peer},
   %%                {fail_if_no_peer_cert, false}]},
    {default_vhost,       <<"{{ rabbitmq_default_vhost }}">>},
    {default_user,        <<"{{ rabbitmq_default_user }}">>},
    {default_pass,        <<"{{ rabbitmq_default_pass }}">>},
    {default_permissions, [<<".*">>, <<".*">>, <<".*">>]},
    {default_user_tags, [{{ rabbitmq_default_user_tags }}]},
    {channel_max, 128},

   %% Customising Socket Options.
   %%
   %% See (http://www.erlang.org/doc/man/inet.html#setopts-2) for
   %% further documentation.
   %%
   %% {tcp_listen_options, [binary,
   %%                       {packet,        raw},
   %%                       {reuseaddr,     true},
   %%                       {backlog,       128},
   %%                       {nodelay,       true},
   %%                       {exit_on_close, false}]},

    {vm_memory_high_watermark, {{ rabbitmq_high_watermark }} },
    {vm_memory_high_watermark_paging_ratio, {{ rabbitmq_high_watermark_paging }} },

   %% Set disk free limit (in bytes). Once free disk space reaches this
   %% lower bound, a disk alarm will be set - see the documentation
   %% listed above for more details.
   %%
   %% {disk_free_limit, 50000000},

      {disk_free_limit, {mem_relative, {{rabbitmq_disk_free_limit}} }}

   %% Make clustering happen *automatically* at startup - only applied
   %% to nodes that have just been reset or started for the first time.
   %% See http://www.rabbitmq.com/clustering.html#auto-config for
   %% further details.
   %%
   %% {cluster_nodes, {['[email protected]'], disc}},
  ]}
].

writeup completo disponível na lista de e-mails rabbitmq link

    
por mschuett 06.01.2015 / 20:41

0 respostas