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 }