b646950ed36812497640e6a317ad8b1c8b18115c
[OpenSRF.git] / src / java / org / opensrf / Request.java
1 package org.opensrf;
2 import java.util.Queue;
3 import java.util.concurrent.ConcurrentLinkedQueue;
4 import java.util.List;
5 import org.opensrf.net.xmpp.XMPPException;
6
7 public class Request {
8     
9     private ClientSession session;
10     private Method method;
11     private int id;
12     private Queue<Result> resultQueue;
13     private boolean resetTimeout;
14     private boolean complete;
15
16     public Request(ClientSession ses, int id, Method method) {
17         this.session = ses;
18         this.id = id;
19         this.method = method;
20         resultQueue = new ConcurrentLinkedQueue<Result>();
21         complete = false;
22         resetTimeout = false;
23     }
24
25     public Request(ClientSession ses, int id, String methodName, List<Object> params) {
26         this(ses, id, new Method(methodName, params));
27     }
28
29     public void send() throws XMPPException {
30         session.send(new Message(id, Message.Type.REQUEST, method));
31     }
32 }