← Back to branch summary

~ubuntu-branches/ubuntu/trusty/rabbitmq-server/trusty

« back to all changes in this revision

Viewing changes to plugins-src/rabbitmq-mqtt/src/rabbit_mqtt_collector.erl

  • Committer: Package Import Robot
  • Author(s): Emile Joubert
  • Date: 2013-11-11 09:49:42 UTC
  • mfrom: (0.5.8) (0.1.44 sid)
  • Revision ID: package-import@ubuntu.com-20131111094942-23vq5tsb04eo9hzv
Tags: 3.2.1-1
New upstream release

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugins-src/rabbitmq-mqtt/src/rabbit_mqtt_collector.erl
49
49
            State = #state{client_ids = Ids}) ->
50
50
    Ids1 = case dict:find(ClientId, Ids) of
51
51
               {ok, {OldPid, MRef}} when Pid =/= OldPid ->
52
 
                   catch gen_server2:call(OldPid, duplicate_id),
 
52
                   catch gen_server2:call(OldPid, duplicate_id, infinity),
53
53
                   erlang:demonitor(MRef),
54
54
                   dict:erase(ClientId, Ids);
55
55
               error ->