rabbitmq / rabbitmq-web-stomp

Provides support for STOMP over WebSockets
Other
89 stars 26 forks source link

Scary message when connection is closed #102

Closed acogoluegnes closed 5 years ago

acogoluegnes commented 5 years ago

There's a scary message on normal connection closing:

2018-12-11 11:22:54.981 [error] <0.715.0> ** Generic server <0.715.0> terminating 
** Last message in was {'EXIT',<0.711.0>,normal}
** When Server state == {state,amqp_direct_connection,{state,'rabbit@acogoluegnes-inspiron',{user,<<"guest">>,[administrator],[{rabbit_auth_backend_internal,none}]},<<"/">>,{amqp_params_direct,<<"guest">>,<<"guest">>,<<"/">>,'rabbit@acogoluegnes-inspiron',{amqp_adapter_info,{127,0,0,1},15674,{127,0,0,1},48106,<<"127.0.0.1:48106 -> 127.0.0.1:15674">>,{'Web STOMP',"1.0"},[{channels,1},{channel_max,1},{frame_max,0},{client_properties,[{<<"product">>,longstr,<<"STOMP client">>}]},{state,running},{ssl,false}]},[]},{amqp_adapter_info,{127,0,0,1},15674,{127,0,0,1},48106,<<"127.0.0.1:48106 -> 127.0.0.1:15674">>,{'Web STOMP',"1.0"},[{channels,1},{channel_max,1},{frame_max,0},{client_properties,[{<<"product">>,longstr,<<"STOMP client">>}]},{state,running},{ssl,false}]},<0.719.0>,undefined,1544523774974},<0.718.0>,{amqp_params_direct,<<"guest">>,<<"guest">>,<<"/">>,'rabbit@acogoluegnes-inspiron',{amqp_adapter_info,{127,0,0,1},15674,{127,0,0,1},48106,<<"127.0.0.1:48106 -> 127.0.0.1:15674">>,{'Web STOMP',"1.0"},[{channels,1},{channel_max,1},{frame_max,0},{client_properties,[{<<"product">>,longstr,<<"STOMP client">>}]},{state,running},{ssl,false}]},[]},0,[{<<"capabilities">>,table,[{<<"publisher_confirms">>,bool,true},{<<"exchange_exchange_bindings">>,bool,true},{<<"basic.nack">>,bool,true},{<<"consumer_cancel_notify">>,bool,true},{<<"connection.blocked">>,bool,true},{<<"consumer_priorities">>,bool,true},{<<"authentication_failure_close">>,bool,true},{<<"per_consumer_qos">>,bool,true},{<<"direct_reply_to">>,bool,true}]},{<<"cluster_name">>,longstr,<<"rabbit@acogoluegnes-inspiron">>},{<<"copyright">>,longstr,<<"Copyright (C) 2007-2018 Pivotal Software, Inc.">>},{<<"information">>,longstr,<<"Licensed under the MPL.  See http://www.rabbitmq.com/">>},{<<"platform">>,longstr,<<"Erlang/OTP 21.1.1">>},{<<"product">>,longstr,<<"RabbitMQ">>},{<<"version">>,longstr,<<"3.7.10-alpha.10">>}],none,false}
** Reason for termination == 
** "stopping because dependent process <0.711.0> died: normal"
2018-12-11 11:22:54.981 [error] <0.715.0> CRASH REPORT Process <0.715.0> with 0 neighbours exited with reason: "stopping because dependent process <0.711.0> died: normal" in gen_server:handle_common_reply/8 line 751
2018-12-11 11:22:54.982 [error] <0.713.0> Supervisor {<0.713.0>,amqp_connection_sup} had child connection started with amqp_gen_connection:start_link(<0.714.0>, {amqp_params_direct,<<"guest">>,<<"guest">>,<<"/">>,'rabbit@acogoluegnes-inspiron',{amqp_adapter_info,...},...}) at <0.715.0> exit with reason "stopping because dependent process <0.711.0> died: normal" in context child_terminated
2018-12-11 11:22:54.982 [error] <0.713.0> Supervisor {<0.713.0>,amqp_connection_sup} had child connection started with amqp_gen_connection:start_link(<0.714.0>, {amqp_params_direct,<<"guest">>,<<"guest">>,<<"/">>,'rabbit@acogoluegnes-inspiron',{amqp_adapter_info,...},...}) at <0.715.0> exit with reason reached_max_restart_intensity in context shutdown

Reproduce with the following Groovy script:

import org.java_websocket.client.WebSocketClient
import org.java_websocket.handshake.ServerHandshake

import java.util.concurrent.CountDownLatch
import java.util.concurrent.TimeUnit

@Grab(group = 'org.java-websocket', module = 'Java-WebSocket', version = "1.3.9")

CountDownLatch latch = new CountDownLatch(1);
WebSocketClient client = new WebSocketClient(new URI("ws://localhost:15674/ws")) {
    @Override
    void onOpen(ServerHandshake serverHandshake) {

    }

    @Override
    void onMessage(String s) {
        if (s.contains("CONNECTED")) {
            latch.countDown()
        }
    }

    @Override
    void onClose(int i, String s, boolean b) {}

    @Override
    void onError(Exception e) {
        e.printStackTrace();
    }
}

client.connectBlocking()
client.send("CONNECT\nlogin: guest\npasscode: guest\n\n\u0000")
if (!latch.await(5, TimeUnit.SECONDS)) {
    throw new RuntimeException("Could not connect in 5 seconds")
}
client.closeBlocking()

Tried on 3.7.9, there's no message. Happens on both 3.8.x and 3.7.x.