home *** CD-ROM | disk | FTP | other *** search
/ PC Pro 1999 April / DPPCPRO0499.ISO / April / Notes / 50b2wic.exe / DATA1.CAB / NotesProgramFilesJavaSupport / Notes.jar / lotus / notes / internal / MessageQueue.class (.txt) < prev    next >
Encoding:
Java Class File  |  1998-11-15  |  2.6 KB  |  121 lines
  1. package lotus.notes.internal;
  2.  
  3. public class MessageQueue {
  4.    public static final int MQSCAN_NOERROR = 0;
  5.    public static final int MQSCAN_ABORT = 1;
  6.    public static final int MQSCAN_DEQUEUE = 2;
  7.    public static final int MQSCAN_DELETE = 3;
  8.    public static final int NOERROR = 0;
  9.    public static final int MQ_WAIT_FOR_MSG = 1;
  10.    public static final int MQ_OVERRIDE_QUIT = 2;
  11.    public static final int MQ_SUPPRESS_DUPLICATES = 1;
  12.    public static final int MQ_CLOSE_ONLYIFEMPTY = 1;
  13.    private int mMessageQueue;
  14.    private StringBuffer mMessageBuffer = new StringBuffer();
  15.    private boolean mbOpen = false;
  16.  
  17.    public void finalize() {
  18.       if (this.mbOpen) {
  19.          this.close(0);
  20.       }
  21.  
  22.    }
  23.  
  24.    public int create(String var1, int var2, int var3) {
  25.       int var4 = 0;
  26.       var4 = this.NCreate(var1, var2, var3);
  27.       return var4;
  28.    }
  29.  
  30.    public int open(String var1, int var2) {
  31.       int var3 = 0;
  32.       var3 = this.NOpen(var1, var2);
  33.       this.mbOpen = var3 == 0;
  34.       return var3;
  35.    }
  36.  
  37.    public int close(int var1) {
  38.       int var2 = 0;
  39.       var2 = this.NClose(this.mMessageQueue, var1);
  40.       this.mbOpen = false;
  41.       return var2;
  42.    }
  43.  
  44.    public int put(int var1, String var2, int var3, int var4, int var5) {
  45.       int var6 = 0;
  46.       var6 = this.NPut(this.mMessageQueue, var1, var2, var3, var4, var5);
  47.       return var6;
  48.    }
  49.  
  50.    public int get(StringBuffer var1, int var2, int var3, int var4) {
  51.       int var5 = 0;
  52.       var1.setLength(0);
  53.       var5 = this.NGet(this.mMessageQueue, var2, var3, var4);
  54.       if (var5 == 0) {
  55.          var1.append(this.mMessageBuffer);
  56.       }
  57.  
  58.       return var5;
  59.    }
  60.  
  61.    public int getRefCount() {
  62.       int var1 = 0;
  63.       var1 = this.NGetRefCount(this.mMessageQueue);
  64.       return var1;
  65.    }
  66.  
  67.    public int scan(StringBuffer var1, int var2, int var3, MessageQueueCBObject var4) {
  68.       int var5 = 0;
  69.       var1.setLength(0);
  70.       if (var4 != null) {
  71.          var5 = this.NScan(this.mMessageQueue, var2, var3, var4);
  72.          if (var5 == 0) {
  73.             var1.append(this.mMessageBuffer);
  74.          }
  75.       }
  76.  
  77.       return var5;
  78.    }
  79.  
  80.    public void putQuitMsg() {
  81.       this.NPutQuitMessage(this.mMessageQueue);
  82.    }
  83.  
  84.    public boolean isQuitPending() {
  85.       return this.NIsQuitPending(this.mMessageQueue);
  86.    }
  87.  
  88.    public int getCount() {
  89.       return this.NGetCount(this.mMessageQueue);
  90.    }
  91.  
  92.    private void setMessageQueue(int var1) {
  93.       this.mMessageQueue = var1;
  94.    }
  95.  
  96.    private void setMessageBuffer(String var1) {
  97.       this.mMessageBuffer.setLength(0);
  98.       this.mMessageBuffer.append(var1);
  99.    }
  100.  
  101.    private native int NCreate(String var1, int var2, int var3);
  102.  
  103.    private native int NOpen(String var1, int var2);
  104.  
  105.    private native int NClose(int var1, int var2);
  106.  
  107.    private native int NPut(int var1, int var2, String var3, int var4, int var5, int var6);
  108.  
  109.    private native int NGet(int var1, int var2, int var3, int var4);
  110.  
  111.    private native int NGetRefCount(int var1);
  112.  
  113.    private native int NPutQuitMessage(int var1);
  114.  
  115.    private native boolean NIsQuitPending(int var1);
  116.  
  117.    private native int NGetCount(int var1);
  118.  
  119.    private native int NScan(int var1, int var2, int var3, MessageQueueCBObject var4);
  120. }
  121.