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 {
                String brugerid;
                String postnr;
                String adresse;
                SearchResult result;
                
                public LogPersistanceWorker(String brugerid, String postnr, String adresse, SearchResult result) {
                        this.brugerid = brugerid;
                        this.postnr = postnr;
                        this.adresse = adresse;
                        this.result = result;
                }
                
                @Override 
                public void run() {
                        try {
                                DatabaseLayer.saveRequestLog(brugerid,postnr,adresse,result);
                        } catch (SQLException e) {
                                System.out.println("Error saving log entry " + e.getMessage() + ". Postnr=" + postnr + ". Adresse=" + adresse);
                        }
                }               
        }
        
        public void saveRequestLog(String brugerid, String postnr, String adresse, SearchResult result) {
                threadPool.execute( new LogPersistanceWorker(brugerid,postnr,adresse,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	2371	String brugerid;
15			String postnr;
16			String adresse;
17			SearchResult result;
18
19			public LogPersistanceWorker(String brugerid, String postnr, String adresse, SearchResult result) {
20			this.brugerid = brugerid;
21			this.postnr = postnr;
22			this.adresse = adresse;
23			this.result = result;
24			}
25
26			@Override
27			public void run() {
28			try {
29			DatabaseLayer.saveRequestLog(brugerid,postnr,adresse,result);
30			} catch (SQLException e) {
31	torben	2541	System.out.println("Error saving log entry " + e.getMessage() + ". Postnr=" + postnr + ". Adresse=" + adresse);
32	torben	2371	}
33			}
34			}
35
36			public void saveRequestLog(String brugerid, String postnr, String adresse, SearchResult result) {
37			threadPool.execute( new LogPersistanceWorker(brugerid,postnr,adresse,result) );
38			}
39	torben	2375
40
41			public void shutdown() {
42			threadPool.shutdown();
43			}
44	torben	2371	}