MqMsgque.java

Go to the documentation of this file.

 
/* LABEL-NO */
package jvmqmsgque;
 
import jvmkkernel.*;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
 
// MARK_D ################################################################
// -----------------------------------------------------------------------
// documentation order
 
 
 
 
 
 
 
 
 
// --------------------------------------------------------------------------------
 
final public class MqMsgque {
 
  private MqMsgque() {};
 
 
  private static boolean first = false;
  static private void SetupTmpl() {
    if (first) return;
    first = true;
    //MkObjectC.M1();
    System.loadLibrary("jvmqmsgque");
 
    if (MqFactoryC.DefaultIdent().equals("libmqmsgque")) {
      MqFactoryC.Add(MqContextC.class, "jvmsgque").Default().Initial();
    }
 
 
    var cmd = System.getProperty("sun.java.command").split(" ")[0];
 
//MkObjectC.printObj(System.getProperty("sun.java.command"));
//MkObjectC.printObj(cmd.substring(cmd.length()-4));
 
    if (cmd.substring(cmd.length()-4).equals(".jar")) {
      InitSetArg0("java","-jar",cmd);
    } else {
      InitSetArg0("java",cmd);
    }
  }
 
 
  // PUBLIC
 
  // BEGIN-MqMsgque - created by 'jv_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
 
  // doc-key: MqMsgque,MqMsgque-Enum,sco
 
  public native static MqIdentE IdentE_FromInt (int value);
 
  public native static MqSlaveE SlaveE_FromInt (int value);
 
  public native static MqStartE StartE_FromInt (int value);
 
  public native static MqStatusIsEF StatusIsEF_FromInt (int value);
 
  public native static MqWaitOnEventE WaitOnEventE_FromInt (int value);
 
  // doc-key: MqMsgque,MqMsgque-Enum,sm_
 
  public native static int IdentE_ToInt (MqIdentE value);
 
  public native static String IdentE_ToString (MqIdentE value);
 
  public native static int SlaveE_ToInt (MqSlaveE value);
 
  public native static String SlaveE_ToString (MqSlaveE value);
 
  public native static int StartE_ToInt (MqStartE value);
 
  public native static String StartE_ToString (MqStartE value);
 
  public native static int StatusIsEF_ToInt (MqStatusIsEF value);
 
  public native static String StatusIsEF_ToString (MqStatusIsEF value);
 
  public native static int WaitOnEventE_ToInt (MqWaitOnEventE value);
 
  public native static String WaitOnEventE_ToString (MqWaitOnEventE value);
 
  // MqMsgque_Enum_JV_API
 
 
  // doc-key: MqMsgque,MqMsgque-Help,sm_
 
  public native static String Help (String tool);
 
  public native static String HelpMsgque ();
 
  // MqMsgque_Help_JV_API
 
 
  // doc-key: MqMsgque,MqMsgque-Init,sm_
 
  public native static MkBufferListC InitGetArg0 ();
 
  public native static MkBufferListC InitResetArg0 ();
 
  public native static void InitSetArg0 (MkBufferListC bfl);
 
  public static void InitSetArg0 (String... bfl) {
    InitSetArg0 (new MkBufferListC(bfl));
  }
 
  public static void InitSetArg0 () {
    InitSetArg0 ((MkBufferListC) null);
  }
 
  // MqMsgque_Init_JV_API
 
 
  // doc-key: MqMsgque,MqMsgque-Setup,sm_
 
  public native static void Cleanup ();
 
  public static void Setup () {
    SetupTmpl();
  }
 
  // MqMsgque_Setup_JV_API
 
  // END-MqMsgque - created by 'jv_MqS.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
 
  // [OVERLOAD THREAD]
 
  private static native void MqSysServerThreadMain(long mainS);
  private static ExecutorService threadPool = null;
 
  private static Future<Object> MqSysServerThreadPipeCB(long mainS) {
    if (threadPool == null) threadPool = Executors.newCachedThreadPool();
    var ret = threadPool.submit(
      () -> {
        try {
          MqSysServerThreadMain(mainS);
        } catch (Throwable e) {
          MkErrorC.DEFAULT().Catch(e).Println();
        }
      }
    ,null);
    return ret;
  }
 
  private static void MqSysServerThreadWorkCB(long mainS) {
    if (threadPool == null) threadPool = Executors.newCachedThreadPool();
    threadPool.execute(
      new Runnable() {
        public void run() {
          try {
            MqSysServerThreadMain(mainS);
          } catch (Throwable e) {
            MkErrorC.DEFAULT().Catch(e).Println();
          }
        }
      }
    );
  }
 
  private void WaitForThreadPipe (Future<Object> fut) {
    try {
      fut.get(200,TimeUnit.MILLISECONDS);
    } catch (Exception e) {
      // ignore
    }
  }
  // [OVERLOAD THREAD]
}