public class Esper {


public void iniciar() {
    EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider();

    ConfigurationDBAdapter adapterConfig = new ConfigurationDBAdapter();
    ConfigurationDBRef configDB = new ConfigurationDBRef();
    configDB.setDriverManagerConnection("org.postgresql.Driver",
            "jdbc:postgresql://localhost:5432/db_name",
            "user",
            "pass");
    adapterConfig.getJdbcConnections().put("db1", configDB);

    EsperIODBAdapter dbAdapter = new EsperIODBAdapter(adapterConfig, "engineURI");
    dbAdapter.start();

    String expression = "select * from pattern[every timer :interval(10)], sql:db1 ['select mosquitoId from registros where velocidad > 50']";
    EPStatement stmt = epService.getEPAdministrator().createEPL(expression);
    Mylistener listener = new Mylistener();
    stmt.addListener(listener);
}
}