diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2016-08-11 13:37:36 +0100 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2016-08-11 13:37:36 +0100 |
| commit | 7749aa8e6072db0a6681cec0000e2794e7e317ba (patch) | |
| tree | 6bc7d31ad7830f991912004e839a21991c50ea21 /src | |
| parent | b68ce3f76e22aefd6ba8091e1f6a8d0cc141bf92 (diff) | |
| download | rabbitmq-server-git-7749aa8e6072db0a6681cec0000e2794e7e317ba.tar.gz | |
Push connection created/closed events
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_direct.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_direct.erl b/src/rabbit_direct.erl index 061105c150..8e429b3ab8 100644 --- a/src/rabbit_direct.erl +++ b/src/rabbit_direct.erl @@ -109,6 +109,7 @@ authz_socket_info_direct(Infos) -> connect1(User, VHost, Protocol, Pid, Infos) -> try rabbit_access_control:check_vhost_access(User, VHost, authz_socket_info_direct(Infos)) of ok -> ok = pg_local:join(rabbit_direct, Pid), + rabbit_core_metrics:connection_created(Pid, Infos), rabbit_event:notify(connection_created, Infos), {ok, {User, rabbit_reader:server_properties(Protocol)}} catch @@ -127,4 +128,5 @@ start_channel(Number, ClientChannelPid, ConnPid, ConnName, Protocol, User, disconnect(Pid, Infos) -> pg_local:leave(rabbit_direct, Pid), + rabbit_core_metrics:connection_closed(Pid), rabbit_event:notify(connection_closed, Infos). |