1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20 package org.backsource.amsterdam.service.protocol;
21 import org.backsource.amsterdam.service.ServiceMessage;
22 import org.backsource.amsterdam.service.InvokerWorker;
23 import org.backsource.amsterdam.service.Mission;
24 import org.backsource.amsterdam.service.MissionSupport;
25 import org.backsource.amsterdam.service.ServiceException;
26 import org.backsource.amsterdam.service.workerqueue.WorkerQueue;
27 /***
28 * RECProtocolHandlerSupport.java
29 *
30 *
31 * Created: Tue Mar 23 18:24:19 2004
32 *
33 * @author <a href="mailto:pra@mogul.com">Peter Antman</a>
34 * @version $Revision: 1.1.1.1 $
35 */
36
37 public class RECProtocolHandlerSupport extends ProtocolHandlerSupport implements RECProtocolHandler{
38 String name;
39 public RECProtocolHandlerSupport (){
40
41 }
42 public String getName() {
43 return name;
44 }
45
46 public void setName(String name) {
47 this.name = name;
48 }
49 public void onMessage(ServiceMessage message) throws ServiceException {
50 InvokerWorker w = getServiceInvoker().getWorker();
51 WorkerQueue q = getServiceInvoker().getWorkerQueue();
52 Mission m = new MissionSupport(Mission.REC_MISSION);
53 m.setMission(message);
54 w.setMission(m);
55 q.execute(w);
56 }
57
58 public void close() {}
59 }