anchor.diff:                  reachable=false,
                   pending = [],
                   max_queue_size,
  +                reconnect_tref,
                   bytes_dropped={os:timestamp(), 0},
                   bytes_send={os:timestamp(), 0}}).
   
  
positive.code:                     end;
                  {error, Reason} ->
                      lager:warning("can't connect to cluster node ~p due to ~p", [RemoteNode, Reason]),
                      erlang:send_after(?RECONNECT, self(), reconnect),
                      State#state{reachable=false}
              end;
          {badrpc, nodedown} ->
              %% we don't scream.. vmq_cluster_mon screams
              erlang:send_after(?RECONNECT, self(), reconnect),
              State#state{reachable=false};
          E ->
              lager:warning("can't connect to cluster node ~p due to ~p", [RemoteNode, E]),
              erlang:send_after(?RECONNECT, self(), reconnect),
              State#state{reachable=false}
      end.
  
  %% connect_params is called by a RPC
  connect_params(_Node) ->
  
negative.code:             State#state{reachable=false}
      end;
  handle_message(reconnect, #state{reachable=false} = State) ->
      connect(State#state{reconnect_tref=undefined});
  handle_message(Msg, #state{node=Node, reachable=Reachable} = State) ->
      lager:warning("got unknown message ~p for node ~p (reachable ~p)",
                    [Msg, Node, Reachable]),
  