var resultPromises = transaction.rcpt_to.map(function(item) {

                var recipients=[];
                var rcpt=item.toString().slice(1,-1);
                connection.loginfo(plugin, 'Message going to: ' + rcpt);
                var mysql = require("promise-mysql");
                var sqlcon;

                return mysql.createConnection({
                        host: "192.168.1.95",
                        user: "gfilter",
                        password: "gfilter2008",
                        database: "gfilter"
                }).then(function(conn){
                        sqlcon=conn;
                        connection.loginfo(plugin, 'Message going to: ' + rcpt + ' Size is: ' + transaction.data_bytes + ' ' + plugin);
                        return sqlcon.query('CALL gscan_getrealuser(?)',[rcpt]);
                }).then(function(rows){
                        for (var i = 0; i < rows[0].length; i++) {
                                recipients[recipients.length]=rows[0][i].email;
                        };
                        return recipients;
                }).then(function() {
                        sqlcon.end();
                }).then(function() {
                        for (var i = 0, len = recipients.length; i < len; i++) {
                                connection.loginfo(plugin,'Archiving: '+ recipients[i]);
                                archive_message(connection,transaction,recipients[i],plugin);
                        }
                });

        });