anchor.diff:  %%
   connect(#pgsql_listen_dsn{host=Host, port=Port, user=User,
                             password=Password, dbname=DBName}) ->
  -  pgsql:connect(Host, User, Password, [{database, DBName},
  -                                       {port, Port},
  -                                       {async, self()}]).
  +   epgsql:connect(Host, User, Password, [{database, DBName},
  +                                         {port, Port},
  +                                         {timeout, 2500},
  +                                         {async, self()}]).
   
   %% @spec listen(Connection, Channel) -> Result
   %% @where
  
positive.code:          listen/2,
           unlisten/2]).
  
  -include_lib("epgsql/include/pgsql.hrl").
  
  -include("pgsql_listen.hrl").
  
  %% @spec close(Conn) -> ok
  
negative.code: %% @end
  %%
  query(Connection, SQL) ->
    case epgsql:squery(Connection, SQL) of
      {ok, _} -> ok;
      {ok, _, _} -> ok;
      {ok, _, _, _} -> ok;
      {error, Error} -> {error, Error}
    end.
  