KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > Jt > ejb > examples > RemoteBusinessObject


1 package Jt.ejb.examples;
2
3 import Jt.*;
4 import Jt.examples.*;
5 import Jt.jndi.*;
6 import java.io.*;
7 import Jt.ejb.*;
8 import Jt.ejb.examples.bmp.*;
9
10
11 // Example of a remote object that implements business logic.
12 // Interfaces with an Entity EJB via its Local Home
13 // interface.
14
15 public class RemoteBusinessObject extends JtObject {
16
17     JtJNDIAdapter jndiAdapter = null;
18     MemberLocalHome memberLocalHome = null;
19     boolean realized = false;
20     MemberLocal memberLocal = null;
21     String JavaDoc firstname, lastname;
22
23
24
25   public void setFirstname (String JavaDoc newFirstname) {
26     firstname = newFirstname;
27   }
28
29   public String JavaDoc getFirstname() {
30     return firstname;
31   }
32
33   public void setLastname (String JavaDoc newLastname) {
34     lastname = newLastname;
35   }
36
37   public String JavaDoc getLastname() {
38     return lastname;
39   }
40
41   /**
42     * Process object messages.
43     */
44
45   public Object JavaDoc processMessage (Object JavaDoc event) {
46
47    String JavaDoc msgid = null;
48    JtMessage e = (JtMessage) event;
49    Object JavaDoc content;
50
51      if (e == null)
52     return null;
53
54      msgid = (String JavaDoc) e.getMsgId ();
55
56      if (msgid == null)
57     return null;
58
59      content = e.getMsgContent(); // email (table key)
60
61
62
63      if (msgid.equals ("DISABLE")) {
64        if (!realized) {
65          realized = true;
66          realize ();
67        }
68             
69        return (disable ((String JavaDoc) content));
70      }
71
72
73      if (msgid.equals ("DELETE")) {
74        if (!realized) {
75          realized = true;
76          realize ();
77        }
78          
79        return (delete ((String JavaDoc) content));
80      }
81
82      if (msgid.equals ("CREATE")) {
83        if (!realized) {
84          realized = true;
85          realize ();
86        }
87          
88        return (create ((String JavaDoc) content, firstname, lastname));
89      }
90
91      if (msgid.equals ("JtFIND")) {
92        if (!realized) {
93          realized = true;
94          realize ();
95        }
96        return (find ((String JavaDoc) content));
97      }
98
99      if (msgid.equals ("MODIFY")) {
100        if (!realized) {
101          realized = true;
102          realize ();
103        }
104          
105        return (modify (e));
106      }
107
108
109      return (super.processMessage (event)); // check
110
111   }
112
113
114   void realize () {
115
116     JtFactory main = new JtFactory (); // Jt Factory
117 JtMessage msg = new JtMessage ("JtLOOKUP");
118     
119     jndiAdapter = (JtJNDIAdapter) createObject ("Jt.jndi.JtJNDIAdapter", "jndiAdapter");
120
121     msg.setMsgContent ("LocalBMPEntityExample");
122
123     memberLocalHome = (MemberLocalHome) main.sendMessage (jndiAdapter, msg);
124         
125   }
126
127   private Object JavaDoc disable (String JavaDoc email) {
128
129
130     if (find (email) == null) {
131        return (null);
132     }
133     memberLocal.setStatus (-1);
134
135     return (null);
136
137
138   }
139
140
141
142  private Object JavaDoc create (String JavaDoc email, String JavaDoc firstname, String JavaDoc lastname) {
143
144  
145     //JtValueObject member = null;
146 String JavaDoc reply = null;
147
148     if (memberLocalHome == null) {
149       handleError ("Local Home Interface is null");
150       return (null);
151     }
152
153     memberLocal = null;
154
155     try {
156
157       memberLocal = memberLocalHome.create (email, firstname, lastname);
158
159
160       if (memberLocal == null)
161         return (null);
162 /*
163       member = new DAOMember ();
164
165       member.setEmail (memberLocal.getEmail ());
166       member.setFirstname (memberLocal.getFirstname ());
167       member.setLastname (memberLocal.getLastname ());
168       member.setStatus (memberLocal.getStatus ());
169       member.setSubject (memberLocal.getSubject ());
170       member.setComments (memberLocal.getComments ());
171       member.setEmail_flag (memberLocal.getEmail_flag ());
172       member.setMdate (memberLocal.getMdate ());
173       member.setLocation (memberLocal.getLocation ());
174       member.setTstamp (memberLocal.getTstamp ());
175 */
176       reply = "OK";
177     } catch (Exception JavaDoc ex) {
178       handleException (ex);
179     }
180     return (reply);
181         
182   }
183
184
185  private Object JavaDoc delete (String JavaDoc email) {
186
187    
188     //DAOMember member = null;
189 //JtValueObject member = null;
190 String JavaDoc reply = null;
191
192
193     if (memberLocalHome == null) {
194       handleError ("Local Home Interface is null");
195       return (null);
196     }
197
198     memberLocal = null;
199
200     try {
201
202       memberLocal = memberLocalHome.findByPrimaryKey (email);
203
204       if (memberLocal != null)
205         memberLocal.remove ();
206
207       reply = "OK";
208     } catch (Exception JavaDoc ex) {
209       handleException (ex);
210     }
211     return (reply);
212         
213   }
214
215
216
217  private Object JavaDoc modify (JtMessage imsg) {
218
219    
220     //DAOMember member = null;
221 //JtValueObject member = null;
222 String JavaDoc reply = null;
223     String JavaDoc email;
224     String JavaDoc tmp;
225     JtMessage msg;
226     JtValueObject valueObject;
227
228     if (imsg == null)
229       return (null);
230
231     email = (String JavaDoc) imsg.getMsgContent ();
232     valueObject = (JtValueObject) imsg.getMsgData ();
233
234     if (email == null || valueObject == null)
235       return (null);
236
237     if (memberLocalHome == null) {
238       handleError ("Local Home Interface is null");
239       return (null);
240     }
241
242     memberLocal = null;
243
244 /*
245     msg = new JtMessage ("JtGET");
246     msg.setMsgData ("email");
247     email = (String) valueObject.processMessage (msg);
248 */
249     //email = (String) getValue (valueObject, "email");
250
251     try {
252
253       memberLocal = memberLocalHome.findByPrimaryKey (email);
254
255       if (memberLocal == null)
256         return (null);
257 /*
258       msg = new JtMessage ("JtGET");
259       msg.setMsgData ("firstname");
260
261       tmp = (String) valueObject.processMessage (msg);
262
263       if (tmp != null)
264        memberLocal.setFirstname (tmp);
265
266       msg.setMsgData ("lastname");
267       tmp = (String) valueObject.processMessage (msg);
268
269       if (tmp != null)
270        memberLocal.setLastname (tmp);
271 */
272       memberLocal.setValueObject (valueObject);
273       reply = "OK";
274     } catch (Exception JavaDoc ex) {
275       handleException (ex);
276     }
277     return (reply);
278         
279   }
280
281  private Object JavaDoc find (String JavaDoc email) {
282
283    
284     //DAOMember member = null;
285 JtValueObject member = null;
286
287
288     if (memberLocalHome == null) {
289       handleError ("find: Local Home Interface is null");
290       return (null);
291     }
292
293     memberLocal = null;
294
295     try {
296
297       memberLocal = memberLocalHome.findByPrimaryKey (email);
298
299
300       if (memberLocal == null) {
301         handleError ("find: findByPrimaryKey failed");
302         return (null);
303       }
304 /*
305       member = new DAOMember ();
306
307       member.setEmail (memberLocal.getEmail ());
308       member.setFirstname (memberLocal.getFirstname ());
309       member.setLastname (memberLocal.getLastname ());
310       member.setStatus (memberLocal.getStatus ());
311       member.setSubject (memberLocal.getSubject ());
312       member.setComments (memberLocal.getComments ());
313       member.setEmail_flag (memberLocal.getEmail_flag ());
314       member.setMdate (memberLocal.getMdate ());
315       member.setLocation (memberLocal.getLocation ());
316       member.setTstamp (memberLocal.getTstamp ());
317 */
318       member = (JtValueObject) memberLocal.getValueObject ();
319
320
321     } catch (javax.ejb.FinderException JavaDoc fe) {
322       
323       handleException (fe);
324     } catch (Exception JavaDoc ex) {
325       handleException (ex);
326     }
327     return (member);
328         
329   }
330
331
332 }
333
334
335
336
Popular Tags