KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > objectweb > celtix > bus > transports > TestResponseCallback


1 package org.objectweb.celtix.bus.transports;
2
3 import java.util.ArrayList JavaDoc;
4 import java.util.List JavaDoc;
5
6 import org.objectweb.celtix.bindings.ResponseCallback;
7 import org.objectweb.celtix.context.InputStreamMessageContext;
8
9 public class TestResponseCallback implements ResponseCallback {
10
11     private List JavaDoc<InputStreamMessageContext> responseContexts =
12         new ArrayList JavaDoc<InputStreamMessageContext>();
13     
14     public synchronized void dispatch(InputStreamMessageContext respCtx) {
15         responseContexts.add(respCtx);
16         notify();
17     }
18     
19     public synchronized InputStreamMessageContext waitForNextResponse() {
20         while (responseContexts.size() == 0) {
21             try {
22                 wait();
23             } catch (InterruptedException JavaDoc ie) {
24                 // ignore
25 }
26         }
27         return responseContexts.remove(0);
28     }
29
30 }
31
Popular Tags