daoadresseservice/db/LogPersistance.java

package dk.daoas.daoadresseservice.db;

import java.sql.SQLException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import dk.daoas.daoadresseservice.beans.SearchResult;

public class LogPersistance  {
        
        ExecutorService threadPool = Executors.newFixedThreadPool(1);
        
        private static class LogPersistanceWorker implements Runnable {
                
                DatabaseLayer db;
                String brugerid;
                String postnr;
                String adresse;
                String omdelingsdag;
                SearchResult result;
                
                public LogPersistanceWorker(DatabaseLayer db, String brugerid, String postnr, String adresse, String omdelingsdag, SearchResult result) {
                        this.db = db;
                        this.brugerid = brugerid;
                        this.postnr = postnr;
                        this.adresse = adresse;
                        this.omdelingsdag = omdelingsdag;
                        this.result = result;
                }
                
                @Override 
                public void run() {
                        try {
                                db.saveRequestLog(brugerid, postnr, adresse, omdelingsdag, result);
                        } catch (SQLException e) {
                                System.out.println("Error saving log entry " + e.getMessage() + ". Postnr=" + postnr + ". Adresse=" + adresse);
                        }
                }               
        }
        
        public void saveRequestLog(DatabaseLayer db, String brugerid, String postnr, String adresse, String omdelingsdag, SearchResult result) {
                threadPool.execute( new LogPersistanceWorker(db, brugerid, postnr, adresse, omdelingsdag, result) );
        }


        public void shutdown() {
                threadPool.shutdown();          
        }
}

1	package dk.daoas.daoadresseservice.db;
2
3	import java.sql.SQLException;
4	import java.util.concurrent.ExecutorService;
5	import java.util.concurrent.Executors;
6
7	import dk.daoas.daoadresseservice.beans.SearchResult;
8
9	public class LogPersistance {
10
11	ExecutorService threadPool = Executors.newFixedThreadPool(1);
12
13	private static class LogPersistanceWorker implements Runnable {
14
15	DatabaseLayer db;
16	String brugerid;
17	String postnr;
18	String adresse;
19	String omdelingsdag;
20	SearchResult result;
21
22	public LogPersistanceWorker(DatabaseLayer db, String brugerid, String postnr, String adresse, String omdelingsdag, SearchResult result) {
23	this.db = db;
24	this.brugerid = brugerid;
25	this.postnr = postnr;
26	this.adresse = adresse;
27	this.omdelingsdag = omdelingsdag;
28	this.result = result;
29	}
30
31	@Override
32	public void run() {
33	try {
34	db.saveRequestLog(brugerid, postnr, adresse, omdelingsdag, result);
35	} catch (SQLException e) {
36	System.out.println("Error saving log entry " + e.getMessage() + ". Postnr=" + postnr + ". Adresse=" + adresse);
37	}
38	}
39	}
40
41	public void saveRequestLog(DatabaseLayer db, String brugerid, String postnr, String adresse, String omdelingsdag, SearchResult result) {
42	threadPool.execute( new LogPersistanceWorker(db, brugerid, postnr, adresse, omdelingsdag, result) );
43	}
44
45
46	public void shutdown() {
47	threadPool.shutdown();
48	}
49	}
50