2 import java.util.Queue;
3 import java.util.concurrent.ConcurrentLinkedQueue;
5 import org.opensrf.net.xmpp.XMPPException;
9 private ClientSession session;
10 private Method method;
12 private Queue<Result> resultQueue;
13 private boolean resetTimeout;
14 private boolean complete;
16 public Request(ClientSession ses, int id, Method method) {
20 resultQueue = new ConcurrentLinkedQueue<Result>();
25 public Request(ClientSession ses, int id, String methodName, List<Object> params) {
26 this(ses, id, new Method(methodName, params));
29 public void send() throws XMPPException {
30 session.send(new Message(id, Message.Type.REQUEST, method));