1 21 package com.db4o.test; 22 23 import com.db4o.*; 24 import com.db4o.messaging.*; 25 26 public class Messaging implements MessageRecipient{ 27 28 static final String MSG = "hibabe"; 29 30 public Object lastMessage; 31 32 public String messageString; 33 34 public void test(){ 35 36 if(Test.isClientServer()){ 37 38 Test.server().ext().configure().setMessageRecipient(this); 39 40 MessageSender sender = Test.objectContainer().configure().getMessageSender(); 41 this.messageString = MSG; 42 sender.send(this); 43 44 synchronized(this) { 45 try { 46 this.wait(5000); 47 } catch (InterruptedException e1) { 48 e1.printStackTrace(); 49 } 50 } 51 52 Test.ensure(lastMessage instanceof Messaging); 53 Messaging received = (Messaging)lastMessage; 54 Test.ensure(received.messageString.equals(MSG)); 55 } 56 } 57 58 public void processMessage(ObjectContainer con, Object message) { 59 synchronized(this) { 60 lastMessage = message; 61 this.notify(); 62 } 63 64 } 65 66 } 67 | Popular Tags |