src/main/java/org/yaz4j/AsyncConnections.java

   1 /*
   2  * Copyright (c) 1995-2015, Index Data
   3  * All rights reserved.
   4  * See the file LICENSE for details.
   5  */
   6 package org.yaz4j;
   7
   8 import java.util.ArrayList;
   9 import java.util.List;
  10 import org.yaz4j.jni.SWIGTYPE_p_p_ZOOM_connection_p;
  11 import static org.yaz4j.jni.yaz4jlib.*;
  12 import static java.lang.System.out;
  13
  14 /**
  15  *
  16  * @author jakub
  17  */
  18 public class AsyncConnections {
  19   private List<AsyncConnection> conns = new ArrayList<AsyncConnection>();
  20
  21   public void add(AsyncConnection conn) {
  22     conns.add(conn);
  23   }
  24
  25   public void start() {
  26     SWIGTYPE_p_p_ZOOM_connection_p c_conns = new_zoomConnectionArray(conns.size());
  27     try {
  28       for (int i=0; i<conns.size(); i++) {
  29         Connection conn = conns.get(i);
  30         zoomConnectionArray_setitem(c_conns, i, conn.zoomConnection);
  31       }
  32       int ret = 0;
  33       while ((ret = ZOOM_event(conns.size(), c_conns)) != 0) {
  34         int idx = ret - 1;
  35         int last = ZOOM_connection_last_event(zoomConnectionArray_getitem(c_conns, idx));
  36         AsyncConnection conn = conns.get(idx);
  37         String event = ZOOM_get_event_str(last);
  38         out.println("Received event " + event + " on connection #"+idx);
  39         switch (last) {
  40           case ZOOM_EVENT_RECV_SEARCH: conn.handleSearch(); break;
  41           case ZOOM_EVENT_RECV_RECORD: conn.handleRecord(); break;
  42         }
  43       }
  44     } finally {
  45       delete_zoomConnectionArray(c_conns);
  46     }
  47   }
  48
  49 }