anchor.diff:  -define(LOG(Logger, Level, Format, Args),
           Logger:Level("[ecql~p] " ++ Format, [self() | Args])).
   
  +-define(PASSWORD_AUTHENTICATOR, <<"org.apache.cassandra.auth.PasswordAuthenticator">>).
  +
   -type cql_result() :: {TableSpec :: binary(),
                          Columns   :: [tuple()],
                          Rows      :: list()}.
  
positive.code: shutdown(Reason, State) ->
      {stop, {shutdown, Reason}, State}.
  
  
negative.code:     process_flag(trap_exit, true),
      random:seed(os:timestamp()),
      Nodes = get_value(nodes, Opts, [{"127.0.0.1", 9042}]),
      Username = bin(get_value(username, Opts)),
      Password = bin(get_value(password, Opts)),
      IsSSL = get_value(ssl, Opts, false),
      SslOpts = get_value(ssl_opts, Opts, []),
      Transport = if IsSSL -> ssl; true -> tcp end,
      Logger = gen_logger:new(get_value(logger, Opts, {console, debug})),
      {ok, startup, #state{nodes     = Nodes,
                           username  = Username,
                           password  = Password,
                           callers   = [],
                           requests  = dict:new(),
                           ssl       = IsSSL,
  