anchor.diff:              Ws:send(M:F(Msg)),
               handle_websocket(State);
           {browser, Data} ->
  -            {E, R} = parse_data(Data),
  -            error_logger:info_msg("Binding to exchange: ~p with RKey: ~p~n", [E, R]),
  +            {Ex, RKey} = parse_data(Data),
  +            error_logger:info_msg("Binding to exchange: ~p with RKey: ~p~n", [Ex, RKey]),
               maybe_stop_consumer(State#websocket_state.consumer),
               {ok, Channel}  = amqp_connection:open_channel(Connection),
  -            BExchange = list_to_binary(E),
  -            BRKey = list_to_binary(R),
  -            {ok, Consumer} = rabbit_websockets_consumer:start([Channel, BExchange, BRKey, self()]),
  +            {ok, Consumer} = rabbit_websockets_consumer:start([Channel, Ex, RKey, self()]),
               handle_websocket(State#websocket_state{consumer = Consumer});
           closed ->
               maybe_stop_consumer(State#websocket_state.consumer);
  
positive.code: web_root() ->
      filename:join(code:priv_dir(rabbitmq_websockets), "www").
  
  js_root() ->
      filename:join(web_root(), "js").
  
  css_root() ->
      filename:join(web_root(), "css").
  
  %-----------------------------------
  % Websockets Handling Implementation
  
negative.code: 
  parse_data(Data) ->
      case string:tokens(Data, ":") of
          [Exchange, RKey] -> {list_to_binary(Exchange), list_to_binary(RKey)};
          [Exchange] -> {list_to_binary(Exchange), <<"">>}
      end.
  
  maybe_start_consumer(undefined, Args) ->
  