KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > db4odoc > f1 > messaging > MessagingExample


1 /* Copyright (C) 2004 - 2006 db4objects Inc. http://www.db4o.com */
2
3 package com.db4odoc.f1.messaging;
4
5 import com.db4o.Db4o;
6 import com.db4o.ObjectContainer;
7 import com.db4o.ObjectServer;
8 import com.db4o.messaging.*;
9
10
11 public class MessagingExample {
12     public final static String JavaDoc YAPFILENAME="formula1.yap";
13     
14     public static void configureServer() {
15         ObjectServer objectServer = Db4o.openServer(YAPFILENAME, 0);
16         objectServer.ext().configure().setMessageRecipient(
17                 new MessageRecipient() {
18                     public void processMessage(ObjectContainer objectContainer,
19                             Object JavaDoc message) {
20                         // message objects will arrive in this code block
21 System.out.println(message);
22                     }
23                 });
24         try {
25             ObjectContainer clientObjectContainer = objectServer.openClient();
26             // Here is what we would do on the client to send the message
27 MessageSender sender = clientObjectContainer.ext().configure()
28                     .getMessageSender();
29
30             sender.send(new MyClientServerMessage("Hello from client."));
31             clientObjectContainer.close();
32         } finally {
33             objectServer.close();
34         }
35     }
36     // end configureServer
37
38 }
39
Popular Tags