gmr / alpine-rabbitmq-autocluster Goto Github PK
View Code? Open in Web Editor NEWRabbitMQ image with the autocluster plugin
Home Page: https://hub.docker.com/r/gavinmroy/alpine-rabbitmq-autocluster/
RabbitMQ image with the autocluster plugin
Home Page: https://hub.docker.com/r/gavinmroy/alpine-rabbitmq-autocluster/
Using the CloudFormation stack - as is but running in eu-west-1, I see the clustering mechanism working as expected but I cannot make a connection from my client code (the management interface is available). Looking at the logs I get the following messages:
`=CRASH REPORT==== 6-Jun-2016::12:38:56 ===
crasher:
initial call: gen:init_it/6
pid: <0.5973.3>
registered_name: []
exception exit: {amqp_error,internal_error,
"Interceptor: more than one module handles {set,1,16,16,8,80,48,\n {[],[],[],[],[],[],[],[],[],[],[],\n [],[],[],[],[]},\n {{[],[],[],[],[],[],[],[],\n ['basic.publish'],\n [],[],[],[],[],[],[]}}}\n",
none}
in function gen_server2:init_it/6 (src/gen_server2.erl, line 601)
ancestors: [<0.5970.3>,<0.5968.3>,<0.5962.3>,<0.5961.3>,<0.859.0>,
<0.858.0>,<0.857.0>,rabbit_sup,<0.82.0>]
messages: []
links: [<0.5970.3>]
dictionary: [{process_name,
{rabbit_channel,
{<<"80.255.245.230:39333 -> 172.31.3.42:5672">>,
1}}}]
trap_exit: true
status: running
heap_size: 1598
stack_size: 27
reductions: 2212
neighbours:
=CRASH REPORT==== 6-Jun-2016::12:38:56 ===
crasher:
initial call: rabbit_reader:init/4
pid: <0.5963.3>
registered_name: []
exception error: no match of right hand side value
{error,
{'EXIT',
{{badmatch,
{error,
{{amqp_error,internal_error,
"Interceptor: more than one module handles {set,1,16,16,8,80,48,\n {[],[],[],[],[],[],[],[],[],[],[],\n [],[],[],[],[]},\n {{[],[],[],[],[],[],[],[],\n ['basic.publish'],\n [],[],[],[],[],[],[]}}}\n",
none},
{child,undefined,channel,
{rabbit_channel,start_link,
[1,<0.5963.3>,<0.5971.3>,<0.5963.3>,
<<"80.255.245.230:39333 -> 172.31.3.42:5672">>,
rabbit_framing_amqp_0_9_1,
{user,<<"guest">>,
[administrator],
[{rabbit_auth_backend_internal,none}]},
<<"/">>,
[{<<"connection.blocked">>,bool,true},
{<<"authentication_failure_close">>,bool,true},
{<<"consumer_cancel_notify">>,bool,true},
{<<"publisher_confirms">>,bool,true},
{<<"basic.nack">>,bool,true}],
<0.5965.3>,<0.5972.3>]},
intrinsic,70000,worker,
[rabbit_channel]}}}},
[{rabbit_channel_sup,start_link,1,
[{file,"src/rabbit_channel_sup.erl"},{line,67}]},
{supervisor2,do_start_child_i,3,
[{file,"src/supervisor2.erl"},{line,437}]},
{supervisor2,handle_call,3,
[{file,"src/supervisor2.erl"},{line,463}]},
{gen_server,try_handle_call,4,
[{file,"gen_server.erl"},{line,629}]},
{gen_server,handle_msg,5,
[{file,"gen_server.erl"},{line,661}]},
{proc_lib,init_p_do_apply,3,
[{file,"proc_lib.erl"},{line,240}]}]}}}
in function rabbit_reader:create_channel/2 (src/rabbit_reader.erl, line 916)
in call from rabbit_reader:process_frame/3 (src/rabbit_reader.erl, line 972)
in call from rabbit_reader:handle_input/3 (src/rabbit_reader.erl, line 1035)
in call from rabbit_reader:recvloop/4 (src/rabbit_reader.erl, line 446)
in call from rabbit_reader:run/1 (src/rabbit_reader.erl, line 428)
in call from rabbit_reader:start_connection/4 (src/rabbit_reader.erl, line 386)
ancestors: [<0.5961.3>,<0.859.0>,<0.858.0>,<0.857.0>,rabbit_sup,
<0.82.0>]
messages: [{'EXIT',#Port<0.41801>,normal}]
links: [<0.5961.3>]
dictionary: [{process_name,
{rabbit_reader,
<<"80.255.245.230:39333 -> 172.31.3.42:5672">>}}]
trap_exit: true
status: running
heap_size: 2586
stack_size: 27
reductions: 3992
neighbours:
=SUPERVISOR REPORT==== 6-Jun-2016::12:38:56 ===
Supervisor: {<0.5961.3>,rabbit_connection_sup}
Context: child_terminated
Reason: {badmatch,
{error,
{'EXIT',
{{badmatch,
{error,
{{amqp_error,internal_error,
"Interceptor: more than one module handles {set,1,16,16,8,80,48,\n {[],[],[],[],[],[],[],[],[],[],[],\n [],[],[],[],[]},\n {{[],[],[],[],[],[],[],[],\n ['basic.publish'],\n [],[],[],[],[],[],[]}}}\n",
none},
{child,undefined,channel,
{rabbit_channel,start_link,
[1,<0.5963.3>,<0.5971.3>,<0.5963.3>,
<<"80.255.245.230:39333 -> 172.31.3.42:5672">>,
rabbit_framing_amqp_0_9_1,
{user,<<"guest">>,
[administrator],
[{rabbit_auth_backend_internal,none}]},
<<"/">>,
[{<<"connection.blocked">>,bool,true},
{<<"authentication_failure_close">>,bool,true},
{<<"consumer_cancel_notify">>,bool,true},
{<<"publisher_confirms">>,bool,true},
{<<"basic.nack">>,bool,true}],
<0.5965.3>,<0.5972.3>]},
intrinsic,70000,worker,
[rabbit_channel]}}}},
[{rabbit_channel_sup,start_link,1,
[{file,"src/rabbit_channel_sup.erl"},{line,67}]},
{supervisor2,do_start_child_i,3,
[{file,"src/supervisor2.erl"},{line,437}]},
{supervisor2,handle_call,3,
[{file,"src/supervisor2.erl"},{line,463}]},
{gen_server,try_handle_call,4,
[{file,"gen_server.erl"},{line,629}]},
{gen_server,handle_msg,5,
[{file,"gen_server.erl"},{line,661}]},
{proc_lib,init_p_do_apply,3,
[{file,"proc_lib.erl"},{line,240}]}]}}}}
Offender: [{pid,<0.5963.3>},
{name,reader},
{mfargs,
{rabbit_reader,start_link,
[<0.5962.3>,
{acceptor,{0,0,0,0,0,0,0,0},5672},
#Port<0.41801>]}},
{restart_type,intrinsic},
{shutdown,4294967295},
{child_type,worker}]
=SUPERVISOR REPORT==== 6-Jun-2016::12:38:56 ===
Supervisor: {<0.5961.3>,rabbit_connection_sup}
Context: shutdown
Reason: reached_max_restart_intensity
Offender: [{pid,<0.5963.3>},
{name,reader},
{mfargs,
{rabbit_reader,start_link,
[<0.5962.3>,
{acceptor,{0,0,0,0,0,0,0,0},5672},
#Port<0.41801>]}},
{restart_type,intrinsic},
{shutdown,4294967295},
{child_type,worker}]`
Any idea what could be causing this?
Hi,
I'm trying to start my rabbitmq server, while I can successfully build the docker image the server will always fail to boot and I get the following error description:
BOOT FAILED
===========
Error description:
{error,{cannot_log_to_file,"-",{error,eacces}}}
Log files (may contain more information):
-
-
Stack trace:
[{rabbit,ensure_working_log_handler,5,[]},
{rabbit,ensure_working_log_handlers,0,[]},
{rabbit,'-boot/0-fun-1-',0,[]},
{rabbit,start_it,1,[]},
{init,start_em,1,[]},
{init,do_boot,3,[]}]
init terminating in do_boot ()
{"init terminating in do_boot",{rabbit,failure_during_boot,{error,{cannot_log_to_file,"-",{error,eacces}}}}}
I'm setting up the correct permissions as per the sample dockerfile
RUN chown -R rabbitmq /var/lib/rabbitmq/.erlang.cookie /var/lib/rabbitmq /usr/lib/rabbitmq
and setting the environmental variables in the same manner:
ENV RABBITMQ_LOGS=-
ENV RABBITMQ_SASL_LOGS=-
Unlike the original dockerfile I am required to use a previous version of [email protected]
Am I missing something that would stop the server from starting correctly?
I'm new to rabbitmq so any help would be greatly appreciated.
Thanks in advance!
How can I handle RabbitMQ Users?
I tried using alpine-rabbitmq-autocluster to setup RabbitMQ AutoCluster using Consul but I am getting the below error. Please share your inputs in case I am missing anything in the configuration.
I am attaching the config and error details
[
{
rabbit,
[
{loopback_users, []},
{cluster_partition_handling, autoheal},
{delegate_count, 64},
{fhc_read_buffering, false},
{fhc_write_buffering, false},
{heartbeat, 60},
{queue_index_embed_msgs_below, 0},
{queue_index_max_journal_entries, 8192},
{log_levels, [{autocluster, info},
{connection, error},
{channel, warning},
{federation, info},
{mirroring, info},
{shovel, info}]},
{vm_memory_high_watermark, 0.8}
]
}
].
docker run --rm -t -i --name=consul \
-p 8500:8500 \
gavinmroy/alpine-consul:0.5.2-0
docker run -h 192.168.99.100 --link=consul --name=node1 -d \
--net=host \
-e AUTOCLUSTER_TYPE=consul \
-e CONSUL_SCHEME=http \
-e CONSUL_HOST=192.168.99.100 \
-e CONSUL_PORT=8500 \
-e CONSUL_SVC=rabbitmq \
-e CONSUL_SVC_ADDR=node1 \
-e CONSUL_SVC_TTL=60 \
-e RABBITMQ_USE_LONGNAME=true \
-e RABBITMQ_NODENAME=node1 \
-p 4369:4369 \
-p 5672:5672 \
-p 15672:15672 \
-p 25672:25672 \
tandv001/alpine-rabbitmq-autocluster:1.0
docker run -h 192.168.99.100 --link=consul --name=node2 -d \
--net=host \
-e AUTOCLUSTER_TYPE=consul \
-e CONSUL_SCHEME=http \
-e CONSUL_HOST=192.168.99.100 \
-e CONSUL_PORT=8500 \
-e CONSUL_SVC=rabbitmq \
-e CONSUL_SVC_ADDR=node2 \
-e CONSUL_SVC_TTL=60 \
-e RABBITMQ_USE_LONGNAME=true \
-e RABBITMQ_NODENAME=node2 \
-p 4370:4369 \
-p 5673:5672 \
-p 15673:15672 \
-p 25673:25672 \
tandv001/alpine-rabbitmq-autocluster:1.0
Error Logs
node2_logs.txt
Consul Service Logs
[
{
"Node": "67593aa3ad38",
"Address": "172.17.0.2",
"ServiceID": "rabbitmq:node1",
"ServiceName": "rabbitmq",
"ServiceTags": null,
"ServiceAddress": "node1",
"ServicePort": 5672
},
{
"Node": "67593aa3ad38",
"Address": "172.17.0.2",
"ServiceID": "rabbitmq:node2",
"ServiceName": "rabbitmq",
"ServiceTags": null,
"ServiceAddress": "node2",
"ServicePort": 5672
}
]
[
{
"Node": {
"Node": "consul",
"Address": "172.17.0.2"
},
"Service": {
"ID": "rabbitmq:node1",
"Service": "rabbitmq",
"Tags": null,
"Address": "node1",
"Port": 5672
},
"Checks": [
{
"Node": "consul",
"CheckID": "service:rabbitmq:node1",
"Name": "Service 'rabbitmq' check",
"Status": "passing",
"Notes": "RabbitMQ Auto-Cluster Plugin TTL Check",
"Output": "",
"ServiceID": "rabbitmq:node1",
"ServiceName": "rabbitmq"
},
{
"Node": "consul",
"CheckID": "serfHealth",
"Name": "Serf Health Status",
"Status": "passing",
"Notes": "",
"Output": "Agent alive and reachable",
"ServiceID": "",
"ServiceName": ""
}
]
},
{
"Node": {
"Node": "consul",
"Address": "172.17.0.2"
},
"Service": {
"ID": "rabbitmq:node2",
"Service": "rabbitmq",
"Tags": null,
"Address": "node2",
"Port": 5672
},
"Checks": [
{
"Node": "consul",
"CheckID": "service:rabbitmq:node2",
"Name": "Service 'rabbitmq' check",
"Status": "critical",
"Notes": "RabbitMQ Auto-Cluster Plugin TTL Check",
"Output": "",
"ServiceID": "rabbitmq:node2",
"ServiceName": "rabbitmq"
},
{
"Node": "consul",
"CheckID": "serfHealth",
"Name": "Serf Health Status",
"Status": "passing",
"Notes": "",
"Output": "Agent alive and reachable",
"ServiceID": "",
"ServiceName": ""
}
]
}
]
I have been trying to add users to rabbit, but i am not able to do it. Can you help me out to figure out if i am doing something wrong
A declarative, efficient, and flexible JavaScript library for building user interfaces.
๐ Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
An Open Source Machine Learning Framework for Everyone
The Web framework for perfectionists with deadlines.
A PHP framework for web artisans
Bring data to life with SVG, Canvas and HTML. ๐๐๐
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
Some thing interesting about web. New door for the world.
A server is a program made to process requests and deliver data to clients.
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Some thing interesting about visualization, use data art
Some thing interesting about game, make everyone happy.
We are working to build community through open source technology. NB: members must have two-factor auth.
Open source projects and samples from Microsoft.
Google โค๏ธ Open Source for everyone.
Alibaba Open Source for everyone
Data-Driven Documents codes.
China tencent open source team.