anchor.diff:              %%reconnect
               set_socket(State, notconnected);
           _ ->
  -            {_, MQL} = process_info(self(), message_queue_len),
  -            QL = msg_queue_len(State),
  -            case QL of
  +            case msg_queue_len(State) of
                   0 ->
  -                    if MQL > 4 ->
  +                    {_, MQL} = process_info(self(), message_queue_len),
  +                    if MQL > 5 ->
                               %% start message bundle for sending
                               %% io:format("MQL ~p~n", [MQL]),
                               T1 = set_msg_queue(State, [{DestPid, Message}]),
  -                            T2 = set_msg_queue_len(T1, QL + 1),
  +                            T2 = set_msg_queue_len(T1, 1),
                               set_desired_bundle_size(T2, util:min(MQL,200));
                          true ->
                               NewSocket =
  
positive.code:                 ok = inet:setopts(Socket, [{active, once}]),
                  State
      end,
      NewState;
  
  on({tcp_closed, Socket}, State) ->
      log:log(warn,"[ CC ] tcp closed info", []),
  
negative.code:                             T1 = set_socket(State, NewSocket),
                              inc_s_msg_count(T1)
                      end;
                  QL ->
                      DBS = desired_bundle_size(State),
                      MSBS = msgs_since_bundle_start(State),
                      case (QL + MSBS) >= DBS of
                          true ->
                              MQueue = [{DestPid, Message} | msg_queue(State)],
  %%                            io:format("Bundle Size: ~p~n", [length(MQueue)]),
                              NewSocket =
                                  send({dest_ip(State), dest_port(State), Socket},
                                       unpack_msg_bundle, MQueue),
                              T1State = set_socket(State, NewSocket),
                              T2State = inc_s_msg_count(T1State),
                              T3State = set_msg_queue(T2State, []),
                              T4State = set_msg_queue_len(T3State, 0),
                              _T5State = set_msgs_since_bundle_start(T4State,0);
                          false ->
                              %% add to message bundle
                              T1 = set_msg_queue(State, [{DestPid, Message}
  