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