theLink 10.0
Loading...
Searching...
No Matches
MqContextC_jv.c
Go to the documentation of this file.
1
9/* LABEL-START */
10#define META_FILE_NAME "MqContextC_jv.c"
11
12#include "jni_h/jvmqmsgque_MqContextC.h"
13#include "LibMqMsgque_private_jv.h"
14
15
16jobject NS(MqContextC_ObjNew) (MK_RT_ARGS JNIEnv *env, MQ_CTX hdl) {
17 static MkThreadLocal jobject NS_NULL = NULL;
18 return (hdl ? MK(AtomObjNew)(MK_RT_CALL env, MqContextC_X2obj(hdl)) : MK_GET__NS_NULL(MqContextC));
19}
20
22static jobject NS(MqContextC_ObjCreate) (MK_RT_ARGS JNIEnv *env, MQ_CTX hdl) {
23 return MK(AtomObjCreate)(MK_RT_CALL env, MqContextC_X2obj(hdl));
24}
25
26static MK_PTR NS(MqContextC_selfCreate) (MK_RT_ARGS MK_OBJ obj, MK_PTR envP) {
27 JNIEnv *env = (JNIEnv*) envP;
28 return (*env)->NewObject(env, NS(Class_MqContextC), NS(MID_MqContextC_INIT), (jlong) obj, JNI_TRUE);
29}
30
31#define ClassInit \
32
33// printTxt("init: MqContextC");
34
35/* LABEL-END */
36
37static MK_TYP MqContextCTT = NULL;
38
39// [OVERLOAD THREAD]
40static int sThreadExit (MK_RT_ARGS int exitnum)
41{
42#ifndef META_THREAD_POOL
43 (*MK(cached_jvm))->DetachCurrentThread(MK(cached_jvm));
44#endif // META_THREAD_POOL
45 return exitnum;
46}
47
48static int sProcessExit (MK_RT_ARGS int exitnum)
49{
50 SETUP_env;
51 (*env)->CallStaticVoidMethod(env, NS(Class_System), NS(MID_System_exit), (jint) exitnum);
52error:
53 return exitnum;
54}
55
56static bool sWaitForPipe (MK_RT_ARGS MQ_CTX const ctx, const struct MkIdS *idP ) {
57 bool retB = false;
58 switch ((*idP).type) {
59 case MK_ID_THREAD: {
60 if ((*idP).setByExtern) {
61 JNIEnv *env = GET_env_X(ctx);
62 if (env == NULL) MK(GetJniEnv)(MK_RT_CALL &env);
63 if (env) {
64 jobject futureO = (jobject) (*idP).val ;
65 if (!(*env)->IsSameObject(env,futureO, NULL)) {
66 (*env)->CallVoidMethod(env, futureO, MQ(MID_Thread_wait));
67 retB = true;
68 }
69 (*env)->DeleteWeakGlobalRef(env,futureO);
70 }
71 }
72 break;
73 }
74 case MK_ID_PROCESS:
75 case MK_ID_UNUSED: break;
76 }
77 return retB;
78}
79// [OVERLOAD THREAD]
80
81JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_INIT (JNIEnv *env, jobject self)
82{
83 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
84 if ((*env)->ExceptionOccurred(env)) goto error;
85 MkRtSetup_X(hdl);
86 MK_PTR call;
87
88 // check for Server
89 if (OT_LNG_OBJ_CLASS_IS(self, NS(Class_MqServerSetupIF)) == JNI_TRUE) {
90 JavaErrorCheckNULL(call = MK(ProcCreate)(MK_RT_CALL env, self, NULL, NS(MID_MqServerSetupIF), false));
91 MqConfigSetServerSetup (hdl, NS(ServiceCall), call, NS(ServiceFree), NS(ServiceCopy));
92 }
93 if (OT_LNG_OBJ_CLASS_IS(self, NS(Class_MqServerCleanupIF)) == JNI_TRUE) {
94 JavaErrorCheckNULL(call = MK(ProcCreate)(MK_RT_CALL env, self, NULL, NS(MID_MqServerCleanupIF), false));
95 MqConfigSetServerCleanup (hdl, NS(ServiceCall), call, NS(ServiceFree), NS(ServiceCopy));
96 }
97
98 // check for BgError
99 if (OT_LNG_OBJ_CLASS_IS(self, NS(Class_MqBgErrorIF)) == JNI_TRUE) {
100 JavaErrorCheckNULL(call = MK(ProcCreate)(MK_RT_CALL env, self, NULL, NS(MID_MqBgErrorIF), false));
101 MqConfigSetBgError (hdl, NS(ServiceCall), call, NS(ServiceFree), NS(ServiceCopy));
102 }
103
104 // check for Event
105 if (OT_LNG_OBJ_CLASS_IS(self, NS(Class_MqEventIF)) == JNI_TRUE) {
106 JavaErrorCheckNULL(call = MK(ProcCreate)(MK_RT_CALL env, self, NULL, NS(MID_MqEventIF), false));
107 MqConfigSetEvent (hdl, NS(ServiceCall), call, NS(ServiceFree), NS(ServiceCopy));
108 }
109
110error:
111 return;
112}
113
114// BEGIN-MqContextC - created by 'jv_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
115
119
120// doc-key: MqContextC,MqContextC-Class-Export,sc_
121
123JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_HandleResolve (JNIEnv *env, jclass class, jint netHdl) {
125 MQ_CTX __retVal__L = MqContextHandleResolve(netHdl);
126 jobject __retVal__S = MQ(MqContextC_ObjNew)(MK_RT_CALL env,__retVal__L);
127 return __retVal__S;
128}
129
130// doc-key: MqContextC,MqContextC-Class-Export,om_
131
132// skip class-overload: HandleGet = MqContextHandleGet → MkObjectHandleGet
133
135// MqContextC_Class_JV_API
136
140
141// doc-key: MqContextC,MqContextC-Class-Introspection,oc_
142
144JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_Next (JNIEnv *env, jobject self) {
145 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
146 JavaErrorCheck;
147 MkRtSetup_X(hdl);
148 MQ_CTX __retVal__L = MqContextNext(hdl);
149 jobject __retVal__S = MQ(MqContextC_ObjNew)(MK_RT_CALL env,__retVal__L);
150 return __retVal__S;
151error:
152 return 0;
153}
154
156JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_Prev (JNIEnv *env, jobject self) {
157 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
158 JavaErrorCheck;
159 MkRtSetup_X(hdl);
160 MQ_CTX __retVal__L = MqContextPrev(hdl);
161 jobject __retVal__S = MQ(MqContextC_ObjNew)(MK_RT_CALL env,__retVal__L);
162 return __retVal__S;
163error:
164 return 0;
165}
166
167// doc-key: MqContextC,MqContextC-Class-Introspection,sc_
168
170JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_Instances (JNIEnv *env, jclass class) {
172 MQ_CTX __retVal__L = MqContextInstances();
173 jobject __retVal__S = MQ(MqContextC_ObjNew)(MK_RT_CALL env,__retVal__L);
174 return __retVal__S;
175}
176
178// MqContextC_Class_JV_API
179
183
184// doc-key: MqContextC,MqContextC-Class-Misc,sc_
185
187JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_GetNull (JNIEnv *env, jclass class) {
189 MQ_CTX __retVal__L = MqContextGetNull();
190 jobject __retVal__S = MQ(MqContextC_ObjNew)(MK_RT_CALL env,__retVal__L);
191 return __retVal__S;
192}
193
195// MqContextC_Class_JV_API
196
200
201// doc-key: MqContextC,MqContextC-ClassApi-Class,oc_
202
204JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ClassFactoryGet (JNIEnv *env, jobject self) {
205 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
206 JavaErrorCheck;
207 MkRtSetup_X(hdl);
208 MQ_FCT __retVal__L = MqClassFactoryGet(hdl);
209 jobject __retVal__S = MQ(MqFactoryC_ObjNew)(MK_RT_CALL env,__retVal__L);
210 return __retVal__S;
211error:
212 return 0;
213}
214
215// doc-key: MqContextC,MqContextC-ClassApi-Class,om_
216
218JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ClassFactorySet (JNIEnv *env, jobject self, jobject item) {
219 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
220 JavaErrorCheck;
221 MkRtSetup_X(hdl);
222 MQ_FCT item_hdl = (MQ_FCT)pObj2Hdl(env,"MqFactoryC",item);
223 JavaErrorCheck;
224 enum MkErrorE errVal = MqClassFactorySet(hdl, item_hdl);
225 MkErrorC_Check(hdl, errVal)
226error:
227 return;
228}
229
231JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ClassIdentGet (JNIEnv *env, jobject self) {
232 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
233 JavaErrorCheck;
234 MkRtSetup_X(hdl);
235 MK_STRN __retVal__L = MqClassIdentGet(hdl);
236 jstring __retVal__S = JC2O(env,__retVal__L);
237 return __retVal__S;
238error:
239 return 0;
240}
241
243JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ClassIdentSet (JNIEnv *env, jobject self, jstring ident) {
244 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
245 JavaErrorCheck;
246 MkRtSetup_X(hdl);
247 MK_STRN ident_ptr = (ident?(*env)->GetStringUTFChars(env,ident,NULL):NULL);
248 JavaErrorCheck;
249 enum MkErrorE errVal = MqClassIdentSet(hdl, ident_ptr);
250 MkErrorC_Check(hdl, errVal)
251 if (ident_ptr) (*env)->ReleaseStringUTFChars(env,ident,ident_ptr);
252error:
253 return;
254}
255
257JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ClassOriginalIdentGet (JNIEnv *env, jobject self) {
258 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
259 JavaErrorCheck;
260 MkRtSetup_X(hdl);
261 MK_STRN __retVal__L = MqClassOriginalIdentGet(hdl);
262 jstring __retVal__S = JC2O(env,__retVal__L);
263 return __retVal__S;
264error:
265 return 0;
266}
267
269// MqContextC_ClassApi_Class_JV_API
270
274
275// doc-key: MqContextC,MqContextC-ConfigApi-Get,oco
276
278JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ConfigGetIoTcpL (JNIEnv *env, jobject self) {
279 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
280 JavaErrorCheck;
281 MkRtSetup_X(hdl);
282 MK_BFL vals_out;
283 enum MkErrorE errVal = MqConfigGetIoTcpL(hdl, &vals_out);
284 MkErrorC_Check(hdl, errVal)
285 jobject __retVal__S = MK(MkBufferListC_ObjNew)(MK_RT_CALL env,vals_out);
286 return __retVal__S;
287error:
288 return 0;
289}
290
291// doc-key: MqContextC,MqContextC-ConfigApi-Get,om_
292
294JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_ConfigGetBuffersize (JNIEnv *env, jobject self) {
295 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
296 JavaErrorCheck;
297 MkRtSetup_X(hdl);
298 MK_I32 __retVal__L = MqConfigGetBuffersize(hdl);
299 jint __retVal__S = __retVal__L;
300 return __retVal__S;
301error:
302 return 0;
303}
304
306JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ConfigGetIdentFrom (JNIEnv *env, jobject self) {
307 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
308 JavaErrorCheck;
309 MkRtSetup_X(hdl);
310 enum MqIdentE __retVal__L = MqConfigGetIdentFrom(hdl);
311 jobject __retVal__S = MK(pGetEnumFromString)(env,MQ(Class_MqIdentE),"Ljvmqmsgque/MqIdentE;",MqIdentE_ToString(__retVal__L));
312 return __retVal__S;
313error:
314 return 0;
315}
316
318JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_ConfigGetIoPipe (JNIEnv *env, jobject self) {
319 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
320 JavaErrorCheck;
321 MkRtSetup_X(hdl);
322 MQ_SOCK_HDL __retVal__L = MqConfigGetIoPipe(hdl);
323 jint __retVal__S = __retVal__L;
324 return __retVal__S;
325error:
326 return 0;
327}
328
330JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ConfigGetIoUds (JNIEnv *env, jobject self) {
331 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
332 JavaErrorCheck;
333 MkRtSetup_X(hdl);
334 MK_STRN __retVal__L = MqConfigGetIoUds(hdl);
335 jstring __retVal__S = JC2O(env,__retVal__L);
336 return __retVal__S;
337error:
338 return 0;
339}
340
342JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ConfigGetIsParent (JNIEnv *env, jobject self) {
343 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
344 JavaErrorCheck;
345 MkRtSetup_X(hdl);
346 MK_BOOL __retVal__L = MqConfigGetIsParent(hdl);
347 jboolean __retVal__S = __retVal__L;
348 return __retVal__S;
349error:
350 return 0;
351}
352
354JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ConfigGetIsServer (JNIEnv *env, jobject self) {
355 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
356 JavaErrorCheck;
357 MkRtSetup_X(hdl);
358 MK_BOOL __retVal__L = MqConfigGetIsServer(hdl);
359 jboolean __retVal__S = __retVal__L;
360 return __retVal__S;
361error:
362 return 0;
363}
364
366JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ConfigGetIsString (JNIEnv *env, jobject self) {
367 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
368 JavaErrorCheck;
369 MkRtSetup_X(hdl);
370 MK_BOOL __retVal__L = MqConfigGetIsString(hdl);
371 jboolean __retVal__S = __retVal__L;
372 return __retVal__S;
373error:
374 return 0;
375}
376
378JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ConfigGetName (JNIEnv *env, jobject self) {
379 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
380 JavaErrorCheck;
381 MkRtSetup_X(hdl);
382 MK_STRN __retVal__L = MqConfigGetName(hdl);
383 jstring __retVal__S = JC2O(env,__retVal__L);
384 return __retVal__S;
385error:
386 return 0;
387}
388
390JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_ConfigGetPkgsize (JNIEnv *env, jobject self) {
391 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
392 JavaErrorCheck;
393 MkRtSetup_X(hdl);
394 MK_I32 __retVal__L = MqConfigGetPkgsize(hdl);
395 jint __retVal__S = __retVal__L;
396 return __retVal__S;
397error:
398 return 0;
399}
400
402JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ConfigGetPostfix (JNIEnv *env, jobject self) {
403 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
404 JavaErrorCheck;
405 MkRtSetup_X(hdl);
406 MK_STRN __retVal__L = MqConfigGetPostfix(hdl);
407 jstring __retVal__S = JC2O(env,__retVal__L);
408 return __retVal__S;
409error:
410 return 0;
411}
412
414JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ConfigGetPrefix (JNIEnv *env, jobject self) {
415 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
416 JavaErrorCheck;
417 MkRtSetup_X(hdl);
418 MK_STRN __retVal__L = MqConfigGetPrefix(hdl);
419 jstring __retVal__S = JC2O(env,__retVal__L);
420 return __retVal__S;
421error:
422 return 0;
423}
424
426JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ConfigGetStartAs (JNIEnv *env, jobject self) {
427 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
428 JavaErrorCheck;
429 MkRtSetup_X(hdl);
430 enum MqStartE __retVal__L = MqConfigGetStartAs(hdl);
431 jobject __retVal__S = MK(pGetEnumFromString)(env,MQ(Class_MqStartE),"Ljvmqmsgque/MqStartE;",MqStartE_ToString(__retVal__L));
432 return __retVal__S;
433error:
434 return 0;
435}
436
438JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ConfigGetStatusIs (JNIEnv *env, jobject self) {
439 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
440 JavaErrorCheck;
441 MkRtSetup_X(hdl);
442 enum MqStatusIsEF __retVal__L = MqConfigGetStatusIs(hdl);
443 jobject __retVal__S = MK(pGetEnumFlagFromInt)(env,MQ(Class_MqStatusIsEF),__retVal__L);
444 return __retVal__S;
445error:
446 return 0;
447}
448
450JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ConfigGetStorage (JNIEnv *env, jobject self) {
451 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
452 JavaErrorCheck;
453 MkRtSetup_X(hdl);
454 MK_STRN __retVal__L = MqConfigGetStorage(hdl);
455 jstring __retVal__S = JC2O(env,__retVal__L);
456 return __retVal__S;
457error:
458 return 0;
459}
460
462JNIEXPORT jlong JNICALL Java_jvmqmsgque_MqContextC_ConfigGetTimeout (JNIEnv *env, jobject self) {
463 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
464 JavaErrorCheck;
465 MkRtSetup_X(hdl);
466 MK_TIME_T __retVal__L = MqConfigGetTimeout(hdl);
467 jlong __retVal__S = __retVal__L;
468 return __retVal__S;
469error:
470 return 0;
471}
472
474JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetConfigFile (JNIEnv *env, jobject self, jstring filename) {
475 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
476 JavaErrorCheck;
477 MkRtSetup_X(hdl);
478 MK_STRN filename_ptr = (filename?(*env)->GetStringUTFChars(env,filename,NULL):NULL);
479 JavaErrorCheck;
480 enum MkErrorE errVal = MqConfigSetConfigFile(hdl, filename_ptr);
481 MkErrorC_Check(hdl, errVal)
482 if (filename_ptr) (*env)->ReleaseStringUTFChars(env,filename,filename_ptr);
483error:
484 return;
485}
486
487// doc-key: MqContextC,MqContextC-ConfigApi-Get,omo
488
490JNIEXPORT jobjectArray JNICALL Java_jvmqmsgque_MqContextC_ConfigGetIoTcp (JNIEnv *env, jobject self) {
491 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
492 JavaErrorCheck;
493 MkRtSetup_X(hdl);
494 MK_STRN host_out;
495 MK_STRN port_out;
496 MK_STRN myhost_out;
497 MK_STRN myport_out;
498 enum MkErrorE errVal = MqConfigGetIoTcp(hdl, &host_out, &port_out, &myhost_out, &myport_out);
499 MkErrorC_Check(hdl, errVal)
500 jobjectArray __retVal__L = (jobjectArray)(*env)->NewObjectArray(env,4,MK(Class_String),NULL);
501 (*env)->SetObjectArrayElement(env,__retVal__L,0,(*env)->NewStringUTF(env,host_out));
502 (*env)->SetObjectArrayElement(env,__retVal__L,1,(*env)->NewStringUTF(env,port_out));
503 (*env)->SetObjectArrayElement(env,__retVal__L,2,(*env)->NewStringUTF(env,myhost_out));
504 (*env)->SetObjectArrayElement(env,__retVal__L,3,(*env)->NewStringUTF(env,myport_out));
505 jobjectArray __retVal__S = __retVal__L;
506 return __retVal__S;
507error:
508 return 0;
509}
510
512// MqContextC_ConfigApi_Get_JV_API
513
517
518// doc-key: MqContextC,MqContextC-ConfigApi-Misc,om_
519
521JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigReset (JNIEnv *env, jobject self) {
522 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
523 JavaErrorCheck;
524 MkRtSetup_X(hdl);
525 MqConfigReset(hdl);
526error:
527 return;
528}
529
531// MqContextC_ConfigApi_Misc_JV_API
532
536
537// doc-key: MqContextC,MqContextC-ConfigApi-Set,om_
538
540JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ConfigCheckStartAs (JNIEnv *env, jobject self, jobject data) {
541 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
542 JavaErrorCheck;
543 MkRtSetup_X(hdl);
544 enum MqStartE data_e = MK(pGetEnumFromObj)(env, NS(Class_MqStartE), data);
545 JavaErrorCheck;
546 MK_BOOL __retVal__L = MqConfigCheckStartAs(hdl, data_e);
547 jboolean __retVal__S = __retVal__L;
548 return __retVal__S;
549error:
550 return 0;
551}
552
554JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetAllDebug (JNIEnv *env, jobject self, jint data) {
555 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
556 JavaErrorCheck;
557 MkRtSetup_X(hdl);
558 enum MkErrorE errVal = MqConfigSetAllDebug(hdl, data);
559 MkErrorC_Check(hdl, errVal)
560error:
561 return;
562}
563
565JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetBuffersize (JNIEnv *env, jobject self, jint data) {
566 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
567 JavaErrorCheck;
568 MkRtSetup_X(hdl);
569 MqConfigSetBuffersize(hdl, data);
570error:
571 return;
572}
573
575JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetDaemon (JNIEnv *env, jobject self, jstring pidfile) {
576 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
577 JavaErrorCheck;
578 MkRtSetup_X(hdl);
579 MK_STRN pidfile_ptr = (pidfile?(*env)->GetStringUTFChars(env,pidfile,NULL):NULL);
580 JavaErrorCheck;
581 enum MkErrorE errVal = MqConfigSetDaemon(hdl, pidfile_ptr);
582 MkErrorC_Check(hdl, errVal)
583 if (pidfile_ptr) (*env)->ReleaseStringUTFChars(env,pidfile,pidfile_ptr);
584error:
585 return;
586}
587
589JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetIdentFrom (JNIEnv *env, jobject self, jobject data) {
590 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
591 JavaErrorCheck;
592 MkRtSetup_X(hdl);
593 enum MqIdentE data_e = MK(pGetEnumFromObj)(env, NS(Class_MqIdentE), data);
594 JavaErrorCheck;
595 MqConfigSetIdentFrom(hdl, data_e);
596error:
597 return;
598}
599
601JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetIgnoreExit (JNIEnv *env, jobject self, jboolean data) {
602 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
603 JavaErrorCheck;
604 MkRtSetup_X(hdl);
605 MqConfigSetIgnoreExit(hdl, data);
606error:
607 return;
608}
609
611JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetIoPipe (JNIEnv *env, jobject self, jint fh) {
612 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
613 JavaErrorCheck;
614 MkRtSetup_X(hdl);
615 enum MkErrorE errVal = MqConfigSetIoPipe(hdl, fh);
616 MkErrorC_Check(hdl, errVal)
617error:
618 return;
619}
620
622JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetIoTcp__Ljava_lang_String_2Ljava_lang_String_2Ljava_lang_String_2Ljava_lang_String_2 (JNIEnv *env, jobject self, jstring host, jstring port, jstring myhost, jstring myport) {
623 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
624 JavaErrorCheck;
625 MkRtSetup_X(hdl);
626 MK_STRN host_ptr = (host?(*env)->GetStringUTFChars(env,host,NULL):NULL);
627 JavaErrorCheck;
628 MK_STRN port_ptr = (port?(*env)->GetStringUTFChars(env,port,NULL):NULL);
629 JavaErrorCheck;
630 MK_STRN myhost_ptr = (myhost?(*env)->GetStringUTFChars(env,myhost,NULL):NULL);
631 JavaErrorCheck;
632 MK_STRN myport_ptr = (myport?(*env)->GetStringUTFChars(env,myport,NULL):NULL);
633 JavaErrorCheck;
634 enum MkErrorE errVal = MqConfigSetIoTcp(hdl, host_ptr, port_ptr, myhost_ptr, myport_ptr);
635 MkErrorC_Check(hdl, errVal)
636 if (host_ptr) (*env)->ReleaseStringUTFChars(env,host,host_ptr);
637 if (port_ptr) (*env)->ReleaseStringUTFChars(env,port,port_ptr);
638 if (myhost_ptr) (*env)->ReleaseStringUTFChars(env,myhost,myhost_ptr);
639 if (myport_ptr) (*env)->ReleaseStringUTFChars(env,myport,myport_ptr);
640error:
641 return;
642}
643
645JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetIoTcp__Ljvmkkernel_MkBufferListC_2 (JNIEnv *env, jobject self, jobject vals) {
646 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
647 JavaErrorCheck;
648 MkRtSetup_X(hdl);
649 MK_BFL vals_hdl = (MK_BFL)pObj2Hdl(env,"MkBufferListC",vals);
650 JavaErrorCheck;
651 enum MkErrorE errVal = MqConfigSetIoTcpL(hdl, vals_hdl);
652 MkErrorC_Check(hdl, errVal)
653error:
654 return;
655}
656
658JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetIoUds (JNIEnv *env, jobject self, jstring file) {
659 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
660 JavaErrorCheck;
661 MkRtSetup_X(hdl);
662 MK_STRN file_ptr = (file?(*env)->GetStringUTFChars(env,file,NULL):NULL);
663 JavaErrorCheck;
664 enum MkErrorE errVal = MqConfigSetIoUds(hdl, file_ptr);
665 MkErrorC_Check(hdl, errVal)
666 if (file_ptr) (*env)->ReleaseStringUTFChars(env,file,file_ptr);
667error:
668 return;
669}
670
672JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetIsServer (JNIEnv *env, jobject self, jboolean data) {
673 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
674 JavaErrorCheck;
675 MkRtSetup_X(hdl);
676 MqConfigSetIsServer(hdl, data);
677error:
678 return;
679}
680
682JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetIsString (JNIEnv *env, jobject self, jboolean data) {
683 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
684 JavaErrorCheck;
685 MkRtSetup_X(hdl);
686 MqConfigSetIsString(hdl, data);
687error:
688 return;
689}
690
692JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetName (JNIEnv *env, jobject self, jstring data) {
693 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
694 JavaErrorCheck;
695 MkRtSetup_X(hdl);
696 MK_STRN data_ptr = (data?(*env)->GetStringUTFChars(env,data,NULL):NULL);
697 JavaErrorCheck;
698 MqConfigSetName(hdl, data_ptr);
699 if (data_ptr) (*env)->ReleaseStringUTFChars(env,data,data_ptr);
700error:
701 return;
702}
703
705JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetPkgsize (JNIEnv *env, jobject self, jint data) {
706 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
707 JavaErrorCheck;
708 MkRtSetup_X(hdl);
709 MqConfigSetPkgsize(hdl, data);
710error:
711 return;
712}
713
715JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetPostfix (JNIEnv *env, jobject self, jstring data) {
716 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
717 JavaErrorCheck;
718 MkRtSetup_X(hdl);
719 MK_STRN data_ptr = (data?(*env)->GetStringUTFChars(env,data,NULL):NULL);
720 JavaErrorCheck;
721 MqConfigSetPostfix(hdl, data_ptr);
722 if (data_ptr) (*env)->ReleaseStringUTFChars(env,data,data_ptr);
723error:
724 return;
725}
726
728JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetPrefix (JNIEnv *env, jobject self, jstring data) {
729 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
730 JavaErrorCheck;
731 MkRtSetup_X(hdl);
732 MK_STRN data_ptr = (data?(*env)->GetStringUTFChars(env,data,NULL):NULL);
733 JavaErrorCheck;
734 MqConfigSetPrefix(hdl, data_ptr);
735 if (data_ptr) (*env)->ReleaseStringUTFChars(env,data,data_ptr);
736error:
737 return;
738}
739
741JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetStartAs (JNIEnv *env, jobject self, jobject data) {
742 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
743 JavaErrorCheck;
744 MkRtSetup_X(hdl);
745 enum MqStartE data_e = MK(pGetEnumFromObj)(env, NS(Class_MqStartE), data);
746 JavaErrorCheck;
747 enum MkErrorE errVal = MqConfigSetStartAs(hdl, data_e);
748 MkErrorC_Check(hdl, errVal)
749error:
750 return;
751}
752
754JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetStartAsString (JNIEnv *env, jobject self, jstring data) {
755 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
756 JavaErrorCheck;
757 MkRtSetup_X(hdl);
758 MK_STRN data_ptr = (data?(*env)->GetStringUTFChars(env,data,NULL):NULL);
759 JavaErrorCheck;
760 enum MkErrorE errVal = MqConfigSetStartAsString(hdl, data_ptr);
761 MkErrorC_Check(hdl, errVal)
762 if (data_ptr) (*env)->ReleaseStringUTFChars(env,data,data_ptr);
763error:
764 return;
765}
766
768JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetStorage (JNIEnv *env, jobject self, jstring data) {
769 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
770 JavaErrorCheck;
771 MkRtSetup_X(hdl);
772 MK_STRN data_ptr = (data?(*env)->GetStringUTFChars(env,data,NULL):NULL);
773 JavaErrorCheck;
774 MqConfigSetStorage(hdl, data_ptr);
775 if (data_ptr) (*env)->ReleaseStringUTFChars(env,data,data_ptr);
776error:
777 return;
778}
779
781JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetTimeout (JNIEnv *env, jobject self, jlong data) {
782 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
783 JavaErrorCheck;
784 MkRtSetup_X(hdl);
785 MqConfigSetTimeout(hdl, data);
786error:
787 return;
788}
789
791// MqContextC_ConfigApi_Set_JV_API
792
796
797// doc-key: MqContextC,MqContextC-EnvApi-Env,om_
798
800JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_EnvProtect (JNIEnv *env, jobject self) {
801 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
802 JavaErrorCheck;
803 MkRtSetup_X(hdl);
804 MqEnvProtect(hdl);
805error:
806 return;
807}
808
810JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_EnvRestore (JNIEnv *env, jobject self) {
811 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
812 JavaErrorCheck;
813 MkRtSetup_X(hdl);
814 MqEnvRestore(hdl);
815error:
816 return;
817}
818
820// MqContextC_EnvApi_Env_JV_API
821
825
826// doc-key: MqContextC,MqContextC-ErrorApi-Error,oc_
827
829JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ErrorFORMAT (JNIEnv *env, jobject self) {
830 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl__null_allow(env,self);
831 JavaErrorCheck;
832 MkRtSetup_X(hdl);
833 MK_ERR __retVal__L = MqContextErrorFORMAT(hdl);
834 jobject __retVal__S = MK(MkErrorC_ObjNew)(MK_RT_CALL env,__retVal__L);
835 return __retVal__S;
836error:
837 return 0;
838}
839
840// doc-key: MqContextC,MqContextC-ErrorApi-Error,om_
841
843JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ErrorCopy (JNIEnv *env, jobject self, jobject sourceCtx) {
844 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
845 JavaErrorCheck;
846 MkRtSetup_X(hdl);
847 MQ_CTXN sourceCtx_hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",sourceCtx);
848 JavaErrorCheck;
849 enum MkErrorE errVal = MqContextErrorCopy(hdl, sourceCtx_hdl);
850 jobject __retVal__S = MK(pGetEnumFromString)(env,MK(Class_MkErrorE),"Ljvmqmsgque/MkErrorE;",MkErrorE_ToString(errVal));
851 return __retVal__S;
852error:
853 return 0;
854}
855
857JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ErrorMove (JNIEnv *env, jobject self, jobject sourceCtx) {
858 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
859 JavaErrorCheck;
860 MkRtSetup_X(hdl);
861 MQ_CTXN sourceCtx_hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",sourceCtx);
862 JavaErrorCheck;
863 enum MkErrorE errVal = MqContextErrorMove(hdl, sourceCtx_hdl);
864 jobject __retVal__S = MK(pGetEnumFromString)(env,MK(Class_MkErrorE),"Ljvmqmsgque/MkErrorE;",MkErrorE_ToString(errVal));
865 return __retVal__S;
866error:
867 return 0;
868}
869
871// MqContextC_ErrorApi_Error_JV_API
872
876
877// doc-key: MqContextC,MqContextC-LinkApi-Link,oc_
878
880JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_LinkGetParent (JNIEnv *env, jobject self) {
881 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
882 JavaErrorCheck;
883 MkRtSetup_X(hdl);
884 MQ_CTX __retVal__L = MqLinkGetParent(hdl);
885 jobject __retVal__S = MQ(MqContextC_ObjNew)(MK_RT_CALL env,__retVal__L);
886 return __retVal__S;
887error:
888 return 0;
889}
890
891// doc-key: MqContextC,MqContextC-LinkApi-Link,om_
892
894JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_LinkConnect (JNIEnv *env, jobject self) {
895 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
896 JavaErrorCheck;
897 MkRtSetup_X(hdl);
898 enum MkErrorE errVal = MqLinkConnect(hdl);
899 MkErrorC_Check(hdl, errVal)
900error:
901 return;
902}
903
905JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_LinkCreate (JNIEnv *env, jobject self, jobject args) {
906 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
907 JavaErrorCheck;
908 MkRtSetup_X(hdl);
909 MK_BAC args_hdl = (MK_BAC)pObj2Hdl__null_allow(env,args);
910 JavaErrorCheck;
911 enum MkErrorE errVal = MqLinkCreate(hdl, args_hdl);
912 MkErrorC_Check(hdl, errVal)
913error:
914 return;
915}
916
918JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_LinkCreateChild (JNIEnv *env, jobject self, jobject parent, jobject args) {
919 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
920 JavaErrorCheck;
921 MkRtSetup_X(hdl);
922 MQ_CTX parent_hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",parent);
923 JavaErrorCheck;
924 MK_BAC args_hdl = (MK_BAC)pObj2Hdl__null_allow(env,args);
925 JavaErrorCheck;
926 enum MkErrorE errVal = MqLinkCreateChild(hdl, parent_hdl, args_hdl);
927 MkErrorC_Check(hdl, errVal)
928error:
929 return;
930}
931
933JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_LinkDelete (JNIEnv *env, jobject self) {
934 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
935 JavaErrorCheck;
936 MkRtSetup_X(hdl);
937 MqLinkDelete(hdl);
938error:
939 return;
940}
941
943JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_LinkGetCtxId (JNIEnv *env, jobject self) {
944 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
945 JavaErrorCheck;
946 MkRtSetup_X(hdl);
947 MK_NUM __retVal__L = MqLinkGetCtxId(hdl);
948 jint __retVal__S = __retVal__L;
949 return __retVal__S;
950error:
951 return 0;
952}
953
955JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_LinkGetTargetIdent (JNIEnv *env, jobject self) {
956 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
957 JavaErrorCheck;
958 MkRtSetup_X(hdl);
959 MK_STRN __retVal__L = MqLinkGetTargetIdent(hdl);
960 jstring __retVal__S = JC2O(env,__retVal__L);
961 return __retVal__S;
962error:
963 return 0;
964}
965
967JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_LinkIsConnected (JNIEnv *env, jobject self) {
968 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
969 JavaErrorCheck;
970 MkRtSetup_X(hdl);
971 MK_BOOL __retVal__L = MqLinkIsConnected(hdl);
972 jboolean __retVal__S = __retVal__L;
973 return __retVal__S;
974error:
975 return 0;
976}
977
979JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_LinkIsParent (JNIEnv *env, jobject self) {
980 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
981 JavaErrorCheck;
982 MkRtSetup_X(hdl);
983 MK_BOOL __retVal__L = MqLinkIsParent(hdl);
984 jboolean __retVal__S = __retVal__L;
985 return __retVal__S;
986error:
987 return 0;
988}
989
991JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_LinkShutdown (JNIEnv *env, jobject self) {
992 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
993 JavaErrorCheck;
994 MkRtSetup_X(hdl);
995 enum MkErrorE errVal = MqLinkShutdown(hdl);
996 MkErrorC_Check(hdl, errVal)
997error:
998 return;
999}
1000
1002// MqContextC_LinkApi_Link_JV_API
1003
1007
1008// doc-key: MqContextC,MqContextC-LogApi-Log,om_
1009
1010// skip class-overload: Log = MqContextLog → MkObjectLog
1011
1013JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_LogConfig (JNIEnv *env, jobject self, jobject fmtobj, jint debug, jstring callfunc, jint lvl) {
1014 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
1015 JavaErrorCheck;
1016 MkRtSetup_X(hdl);
1017 MK_OBJN fmtobj_hdl = (MK_OBJN)pObj2Hdl__null_allow(env,fmtobj);
1018 JavaErrorCheck;
1019 if (callfunc == NULL) {
1020 (*env)->CallStaticVoidMethod(env,MK(Class_MkKernel),MK(MID_MkKernel_getCallerStack));
1021 }
1022 if (callfunc == NULL) {callfunc = MK(pGetCallerProc)(env);}
1023 if (debug > (jint)(MkRuntimeDebugGet())) {return;}
1024 MK_STRN callfunc_ptr = (callfunc?(*env)->GetStringUTFChars(env,callfunc,NULL):NULL);
1025 JavaErrorCheck;
1026 MqContextLogConfig(hdl, fmtobj_hdl, debug, callfunc_ptr, lvl);
1027 if (callfunc_ptr) (*env)->ReleaseStringUTFChars(env,callfunc,callfunc_ptr);
1028error:
1029 return;
1030}
1031
1033JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_LogEnv (JNIEnv *env, jobject self, jobject fmtobj, jint debug, jstring callfunc, jint lvl) {
1034 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1035 JavaErrorCheck;
1036 MkRtSetup_X(hdl);
1037 MK_OBJN fmtobj_hdl = (MK_OBJN)pObj2Hdl__null_allow(env,fmtobj);
1038 JavaErrorCheck;
1039 if (callfunc == NULL) {
1040 (*env)->CallStaticVoidMethod(env,MK(Class_MkKernel),MK(MID_MkKernel_getCallerStack));
1041 }
1042 if (callfunc == NULL) {callfunc = MK(pGetCallerProc)(env);}
1043 if (debug > (jint)(MkRuntimeDebugGet())) {return;}
1044 MK_STRN callfunc_ptr = (callfunc?(*env)->GetStringUTFChars(env,callfunc,NULL):NULL);
1045 JavaErrorCheck;
1046 MqContextLogEnv(hdl, fmtobj_hdl, debug, callfunc_ptr, lvl);
1047 if (callfunc_ptr) (*env)->ReleaseStringUTFChars(env,callfunc,callfunc_ptr);
1048error:
1049 return;
1050}
1051
1053JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_LogLink (JNIEnv *env, jobject self, jobject fmtobj, jint debug, jstring callfunc, jint lvl) {
1054 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
1055 JavaErrorCheck;
1056 MkRtSetup_X(hdl);
1057 MK_OBJN fmtobj_hdl = (MK_OBJN)pObj2Hdl__null_allow(env,fmtobj);
1058 JavaErrorCheck;
1059 if (callfunc == NULL) {
1060 (*env)->CallStaticVoidMethod(env,MK(Class_MkKernel),MK(MID_MkKernel_getCallerStack));
1061 }
1062 if (callfunc == NULL) {callfunc = MK(pGetCallerProc)(env);}
1063 if (debug > (jint)(MkRuntimeDebugGet())) {return;}
1064 MK_STRN callfunc_ptr = (callfunc?(*env)->GetStringUTFChars(env,callfunc,NULL):NULL);
1065 JavaErrorCheck;
1066 MqContextLogLink(hdl, fmtobj_hdl, debug, callfunc_ptr, lvl);
1067 if (callfunc_ptr) (*env)->ReleaseStringUTFChars(env,callfunc,callfunc_ptr);
1068error:
1069 return;
1070}
1071
1073JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_LogSetup (JNIEnv *env, jobject self, jobject fmtobj, jint debug, jstring callfunc, jint lvl) {
1074 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
1075 JavaErrorCheck;
1076 MkRtSetup_X(hdl);
1077 MK_OBJN fmtobj_hdl = (MK_OBJN)pObj2Hdl__null_allow(env,fmtobj);
1078 JavaErrorCheck;
1079 if (callfunc == NULL) {
1080 (*env)->CallStaticVoidMethod(env,MK(Class_MkKernel),MK(MID_MkKernel_getCallerStack));
1081 }
1082 if (callfunc == NULL) {callfunc = MK(pGetCallerProc)(env);}
1083 if (debug > (jint)(MkRuntimeDebugGet())) {return;}
1084 MK_STRN callfunc_ptr = (callfunc?(*env)->GetStringUTFChars(env,callfunc,NULL):NULL);
1085 JavaErrorCheck;
1086 MqContextLogSetup(hdl, fmtobj_hdl, debug, callfunc_ptr, lvl);
1087 if (callfunc_ptr) (*env)->ReleaseStringUTFChars(env,callfunc,callfunc_ptr);
1088error:
1089 return;
1090}
1091
1093JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_LogShort (JNIEnv *env, jobject self, jobject fmtobj, jint debug, jstring callfunc, jint lvl, jstring label) {
1094 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
1095 JavaErrorCheck;
1096 MkRtSetup_X(hdl);
1097 MK_OBJN fmtobj_hdl = (MK_OBJN)pObj2Hdl__null_allow(env,fmtobj);
1098 JavaErrorCheck;
1099 if (callfunc == NULL) {
1100 (*env)->CallStaticVoidMethod(env,MK(Class_MkKernel),MK(MID_MkKernel_getCallerStack));
1101 }
1102 if (callfunc == NULL) {callfunc = MK(pGetCallerProc)(env);}
1103 if (debug > (jint)(MkRuntimeDebugGet())) {return;}
1104 MK_STRN callfunc_ptr = (callfunc?(*env)->GetStringUTFChars(env,callfunc,NULL):NULL);
1105 JavaErrorCheck;
1106 MK_STRN label_ptr = (label?(*env)->GetStringUTFChars(env,label,NULL):NULL);
1107 JavaErrorCheck;
1108 MqContextLogShort(hdl, fmtobj_hdl, debug, callfunc_ptr, lvl, label_ptr);
1109 if (callfunc_ptr) (*env)->ReleaseStringUTFChars(env,callfunc,callfunc_ptr);
1110 if (label_ptr) (*env)->ReleaseStringUTFChars(env,label,label_ptr);
1111error:
1112 return;
1113}
1114
1116JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_LogType (JNIEnv *env, jobject self, jobject fmtobj, jint debug, jstring callfunc, jint lvl) {
1117 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1118 JavaErrorCheck;
1119 MkRtSetup_X(hdl);
1120 MK_OBJN fmtobj_hdl = (MK_OBJN)pObj2Hdl__null_allow(env,fmtobj);
1121 JavaErrorCheck;
1122 if (callfunc == NULL) {
1123 (*env)->CallStaticVoidMethod(env,MK(Class_MkKernel),MK(MID_MkKernel_getCallerStack));
1124 }
1125 if (callfunc == NULL) {callfunc = MK(pGetCallerProc)(env);}
1126 if (debug > (jint)(MkRuntimeDebugGet())) {return;}
1127 MK_STRN callfunc_ptr = (callfunc?(*env)->GetStringUTFChars(env,callfunc,NULL):NULL);
1128 JavaErrorCheck;
1129 MqContextLogType(hdl, fmtobj_hdl, debug, callfunc_ptr, lvl);
1130 if (callfunc_ptr) (*env)->ReleaseStringUTFChars(env,callfunc,callfunc_ptr);
1131error:
1132 return;
1133}
1134
1136JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_LogParentOrChild (JNIEnv *env, jobject self) {
1137 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
1138 JavaErrorCheck;
1139 MkRtSetup_X(hdl);
1140 MK_STRN __retVal__L = MqLogParentOrChild(hdl);
1141 jstring __retVal__S = JC2O(env,__retVal__L);
1142 return __retVal__S;
1143error:
1144 return 0;
1145}
1146
1148JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_LogServerOrClient (JNIEnv *env, jobject self) {
1149 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
1150 JavaErrorCheck;
1151 MkRtSetup_X(hdl);
1152 MK_STRN __retVal__L = MqLogServerOrClient(hdl);
1153 jstring __retVal__S = JC2O(env,__retVal__L);
1154 return __retVal__S;
1155error:
1156 return 0;
1157}
1158
1160// MqContextC_LogApi_Log_JV_API
1161
1165
1166// doc-key: MqContextC,MqContextC-MiscApi-Misc,oc_
1167
1169JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_GetBuffer (JNIEnv *env, jobject self) {
1170 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1171 JavaErrorCheck;
1172 MkRtSetup_X(hdl);
1173 MK_BUF __retVal__L = MqContextGetBuffer(hdl);
1174 jobject __retVal__S = MK(MkBufferC_ObjNew)(MK_RT_CALL env,__retVal__L);
1175 return __retVal__S;
1176error:
1177 return 0;
1178}
1179
1181JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_GetRoot (JNIEnv *env, jobject self) {
1182 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1183 JavaErrorCheck;
1184 MkRtSetup_X(hdl);
1185 MQ_CTX __retVal__L = MqGetRoot(hdl);
1186 jobject __retVal__S = MQ(MqContextC_ObjNew)(MK_RT_CALL env,__retVal__L);
1187 return __retVal__S;
1188error:
1189 return 0;
1190}
1191
1192// doc-key: MqContextC,MqContextC-MiscApi-Misc,om_
1193
1194// skip class-overload: ToString = MqContextToString → MkObjectToString
1195
1197JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_Exit (JNIEnv *env, jobject self, jstring callfunc, jstring callfile, jint callline) {
1198 MQ_CTX hdl = (MQ_CTX)pObj2Hdl__null_allow(env,self);
1199 JavaErrorCheck;
1200 MkRtSetup_X(hdl);
1201 if (callline == -1 && callfile == NULL && callfunc == NULL) {
1202 (*env)->CallStaticVoidMethod(env,MK(Class_MkKernel),MK(MID_MkKernel_getCallerStack));
1203 }
1204 if (callline == -1) {callline = MK(pGetCallerLine)(env);}
1205 if (callfile == NULL) {callfile = MK(pGetCallerFile)(env);}
1206 if (callfunc == NULL) {callfunc = MK(pGetCallerProc)(env);}
1207 MK_STRN callfunc_ptr = (callfunc?(*env)->GetStringUTFChars(env,callfunc,NULL):NULL);
1208 JavaErrorCheck;
1209 MK_STRN callfile_ptr = (callfile?(*env)->GetStringUTFChars(env,callfile,NULL):NULL);
1210 JavaErrorCheck;
1211 MK_I32 __retVal__L = MqExit(hdl, callfunc_ptr, callfile_ptr, callline);
1212 jint __retVal__S = __retVal__L;
1213 if (callfunc_ptr) (*env)->ReleaseStringUTFChars(env,callfunc,callfunc_ptr);
1214 if (callfile_ptr) (*env)->ReleaseStringUTFChars(env,callfile,callfile_ptr);
1215 return __retVal__S;
1216error:
1217 return 0;
1218}
1219
1221JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ProcessEvent (JNIEnv *env, jobject self, jobject wait, jlong timeout) {
1222 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1223 JavaErrorCheck;
1224 MkRtSetup_X(hdl);
1225 enum MqWaitOnEventE wait_e = MK(pGetEnumFromObj)(env, NS(Class_MqWaitOnEventE), wait);
1226 JavaErrorCheck;
1227 enum MkErrorE errVal = MqProcessEvent(hdl, wait_e, timeout);
1228 MkErrorC_Check(hdl, errVal)
1229error:
1230 return;
1231}
1232
1234// MqContextC_MiscApi_Misc_JV_API
1235
1239
1240// doc-key: MqContextC,MqContextC-ProxyApi-Proxy,om_
1241
1243JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ProxyForward (JNIEnv *env, jobject self, jobject targetCtx, jobject dump, jlong timeout) {
1244 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1245 JavaErrorCheck;
1246 MkRtSetup_X(hdl);
1247 MQ_CTX targetCtx_hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",targetCtx);
1248 JavaErrorCheck;
1249 MQ_DMP dump_hdl = (MQ_DMP)pObj2Hdl__null_allow(env,dump);
1250 JavaErrorCheck;
1251 enum MkErrorE errVal = MqProxyForward(hdl, targetCtx_hdl, dump_hdl, timeout);
1252 MkErrorC_Check(hdl, errVal)
1253error:
1254 return;
1255}
1256
1258JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ProxyItem (JNIEnv *env, jobject self, jobject targetCtx) {
1259 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1260 JavaErrorCheck;
1261 MkRtSetup_X(hdl);
1262 MQ_CTX targetCtx_hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",targetCtx);
1263 JavaErrorCheck;
1264 enum MkErrorE errVal = MqProxyItem(hdl, targetCtx_hdl);
1265 MkErrorC_Check(hdl, errVal)
1266error:
1267 return;
1268}
1269
1271// MqContextC_ProxyApi_Proxy_JV_API
1272
1276
1277// doc-key: MqContextC,MqContextC-ReadApi-Atom,oci
1278
1280JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ReadALL (JNIEnv *env, jobject self, jobject val_inout) {
1281 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1282 JavaErrorCheck;
1283 MkRtSetup_X(hdl);
1284 MK_BFL val_inout_hdl = (MK_BFL)pObj2Hdl__null_allow(env,val_inout);
1285 JavaErrorCheck;
1286 enum MkErrorE errVal = MqReadALL(hdl, &val_inout_hdl);
1287 MkErrorC_Check(hdl, errVal)
1288 jobject __retVal__S = MK(MkBufferListC_ObjNew)(MK_RT_CALL env,val_inout_hdl);
1289 return __retVal__S;
1290error:
1291 return 0;
1292}
1293
1294// doc-key: MqContextC,MqContextC-ReadApi-Atom,oco
1295
1297JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ReadBFL (JNIEnv *env, jobject self) {
1298 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1299 JavaErrorCheck;
1300 MkRtSetup_X(hdl);
1301 MK_BFL val_out;
1302 enum MkErrorE errVal = MqReadBFL(hdl, &val_out);
1303 MkErrorC_Check(hdl, errVal)
1304 jobject __retVal__S = MK(MkBufferListC_ObjNew)(MK_RT_CALL env,val_out);
1305 return __retVal__S;
1306error:
1307 return 0;
1308}
1309
1311JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ReadBUF (JNIEnv *env, jobject self) {
1312 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1313 JavaErrorCheck;
1314 MkRtSetup_X(hdl);
1315 MK_BUF val_out;
1316 enum MkErrorE errVal = MqReadBUF(hdl, &val_out);
1317 MkErrorC_Check(hdl, errVal)
1318 jobject __retVal__S = MK(MkBufferC_ObjNew)(MK_RT_CALL env,val_out);
1319 return __retVal__S;
1320error:
1321 return 0;
1322}
1323
1324// doc-key: MqContextC,MqContextC-ReadApi-Atom,omo
1325
1327JNIEXPORT jbyteArray JNICALL Java_jvmqmsgque_MqContextC_ReadBIN (JNIEnv *env, jobject self) {
1328 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1329 JavaErrorCheck;
1330 MkRtSetup_X(hdl);
1331 MkBinaryR val_out_ref;
1332 enum MkErrorE errVal = MqReadBIN(hdl, &val_out_ref);
1333 MkErrorC_Check(hdl, errVal)
1334 const jsize val_out_size = (jsize) val_out_ref.size;
1335 const jbyte *val_out_byte = (jbyte*) val_out_ref.data;
1336 jbyteArray val_out = (*env)->NewByteArray(env, val_out_size);
1337 JavaErrorCheck;
1338 (*env)->SetByteArrayRegion(env,val_out,0,val_out_size,val_out_byte);
1339 JavaErrorCheck;
1340 jbyteArray __retVal__S = val_out;
1341 return __retVal__S;
1342error:
1343 return 0;
1344}
1345
1347JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ReadBOL (JNIEnv *env, jobject self) {
1348 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1349 JavaErrorCheck;
1350 MkRtSetup_X(hdl);
1351 MK_BOL val_out;
1352 enum MkErrorE errVal = MqReadBOL(hdl, &val_out);
1353 MkErrorC_Check(hdl, errVal)
1354 jboolean __retVal__S = val_out != 0;
1355 return __retVal__S;
1356error:
1357 return 0;
1358}
1359
1361JNIEXPORT jbyteArray JNICALL Java_jvmqmsgque_MqContextC_ReadBinaryR (JNIEnv *env, jobject self) {
1362 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1363 JavaErrorCheck;
1364 MkRtSetup_X(hdl);
1365 MkBinaryR val_out_ref;
1366 enum MkErrorE errVal = MqReadBinaryR(hdl, &val_out_ref);
1367 MkErrorC_Check(hdl, errVal)
1368 const jsize val_out_size = (jsize) val_out_ref.size;
1369 const jbyte *val_out_byte = (jbyte*) val_out_ref.data;
1370 jbyteArray val_out = (*env)->NewByteArray(env, val_out_size);
1371 JavaErrorCheck;
1372 (*env)->SetByteArrayRegion(env,val_out,0,val_out_size,val_out_byte);
1373 JavaErrorCheck;
1374 jbyteArray __retVal__S = val_out;
1375 return __retVal__S;
1376error:
1377 return 0;
1378}
1379
1381JNIEXPORT jdouble JNICALL Java_jvmqmsgque_MqContextC_ReadDBL (JNIEnv *env, jobject self) {
1382 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1383 JavaErrorCheck;
1384 MkRtSetup_X(hdl);
1385 MK_DBL val_out;
1386 enum MkErrorE errVal = MqReadDBL(hdl, &val_out);
1387 MkErrorC_Check(hdl, errVal)
1388 jdouble __retVal__S = val_out;
1389 return __retVal__S;
1390error:
1391 return 0;
1392}
1393
1395JNIEXPORT jfloat JNICALL Java_jvmqmsgque_MqContextC_ReadFLT (JNIEnv *env, jobject self) {
1396 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1397 JavaErrorCheck;
1398 MkRtSetup_X(hdl);
1399 MK_FLT val_out;
1400 enum MkErrorE errVal = MqReadFLT(hdl, &val_out);
1401 MkErrorC_Check(hdl, errVal)
1402 jfloat __retVal__S = val_out;
1403 return __retVal__S;
1404error:
1405 return 0;
1406}
1407
1409JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_ReadHDL (JNIEnv *env, jobject self) {
1410 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1411 JavaErrorCheck;
1412 MkRtSetup_X(hdl);
1413 MK_HDL val_out;
1414 enum MkErrorE errVal = MqReadHDL(hdl, &val_out);
1415 MkErrorC_Check(hdl, errVal)
1416 jint __retVal__S = val_out;
1417 return __retVal__S;
1418error:
1419 return 0;
1420}
1421
1423JNIEXPORT jshort JNICALL Java_jvmqmsgque_MqContextC_ReadI16 (JNIEnv *env, jobject self) {
1424 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1425 JavaErrorCheck;
1426 MkRtSetup_X(hdl);
1427 MK_I16 val_out;
1428 enum MkErrorE errVal = MqReadI16(hdl, &val_out);
1429 MkErrorC_Check(hdl, errVal)
1430 jshort __retVal__S = val_out;
1431 return __retVal__S;
1432error:
1433 return 0;
1434}
1435
1437JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_ReadI32 (JNIEnv *env, jobject self) {
1438 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1439 JavaErrorCheck;
1440 MkRtSetup_X(hdl);
1441 MK_I32 val_out;
1442 enum MkErrorE errVal = MqReadI32(hdl, &val_out);
1443 MkErrorC_Check(hdl, errVal)
1444 jint __retVal__S = val_out;
1445 return __retVal__S;
1446error:
1447 return 0;
1448}
1449
1451JNIEXPORT jlong JNICALL Java_jvmqmsgque_MqContextC_ReadI64 (JNIEnv *env, jobject self) {
1452 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1453 JavaErrorCheck;
1454 MkRtSetup_X(hdl);
1455 MK_I64 val_out;
1456 enum MkErrorE errVal = MqReadI64(hdl, &val_out);
1457 MkErrorC_Check(hdl, errVal)
1458 jlong __retVal__S = val_out;
1459 return __retVal__S;
1460error:
1461 return 0;
1462}
1463
1465JNIEXPORT jbyte JNICALL Java_jvmqmsgque_MqContextC_ReadI8 (JNIEnv *env, jobject self) {
1466 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1467 JavaErrorCheck;
1468 MkRtSetup_X(hdl);
1469 MK_I8 val_out;
1470 enum MkErrorE errVal = MqReadI8(hdl, &val_out);
1471 MkErrorC_Check(hdl, errVal)
1472 jbyte __retVal__S = (jbyte)val_out;
1473 return __retVal__S;
1474error:
1475 return 0;
1476}
1477
1479JNIEXPORT MK_NAT_LIST JNICALL ReadLIST (JNIEnv *env, jobject self); // skip template-required
1480
1482JNIEXPORT jlong JNICALL Java_jvmqmsgque_MqContextC_ReadLONG (JNIEnv *env, jobject self) {
1483 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1484 JavaErrorCheck;
1485 MkRtSetup_X(hdl);
1486 MK_LONG val_out;
1487 enum MkErrorE errVal = MqReadLONG(hdl, &val_out);
1488 MkErrorC_Check(hdl, errVal)
1489 jlong __retVal__S = val_out;
1490 return __retVal__S;
1491error:
1492 return 0;
1493}
1494
1496JNIEXPORT MK_NAT_OBJECT JNICALL ReadNEXT (JNIEnv *env, jobject self); // skip template-required
1497
1499JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ReadSTR (JNIEnv *env, jobject self) {
1500 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1501 JavaErrorCheck;
1502 MkRtSetup_X(hdl);
1503 MK_STRN val_out;
1504 enum MkErrorE errVal = MqReadSTR(hdl, &val_out);
1505 MkErrorC_Check(hdl, errVal)
1506 jstring __retVal__S = JC2O(env,val_out);
1507 return __retVal__S;
1508error:
1509 return 0;
1510}
1511
1513JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ReadStringR (JNIEnv *env, jobject self) {
1514 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1515 JavaErrorCheck;
1516 MkRtSetup_X(hdl);
1517 MkStringR val_out_ref;
1518 enum MkErrorE errVal = MqReadStringR(hdl, &val_out_ref);
1519 MkErrorC_Check(hdl, errVal)
1520 jstring val_out = (*env)->NewStringUTF(env, val_out_ref.ptr);
1521 JavaErrorCheck;
1522 jstring __retVal__S = val_out;
1523 return __retVal__S;
1524error:
1525 return 0;
1526}
1527
1529// MqContextC_ReadApi_Atom_JV_API
1530
1534
1535// doc-key: MqContextC,MqContextC-ReadApi-Block,om_
1536
1538JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ReadL_1END (JNIEnv *env, jobject self) {
1539 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1540 JavaErrorCheck;
1541 MkRtSetup_X(hdl);
1542 enum MkErrorE errVal = MqReadL_END(hdl);
1543 MkErrorC_Check(hdl, errVal)
1544error:
1545 return;
1546}
1547
1549JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ReadL_1START (JNIEnv *env, jobject self, jobject buf) {
1550 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1551 JavaErrorCheck;
1552 MkRtSetup_X(hdl);
1553 MK_BUF buf_hdl = (MK_BUF)pObj2Hdl__null_allow(env,buf);
1554 JavaErrorCheck;
1555 enum MkErrorE errVal = MqReadL_START(hdl, buf_hdl);
1556 MkErrorC_Check(hdl, errVal)
1557error:
1558 return;
1559}
1560
1562JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ReadT_1END (JNIEnv *env, jobject self) {
1563 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1564 JavaErrorCheck;
1565 MkRtSetup_X(hdl);
1566 enum MkErrorE errVal = MqReadT_END(hdl);
1567 MkErrorC_Check(hdl, errVal)
1568error:
1569 return;
1570}
1571
1573JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ReadT_1START (JNIEnv *env, jobject self) {
1574 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1575 JavaErrorCheck;
1576 MkRtSetup_X(hdl);
1577 enum MkErrorE errVal = MqReadT_START(hdl);
1578 MkErrorC_Check(hdl, errVal)
1579error:
1580 return;
1581}
1582
1584// MqContextC_ReadApi_Block_JV_API
1585
1589
1590// doc-key: MqContextC,MqContextC-ReadApi-Misc,om_
1591
1593JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ReadDbg (JNIEnv *env, jobject self) {
1594 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1595 JavaErrorCheck;
1596 MkRtSetup_X(hdl);
1597 MqReadDbg(hdl);
1598error:
1599 return;
1600}
1601
1603JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ReadGetNextType (JNIEnv *env, jobject self) {
1604 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1605 JavaErrorCheck;
1606 MkRtSetup_X(hdl);
1607 enum MkTypeE __retVal__L = MqReadGetNextType(hdl);
1608 jobject __retVal__S = MK(pGetEnumFromString)(env,MK(Class_MkTypeE),"Ljvmqmsgque/MkTypeE;",MkTypeE_ToString(__retVal__L));
1609 return __retVal__S;
1610error:
1611 return 0;
1612}
1613
1615JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_ReadGetNumItems (JNIEnv *env, jobject self) {
1616 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1617 JavaErrorCheck;
1618 MkRtSetup_X(hdl);
1619 MK_NUM __retVal__L = MqReadGetNumItems(hdl);
1620 jint __retVal__S = __retVal__L;
1621 return __retVal__S;
1622error:
1623 return 0;
1624}
1625
1627JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ReadItemExists (JNIEnv *env, jobject self) {
1628 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1629 JavaErrorCheck;
1630 MkRtSetup_X(hdl);
1631 MK_BOOL __retVal__L = MqReadItemExists(hdl);
1632 jboolean __retVal__S = __retVal__L;
1633 return __retVal__S;
1634error:
1635 return 0;
1636}
1637
1639JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ReadUndo (JNIEnv *env, jobject self) {
1640 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1641 JavaErrorCheck;
1642 MkRtSetup_X(hdl);
1643 enum MkErrorE errVal = MqReadUndo(hdl);
1644 MkErrorC_Check(hdl, errVal)
1645error:
1646 return;
1647}
1648
1650// MqContextC_ReadApi_Misc_JV_API
1651
1655
1656// doc-key: MqContextC,MqContextC-RouteApi-Route,oco
1657
1659JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_RouteGetTree (JNIEnv *env, jobject self) {
1660 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1661 JavaErrorCheck;
1662 MkRtSetup_X(hdl);
1663 MK_BFL treeP_out;
1664 enum MkErrorE errVal = MqRouteGetTree(hdl, &treeP_out);
1665 MkErrorC_Check(hdl, errVal)
1666 jobject __retVal__S = MK(MkBufferListC_ObjNew)(MK_RT_CALL env,treeP_out);
1667 return __retVal__S;
1668error:
1669 return 0;
1670}
1671
1672// doc-key: MqContextC,MqContextC-RouteApi-Route,om_
1673
1675JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_RouteCreate (JNIEnv *env, jobject self, jstring route, jstring service, jboolean overwrite) {
1676 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1677 JavaErrorCheck;
1678 MkRtSetup_X(hdl);
1679 MK_STRN route_ptr = (route?(*env)->GetStringUTFChars(env,route,NULL):NULL);
1680 JavaErrorCheck;
1681 MK_STRN service_ptr = (service?(*env)->GetStringUTFChars(env,service,NULL):NULL);
1682 JavaErrorCheck;
1683 enum MkErrorE errVal = MqRouteCreate(hdl, route_ptr, service_ptr, overwrite);
1684 MkErrorC_Check(hdl, errVal)
1685 if (route_ptr) (*env)->ReleaseStringUTFChars(env,route,route_ptr);
1686 if (service_ptr) (*env)->ReleaseStringUTFChars(env,service,service_ptr);
1687error:
1688 return;
1689}
1690
1692JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_RouteDelete (JNIEnv *env, jobject self, jstring route, jstring service, jboolean overwrite) {
1693 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1694 JavaErrorCheck;
1695 MkRtSetup_X(hdl);
1696 MK_STRN route_ptr = (route?(*env)->GetStringUTFChars(env,route,NULL):NULL);
1697 JavaErrorCheck;
1698 MK_STRN service_ptr = (service?(*env)->GetStringUTFChars(env,service,NULL):NULL);
1699 JavaErrorCheck;
1700 enum MkErrorE errVal = MqRouteDelete(hdl, route_ptr, service_ptr, overwrite);
1701 MkErrorC_Check(hdl, errVal)
1702 if (route_ptr) (*env)->ReleaseStringUTFChars(env,route,route_ptr);
1703 if (service_ptr) (*env)->ReleaseStringUTFChars(env,service,service_ptr);
1704error:
1705 return;
1706}
1707
1709JNIEXPORT jobjectArray JNICALL Java_jvmqmsgque_MqContextC_RouteResolve (JNIEnv *env, jobject self, jstring ident, jint retnum) {
1710 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1711 JavaErrorCheck;
1712 MkRtSetup_X(hdl);
1713 MK_STRN ident_ptr = (ident?(*env)->GetStringUTFChars(env,ident,NULL):NULL);
1714 JavaErrorCheck;
1715 MQ_CTX_A __retVal__L = MqRouteResolve(hdl, ident_ptr, retnum);
1716 jobjectArray ret = (*env)->NewObjectArray(env, (jsize)__retVal__L.size, MQ(Class_ME_CCC_MqContextC), NULL);
1717 for (MK_NUM num=0; num<__retVal__L.size; num++) {
1718 (*env)->SetObjectArrayElement(env, ret, num, MQ(MqContextC_ObjNew)(MK_RT_CALL env,__retVal__L.data[num]));
1719 }
1720 jobjectArray __retVal__S = ret;
1721 if (ident_ptr) (*env)->ReleaseStringUTFChars(env,ident,ident_ptr);
1722 return __retVal__S;
1723error:
1724 return 0;
1725}
1726
1728JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_RouteTraverse (JNIEnv *env, jobject self, jstring service, jobject args) {
1729 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1730 JavaErrorCheck;
1731 MkRtSetup_X(hdl);
1732 MK_BAC args_hdl = (MK_BAC)pObj2Hdl__null_allow(env,args);
1733 JavaErrorCheck;
1734 MK_STRN service_ptr = (service?(*env)->GetStringUTFChars(env,service,NULL):NULL);
1735 JavaErrorCheck;
1736 enum MkErrorE errVal = MqRouteTraverse(hdl, service_ptr, args_hdl);
1737 MkErrorC_Check(hdl, errVal)
1738 if (service_ptr) (*env)->ReleaseStringUTFChars(env,service,service_ptr);
1739error:
1740 return;
1741}
1742
1743// doc-key: MqContextC,MqContextC-RouteApi-Route,omo
1744
1746JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_RouteGetPath (JNIEnv *env, jobject self) {
1747 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1748 JavaErrorCheck;
1749 MkRtSetup_X(hdl);
1750 MK_STRN path_out;
1751 enum MkErrorE errVal = MqRouteGetPath(hdl, &path_out);
1752 MkErrorC_Check(hdl, errVal)
1753 jstring __retVal__S = JC2O(env,path_out);
1754 return __retVal__S;
1755error:
1756 return 0;
1757}
1758
1760// MqContextC_RouteApi_Route_JV_API
1761
1765
1766// doc-key: MqContextC,MqContextC-SendApi-Atom,om_
1767
1769JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendBFL (JNIEnv *env, jobject self, jobject val) {
1770 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1771 JavaErrorCheck;
1772 MkRtSetup_X(hdl);
1773 MK_BFLN val_hdl = (MK_BFLN)pObj2Hdl(env,"MkBufferListC",val);
1774 JavaErrorCheck;
1775 enum MkErrorE errVal = MqSendBFL(hdl, val_hdl);
1776 MkErrorC_Check(hdl, errVal)
1777error:
1778 return;
1779}
1780
1782JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendBIN (JNIEnv *env, jobject self, jbyteArray val) {
1783 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1784 JavaErrorCheck;
1785 MkRtSetup_X(hdl);
1786 MK_BINN val_data = (MK_BINN) (*env)->GetByteArrayElements(env, val, NULL);
1787 JavaErrorCheck;
1788 MK_SIZE val_size = (MK_SIZE) (*env)->GetArrayLength (env, val);
1789 JavaErrorCheck;
1790 MkBinaryR val_ref = MkBinaryCreate(val_size,val_data);
1791 enum MkErrorE errVal = MqSendBIN(hdl, val_ref);
1792 MkErrorC_Check(hdl, errVal)
1793 (*env)->ReleaseByteArrayElements(env, val, (jbyte*)val_data, JNI_ABORT);
1794error:
1795 return;
1796}
1797
1799JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendBOL (JNIEnv *env, jobject self, jboolean val) {
1800 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1801 JavaErrorCheck;
1802 MkRtSetup_X(hdl);
1803 enum MkErrorE errVal = MqSendBOL(hdl, (MK_BOL)(val?1:0));
1804 MkErrorC_Check(hdl, errVal)
1805error:
1806 return;
1807}
1808
1810JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendBUF (JNIEnv *env, jobject self, jobject val) {
1811 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1812 JavaErrorCheck;
1813 MkRtSetup_X(hdl);
1814 MK_BUFN val_hdl = (MK_BUFN)pObj2Hdl(env,"MkBufferC",val);
1815 JavaErrorCheck;
1816 enum MkErrorE errVal = MqSendBUF(hdl, val_hdl);
1817 MkErrorC_Check(hdl, errVal)
1818error:
1819 return;
1820}
1821
1823JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendBUS_1FLAT (JNIEnv *env, jobject self, jobject val) {
1824 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1825 JavaErrorCheck;
1826 MkRtSetup_X(hdl);
1827 MK_BUSN val_hdl = (MK_BUSN)pObj2Hdl(env,"MkBufferStreamC",val);
1828 JavaErrorCheck;
1829 enum MkErrorE errVal = MqSendBUS_FLAT(hdl, val_hdl);
1830 MkErrorC_Check(hdl, errVal)
1831error:
1832 return;
1833}
1834
1836JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendBinaryR (JNIEnv *env, jobject self, jbyteArray val) {
1837 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1838 JavaErrorCheck;
1839 MkRtSetup_X(hdl);
1840 MK_BINN val_data = (MK_BINN) (*env)->GetByteArrayElements(env, val, NULL);
1841 JavaErrorCheck;
1842 MK_SIZE val_size = (MK_SIZE) (*env)->GetArrayLength (env, val);
1843 JavaErrorCheck;
1844 MkBinaryR val_ref = MkBinaryCreate(val_size,val_data);
1845 enum MkErrorE errVal = MqSendBinaryR(hdl, val_ref);
1846 MkErrorC_Check(hdl, errVal)
1847 (*env)->ReleaseByteArrayElements(env, val, (jbyte*)val_data, JNI_ABORT);
1848error:
1849 return;
1850}
1851
1853JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendDBL (JNIEnv *env, jobject self, jdouble val) {
1854 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1855 JavaErrorCheck;
1856 MkRtSetup_X(hdl);
1857 enum MkErrorE errVal = MqSendDBL(hdl, val);
1858 MkErrorC_Check(hdl, errVal)
1859error:
1860 return;
1861}
1862
1864JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendFLT (JNIEnv *env, jobject self, jfloat val) {
1865 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1866 JavaErrorCheck;
1867 MkRtSetup_X(hdl);
1868 enum MkErrorE errVal = MqSendFLT(hdl, val);
1869 MkErrorC_Check(hdl, errVal)
1870error:
1871 return;
1872}
1873
1875JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendHDL (JNIEnv *env, jobject self, jint val) {
1876 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1877 JavaErrorCheck;
1878 MkRtSetup_X(hdl);
1879 enum MkErrorE errVal = MqSendHDL(hdl, val);
1880 MkErrorC_Check(hdl, errVal)
1881error:
1882 return;
1883}
1884
1886JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendI16 (JNIEnv *env, jobject self, jshort val) {
1887 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1888 JavaErrorCheck;
1889 MkRtSetup_X(hdl);
1890 enum MkErrorE errVal = MqSendI16(hdl, val);
1891 MkErrorC_Check(hdl, errVal)
1892error:
1893 return;
1894}
1895
1897JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendI32 (JNIEnv *env, jobject self, jint val) {
1898 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1899 JavaErrorCheck;
1900 MkRtSetup_X(hdl);
1901 enum MkErrorE errVal = MqSendI32(hdl, val);
1902 MkErrorC_Check(hdl, errVal)
1903error:
1904 return;
1905}
1906
1908JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendI64 (JNIEnv *env, jobject self, jlong val) {
1909 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1910 JavaErrorCheck;
1911 MkRtSetup_X(hdl);
1912 enum MkErrorE errVal = MqSendI64(hdl, val);
1913 MkErrorC_Check(hdl, errVal)
1914error:
1915 return;
1916}
1917
1919JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendI8 (JNIEnv *env, jobject self, jbyte val) {
1920 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1921 JavaErrorCheck;
1922 MkRtSetup_X(hdl);
1923 enum MkErrorE errVal = MqSendI8(hdl, (MK_I8)(val));
1924 MkErrorC_Check(hdl, errVal)
1925error:
1926 return;
1927}
1928
1930JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendLONG (JNIEnv *env, jobject self, jlong val) {
1931 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1932 JavaErrorCheck;
1933 MkRtSetup_X(hdl);
1934 enum MkErrorE errVal = MqSendLONG(hdl, val);
1935 MkErrorC_Check(hdl, errVal)
1936error:
1937 return;
1938}
1939
1941JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendLTR (JNIEnv *env, jobject self, jint transLId) {
1942 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1943 JavaErrorCheck;
1944 MkRtSetup_X(hdl);
1945 enum MkErrorE errVal = MqSendLTR(hdl, transLId);
1946 MkErrorC_Check(hdl, errVal)
1947error:
1948 return;
1949}
1950
1952JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendL_1FLAT (JNIEnv *env, jobject self, jobject val) {
1953 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1954 JavaErrorCheck;
1955 MkRtSetup_X(hdl);
1956 MK_BFLN val_hdl = (MK_BFLN)pObj2Hdl(env,"MkBufferListC",val);
1957 JavaErrorCheck;
1958 enum MkErrorE errVal = MqSendL_FLAT(hdl, val_hdl);
1959 MkErrorC_Check(hdl, errVal)
1960error:
1961 return;
1962}
1963
1965JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendSTR (JNIEnv *env, jobject self, jstring val) {
1966 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1967 JavaErrorCheck;
1968 MkRtSetup_X(hdl);
1969 MK_STRN val_ptr = (val?(*env)->GetStringUTFChars(env,val,NULL):NULL);
1970 JavaErrorCheck;
1971 enum MkErrorE errVal = MqSendSTR(hdl, val_ptr);
1972 MkErrorC_Check(hdl, errVal)
1973 if (val_ptr) (*env)->ReleaseStringUTFChars(env,val,val_ptr);
1974error:
1975 return;
1976}
1977
1979JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendStringR (JNIEnv *env, jobject self, jstring val) {
1980 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
1981 JavaErrorCheck;
1982 MkRtSetup_X(hdl);
1983 MkStringR val_ref = MkStringCreate((*env)->GetStringUTFLength(env,val),(val?(*env)->GetStringUTFChars(env,val,NULL):NULL));
1984 JavaErrorCheck;
1985 enum MkErrorE errVal = MqSendStringR(hdl, val_ref);
1986 MkErrorC_Check(hdl, errVal)
1987 if (val_ref.ptr) (*env)->ReleaseStringUTFChars(env,val,val_ref.ptr);
1988error:
1989 return;
1990}
1991
1993// MqContextC_SendApi_Atom_JV_API
1994
1998
1999// doc-key: MqContextC,MqContextC-SendApi-Basics,om_
2000
2002JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendEND (JNIEnv *env, jobject self, jstring token, jlong timeout) {
2003 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2004 JavaErrorCheck;
2005 MkRtSetup_X(hdl);
2006 MQ_TOK token_ptr = (token?(*env)->GetStringUTFChars(env,token,NULL):NULL);
2007 JavaErrorCheck;
2008 enum MkErrorE errVal = MqSendEND(hdl, token_ptr, timeout);
2009 MkErrorC_Check(hdl, errVal)
2010 if (token_ptr) (*env)->ReleaseStringUTFChars(env,token,token_ptr);
2011error:
2012 return;
2013}
2014
2016JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendEND_1AND_1CALLBACK (JNIEnv *env, jobject self, jstring token, jobject callback, jlong timeout) {
2017 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2018 JavaErrorCheck;
2019 MkRtSetup_X(hdl);
2020 MQ_TOK token_ptr = (token?(*env)->GetStringUTFChars(env,token,NULL):NULL);
2021 JavaErrorCheck;
2022 MK_CBP callback_ptr = MK(ProcCreate)(MK_RT_CALL env, callback, NULL, NS(MID_callback), true);
2023 JavaErrorCheck;
2024 enum MkErrorE errVal = MqSendEND_AND_CALLBACK(hdl, token_ptr, NS(ServiceCall), callback_ptr, NS(ServiceFree), timeout);
2025 MkErrorC_Check(hdl, errVal)
2026 if (token_ptr) (*env)->ReleaseStringUTFChars(env,token,token_ptr);
2027error:
2028 return;
2029}
2030
2032JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendEND_1AND_1SUB (JNIEnv *env, jobject self, jstring token, jobject callback, jlong timeout) {
2033 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2034 JavaErrorCheck;
2035 MkRtSetup_X(hdl);
2036 MQ_TOK token_ptr = (token?(*env)->GetStringUTFChars(env,token,NULL):NULL);
2037 JavaErrorCheck;
2038 MK_CBP callback_ptr = MK(ProcCreate)(MK_RT_CALL env, callback, NULL, NS(MID_callback), true);
2039 JavaErrorCheck;
2040 enum MkErrorE errVal = MqSendEND_AND_SUB(hdl, token_ptr, NS(ServiceCall), callback_ptr, NS(ServiceFree), timeout);
2041 MkErrorC_Check(hdl, errVal)
2042 if (token_ptr) (*env)->ReleaseStringUTFChars(env,token,token_ptr);
2043error:
2044 return;
2045}
2046
2048JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendEND_1AND_1TRANSACTION (JNIEnv *env, jobject self, jstring token, jstring callback, jlong timeout) {
2049 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2050 JavaErrorCheck;
2051 MkRtSetup_X(hdl);
2052 MQ_TOK token_ptr = (token?(*env)->GetStringUTFChars(env,token,NULL):NULL);
2053 JavaErrorCheck;
2054 MQ_TOK callback_ptr = (callback?(*env)->GetStringUTFChars(env,callback,NULL):NULL);
2055 JavaErrorCheck;
2056 enum MkErrorE errVal = MqSendEND_AND_TRANSACTION(hdl, token_ptr, callback_ptr, timeout);
2057 MkErrorC_Check(hdl, errVal)
2058 if (token_ptr) (*env)->ReleaseStringUTFChars(env,token,token_ptr);
2059 if (callback_ptr) (*env)->ReleaseStringUTFChars(env,callback,callback_ptr);
2060error:
2061 return;
2062}
2063
2065JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendEND_1AND_1WAIT (JNIEnv *env, jobject self, jstring token, jlong timeout) {
2066 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2067 JavaErrorCheck;
2068 MkRtSetup_X(hdl);
2069 MQ_TOK token_ptr = (token?(*env)->GetStringUTFChars(env,token,NULL):NULL);
2070 JavaErrorCheck;
2071 enum MkErrorE errVal = MqSendEND_AND_WAIT(hdl, token_ptr, timeout);
2072 MkErrorC_Check(hdl, errVal)
2073 if (token_ptr) (*env)->ReleaseStringUTFChars(env,token,token_ptr);
2074error:
2075 return;
2076}
2077
2079JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendSTART (JNIEnv *env, jobject self) {
2080 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2081 JavaErrorCheck;
2082 MkRtSetup_X(hdl);
2083 enum MkErrorE errVal = MqSendSTART(hdl);
2084 MkErrorC_Check(hdl, errVal)
2085error:
2086 return;
2087}
2088
2090JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendSYNC (JNIEnv *env, jobject self) {
2091 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2092 JavaErrorCheck;
2093 MkRtSetup_X(hdl);
2094 enum MkErrorE errVal = MqSendSYNC(hdl);
2095 MkErrorC_Check(hdl, errVal)
2096error:
2097 return;
2098}
2099
2101// MqContextC_SendApi_Basics_JV_API
2102
2106
2107// doc-key: MqContextC,MqContextC-SendApi-Block,om_
2108
2110JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendL_1END (JNIEnv *env, jobject self) {
2111 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2112 JavaErrorCheck;
2113 MkRtSetup_X(hdl);
2114 enum MkErrorE errVal = MqSendL_END(hdl);
2115 MkErrorC_Check(hdl, errVal)
2116error:
2117 return;
2118}
2119
2121JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendL_1START (JNIEnv *env, jobject self) {
2122 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2123 JavaErrorCheck;
2124 MkRtSetup_X(hdl);
2125 enum MkErrorE errVal = MqSendL_START(hdl);
2126 MkErrorC_Check(hdl, errVal)
2127error:
2128 return;
2129}
2130
2132JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendT_1END (JNIEnv *env, jobject self) {
2133 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2134 JavaErrorCheck;
2135 MkRtSetup_X(hdl);
2136 enum MkErrorE errVal = MqSendT_END(hdl);
2137 MkErrorC_Check(hdl, errVal)
2138error:
2139 return;
2140}
2141
2143JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendT_1START (JNIEnv *env, jobject self) {
2144 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2145 JavaErrorCheck;
2146 MkRtSetup_X(hdl);
2147 enum MkErrorE errVal = MqSendT_START(hdl);
2148 MkErrorC_Check(hdl, errVal)
2149error:
2150 return;
2151}
2152
2154// MqContextC_SendApi_Block_JV_API
2155
2159
2160// doc-key: MqContextC,MqContextC-SendApi-Return,om_
2161
2163JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendERROR (JNIEnv *env, jobject self) {
2164 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2165 JavaErrorCheck;
2166 MkRtSetup_X(hdl);
2167 enum MkErrorE errVal = MqSendERROR(hdl);
2168 MkErrorC_Check(hdl, errVal)
2169error:
2170 return;
2171}
2172
2174JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendRETURN (JNIEnv *env, jobject self) {
2175 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2176 JavaErrorCheck;
2177 MkRtSetup_X(hdl);
2178 enum MkErrorE errVal = MqSendRETURN(hdl);
2179 MkErrorC_Check(hdl, errVal)
2180error:
2181 return;
2182}
2183
2185JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendRETURN_1SUB (JNIEnv *env, jobject self) {
2186 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2187 JavaErrorCheck;
2188 MkRtSetup_X(hdl);
2189 enum MkErrorE errVal = MqSendRETURN_SUB(hdl);
2190 MkErrorC_Check(hdl, errVal)
2191error:
2192 return;
2193}
2194
2196// MqContextC_SendApi_Return_JV_API
2197
2201
2202// doc-key: MqContextC,MqContextC-ServiceApi-Service,om_
2203
2205JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ServiceCreate (JNIEnv *env, jobject self, jstring token, jobject callback) {
2206 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2207 JavaErrorCheck;
2208 MkRtSetup_X(hdl);
2209 MQ_TOK token_ptr = (token?(*env)->GetStringUTFChars(env,token,NULL):NULL);
2210 JavaErrorCheck;
2211 MK_CBP callback_ptr = MK(ProcCreate)(MK_RT_CALL env, callback, NULL, NS(MID_callback), true);
2212 JavaErrorCheck;
2213 enum MkErrorE errVal = MqServiceCreate(hdl, token_ptr, NS(ServiceCall), callback_ptr, NS(ServiceFree), NULL);
2214 MkErrorC_Check(hdl, errVal)
2215 if (token_ptr) (*env)->ReleaseStringUTFChars(env,token,token_ptr);
2216error:
2217 return;
2218}
2219
2221JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ServiceDelete (JNIEnv *env, jobject self, jstring token) {
2222 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2223 JavaErrorCheck;
2224 MkRtSetup_X(hdl);
2225 MQ_TOK token_ptr = (token?(*env)->GetStringUTFChars(env,token,NULL):NULL);
2226 JavaErrorCheck;
2227 enum MkErrorE errVal = MqServiceDelete(hdl, token_ptr);
2228 MkErrorC_Check(hdl, errVal)
2229 if (token_ptr) (*env)->ReleaseStringUTFChars(env,token,token_ptr);
2230error:
2231 return;
2232}
2233
2235JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ServiceIsTransaction (JNIEnv *env, jobject self) {
2236 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2237 JavaErrorCheck;
2238 MkRtSetup_X(hdl);
2239 MK_BOOL __retVal__L = MqServiceIsTransaction(hdl);
2240 jboolean __retVal__S = __retVal__L;
2241 return __retVal__S;
2242error:
2243 return 0;
2244}
2245
2247JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ServiceProxy (JNIEnv *env, jobject self, jstring token, jint id) {
2248 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2249 JavaErrorCheck;
2250 MkRtSetup_X(hdl);
2251 MQ_TOK token_ptr = (token?(*env)->GetStringUTFChars(env,token,NULL):NULL);
2252 JavaErrorCheck;
2253 enum MkErrorE errVal = MqServiceProxy(hdl, token_ptr, id);
2254 MkErrorC_Check(hdl, errVal)
2255 if (token_ptr) (*env)->ReleaseStringUTFChars(env,token,token_ptr);
2256error:
2257 return;
2258}
2259
2261JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ServiceProxyCtx (JNIEnv *env, jobject self, jstring token, jobject target) {
2262 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2263 JavaErrorCheck;
2264 MkRtSetup_X(hdl);
2265 MQ_CTX target_hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",target);
2266 JavaErrorCheck;
2267 MQ_TOK token_ptr = (token?(*env)->GetStringUTFChars(env,token,NULL):NULL);
2268 JavaErrorCheck;
2269 enum MkErrorE errVal = MqServiceProxyCtx(hdl, token_ptr, target_hdl);
2270 MkErrorC_Check(hdl, errVal)
2271 if (token_ptr) (*env)->ReleaseStringUTFChars(env,token,token_ptr);
2272error:
2273 return;
2274}
2275
2277JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ServiceProxyCtxExists (JNIEnv *env, jobject self, jstring token, jobject target) {
2278 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2279 JavaErrorCheck;
2280 MkRtSetup_X(hdl);
2281 MQ_CTX target_hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",target);
2282 JavaErrorCheck;
2283 MQ_TOK token_ptr = (token?(*env)->GetStringUTFChars(env,token,NULL):NULL);
2284 JavaErrorCheck;
2285 MK_BOOL __retVal__L = MqServiceProxyCtxExists(hdl, token_ptr, target_hdl);
2286 jboolean __retVal__S = __retVal__L;
2287 if (token_ptr) (*env)->ReleaseStringUTFChars(env,token,token_ptr);
2288 return __retVal__S;
2289error:
2290 return 0;
2291}
2292
2294JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ServiceProxyRoundRobin (JNIEnv *env, jobject self, jstring token, jstring ident) {
2295 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2296 JavaErrorCheck;
2297 MkRtSetup_X(hdl);
2298 MQ_TOK token_ptr = (token?(*env)->GetStringUTFChars(env,token,NULL):NULL);
2299 JavaErrorCheck;
2300 MK_STRN ident_ptr = (ident?(*env)->GetStringUTFChars(env,ident,NULL):NULL);
2301 JavaErrorCheck;
2302 enum MkErrorE errVal = MqServiceProxyRoundRobin(hdl, token_ptr, ident_ptr);
2303 MkErrorC_Check(hdl, errVal)
2304 if (token_ptr) (*env)->ReleaseStringUTFChars(env,token,token_ptr);
2305 if (ident_ptr) (*env)->ReleaseStringUTFChars(env,ident,ident_ptr);
2306error:
2307 return;
2308}
2309
2311JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ServiceStorage (JNIEnv *env, jobject self, jstring token) {
2312 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2313 JavaErrorCheck;
2314 MkRtSetup_X(hdl);
2315 MQ_TOK token_ptr = (token?(*env)->GetStringUTFChars(env,token,NULL):NULL);
2316 JavaErrorCheck;
2317 enum MkErrorE errVal = MqServiceStorage(hdl, token_ptr);
2318 MkErrorC_Check(hdl, errVal)
2319 if (token_ptr) (*env)->ReleaseStringUTFChars(env,token,token_ptr);
2320error:
2321 return;
2322}
2323
2325JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ServiceTokenCheck (JNIEnv *env, jobject self, jstring token) {
2326 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2327 JavaErrorCheck;
2328 MkRtSetup_X(hdl);
2329 MQ_TOK token_ptr = (token?(*env)->GetStringUTFChars(env,token,NULL):NULL);
2330 JavaErrorCheck;
2331 MK_BOOL __retVal__L = MqServiceTokenCheck(hdl, token_ptr);
2332 jboolean __retVal__S = __retVal__L;
2333 if (token_ptr) (*env)->ReleaseStringUTFChars(env,token,token_ptr);
2334 return __retVal__S;
2335error:
2336 return 0;
2337}
2338
2340JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ServiceTokenExists (JNIEnv *env, jobject self, jstring token) {
2341 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2342 JavaErrorCheck;
2343 MkRtSetup_X(hdl);
2344 MQ_TOK token_ptr = (token?(*env)->GetStringUTFChars(env,token,NULL):NULL);
2345 JavaErrorCheck;
2346 MK_BOOL __retVal__L = MqServiceTokenExists(hdl, token_ptr);
2347 jboolean __retVal__S = __retVal__L;
2348 if (token_ptr) (*env)->ReleaseStringUTFChars(env,token,token_ptr);
2349 return __retVal__S;
2350error:
2351 return 0;
2352}
2353
2355JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ServiceTokenGet (JNIEnv *env, jobject self) {
2356 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2357 JavaErrorCheck;
2358 MkRtSetup_X(hdl);
2359 MQ_TOK __retVal__L = MqServiceTokenGet(hdl);
2360 jstring __retVal__S = JC2O(env,__retVal__L);
2361 return __retVal__S;
2362error:
2363 return 0;
2364}
2365
2367// MqContextC_ServiceApi_Service_JV_API
2368
2372
2373// doc-key: MqContextC,MqContextC-SlaveApi-Slave,oc_
2374
2376JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_SlaveGetMaster (JNIEnv *env, jobject self) {
2377 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2378 JavaErrorCheck;
2379 MkRtSetup_X(hdl);
2380 MQ_CTX __retVal__L = MqSlaveGetMaster(hdl);
2381 jobject __retVal__S = MQ(MqContextC_ObjNew)(MK_RT_CALL env,__retVal__L);
2382 return __retVal__S;
2383error:
2384 return 0;
2385}
2386
2387// doc-key: MqContextC,MqContextC-SlaveApi-Slave,oco
2388
2390JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_SlaveGet (JNIEnv *env, jobject self, jint id) {
2391 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2392 JavaErrorCheck;
2393 MkRtSetup_X(hdl);
2394 MQ_CTX ctx_out;
2395 enum MkErrorE errVal = MqSlaveGet(hdl, id, &ctx_out);
2396 MkErrorC_Check(hdl, errVal)
2397 jobject __retVal__S = MQ(MqContextC_ObjNew)(MK_RT_CALL env,ctx_out);
2398 return __retVal__S;
2399error:
2400 return 0;
2401}
2402
2404JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_SlaveGetFilter (JNIEnv *env, jobject self) {
2405 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2406 JavaErrorCheck;
2407 MkRtSetup_X(hdl);
2408 MQ_CTX ctx_out;
2409 enum MkErrorE errVal = MqSlaveGetFilter(hdl, &ctx_out);
2410 MkErrorC_Check(hdl, errVal)
2411 jobject __retVal__S = MQ(MqContextC_ObjNew)(MK_RT_CALL env,ctx_out);
2412 return __retVal__S;
2413error:
2414 return 0;
2415}
2416
2418JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_SlaveGetProxy (JNIEnv *env, jobject self, jint id) {
2419 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2420 JavaErrorCheck;
2421 MkRtSetup_X(hdl);
2422 MQ_CTX ctx_out;
2423 enum MkErrorE errVal = MqSlaveGetProxy(hdl, id, &ctx_out);
2424 MkErrorC_Check(hdl, errVal)
2425 jobject __retVal__S = MQ(MqContextC_ObjNew)(MK_RT_CALL env,ctx_out);
2426 return __retVal__S;
2427error:
2428 return 0;
2429}
2430
2431// doc-key: MqContextC,MqContextC-SlaveApi-Slave,om_
2432
2434JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_SlaveCheck (JNIEnv *env, jobject self, jint id) {
2435 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
2436 JavaErrorCheck;
2437 MkRtSetup_X(hdl);
2438 MK_BOOL __retVal__L = MqSlaveCheck(hdl, id);
2439 jboolean __retVal__S = __retVal__L;
2440 return __retVal__S;
2441error:
2442 return 0;
2443}
2444
2446JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SlaveCreate (JNIEnv *env, jobject self, jint id, jobject slave) {
2447 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2448 JavaErrorCheck;
2449 MkRtSetup_X(hdl);
2450 MQ_CTX slave_hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",slave);
2451 JavaErrorCheck;
2452 enum MkErrorE errVal = MqSlaveCreate(hdl, id, slave_hdl);
2453 MkErrorC_Check(hdl, errVal)
2454error:
2455 return;
2456}
2457
2459JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SlaveDelete (JNIEnv *env, jobject self, jint id) {
2460 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2461 JavaErrorCheck;
2462 MkRtSetup_X(hdl);
2463 enum MkErrorE errVal = MqSlaveDelete(hdl, id);
2464 MkErrorC_Check(hdl, errVal)
2465error:
2466 return;
2467}
2468
2470JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_SlaveIs (JNIEnv *env, jobject self) {
2471 MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
2472 JavaErrorCheck;
2473 MkRtSetup_X(hdl);
2474 MK_BOOL __retVal__L = MqSlaveIs(hdl);
2475 jboolean __retVal__S = __retVal__L;
2476 return __retVal__S;
2477error:
2478 return 0;
2479}
2480
2482JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SlaveWorker (JNIEnv *env, jobject self, jint id, jstring fct, jobject args) {
2483 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2484 JavaErrorCheck;
2485 MkRtSetup_X(hdl);
2486 MK_BAC args_hdl = (MK_BAC)pObj2Hdl__null_allow(env,args);
2487 JavaErrorCheck;
2488 MK_STRN fct_ptr = (fct?(*env)->GetStringUTFChars(env,fct,NULL):NULL);
2489 JavaErrorCheck;
2490 enum MkErrorE errVal = MqSlaveWorker(hdl, id, fct_ptr, args_hdl);
2491 MkErrorC_Check(hdl, errVal)
2492 if (fct_ptr) (*env)->ReleaseStringUTFChars(env,fct,fct_ptr);
2493error:
2494 return;
2495}
2496
2498// MqContextC_SlaveApi_Slave_JV_API
2499
2503
2504// doc-key: MqContextC,MqContextC-StorageApi-Storage,oci
2505
2507JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_StorageDelete (JNIEnv *env, jobject self, jint transLIdP_inout) {
2508 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2509 JavaErrorCheck;
2510 MkRtSetup_X(hdl);
2511 enum MkErrorE errVal = MqStorageDelete(hdl, &transLIdP_inout);
2512 MkErrorC_Check(hdl, errVal)
2513 jint __retVal__S = transLIdP_inout;
2514 return __retVal__S;
2515error:
2516 return 0;
2517}
2518
2520JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_StorageImport (JNIEnv *env, jobject self, jint transLIdP_inout) {
2521 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2522 JavaErrorCheck;
2523 MkRtSetup_X(hdl);
2524 enum MkErrorE errVal = MqStorageImport(hdl, &transLIdP_inout);
2525 MkErrorC_Check(hdl, errVal)
2526 jint __retVal__S = transLIdP_inout;
2527 return __retVal__S;
2528error:
2529 return 0;
2530}
2531
2532// doc-key: MqContextC,MqContextC-StorageApi-Storage,om_
2533
2535JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_StorageClose (JNIEnv *env, jobject self) {
2536 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2537 JavaErrorCheck;
2538 MkRtSetup_X(hdl);
2539 enum MkErrorE errVal = MqStorageClose(hdl);
2540 MkErrorC_Check(hdl, errVal)
2541error:
2542 return;
2543}
2544
2546JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_StorageDecrRef (JNIEnv *env, jobject self, jint transLId) {
2547 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2548 JavaErrorCheck;
2549 MkRtSetup_X(hdl);
2550 enum MkErrorE errVal = MqStorageDecrRef(hdl, transLId);
2551 MkErrorC_Check(hdl, errVal)
2552error:
2553 return;
2554}
2555
2557JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_StorageIncrRef (JNIEnv *env, jobject self, jint transLId) {
2558 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2559 JavaErrorCheck;
2560 MkRtSetup_X(hdl);
2561 enum MkErrorE errVal = MqStorageIncrRef(hdl, transLId);
2562 MkErrorC_Check(hdl, errVal)
2563error:
2564 return;
2565}
2566
2568JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_StorageLog (JNIEnv *env, jobject self, jstring callfunc) {
2569 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2570 JavaErrorCheck;
2571 MkRtSetup_X(hdl);
2572 if (callfunc == NULL) {
2573 (*env)->CallStaticVoidMethod(env,MK(Class_MkKernel),MK(MID_MkKernel_getCallerStack));
2574 }
2575 if (callfunc == NULL) {callfunc = MK(pGetCallerProc)(env);}
2576 MK_STRN callfunc_ptr = (callfunc?(*env)->GetStringUTFChars(env,callfunc,NULL):NULL);
2577 JavaErrorCheck;
2578 enum MkErrorE errVal = MqStorageLog(hdl, callfunc_ptr);
2579 MkErrorC_Check(hdl, errVal)
2580 if (callfunc_ptr) (*env)->ReleaseStringUTFChars(env,callfunc,callfunc_ptr);
2581error:
2582 return;
2583}
2584
2586JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_StorageOpen (JNIEnv *env, jobject self, jstring storageFile) {
2587 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2588 JavaErrorCheck;
2589 MkRtSetup_X(hdl);
2590 MK_STRN storageFile_ptr = (storageFile?(*env)->GetStringUTFChars(env,storageFile,NULL):NULL);
2591 JavaErrorCheck;
2592 enum MkErrorE errVal = MqStorageOpen(hdl, storageFile_ptr);
2593 MkErrorC_Check(hdl, errVal)
2594 if (storageFile_ptr) (*env)->ReleaseStringUTFChars(env,storageFile,storageFile_ptr);
2595error:
2596 return;
2597}
2598
2599// doc-key: MqContextC,MqContextC-StorageApi-Storage,omo
2600
2602JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_StorageCount (JNIEnv *env, jobject self) {
2603 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2604 JavaErrorCheck;
2605 MkRtSetup_X(hdl);
2606 MQ_LTR cnt_out;
2607 enum MkErrorE errVal = MqStorageCount(hdl, &cnt_out);
2608 MkErrorC_Check(hdl, errVal)
2609 jint __retVal__S = cnt_out;
2610 return __retVal__S;
2611error:
2612 return 0;
2613}
2614
2616JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_StorageErrCnt (JNIEnv *env, jobject self, jint transLId) {
2617 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2618 JavaErrorCheck;
2619 MkRtSetup_X(hdl);
2620 MK_I32 cnt_out;
2621 enum MkErrorE errVal = MqStorageErrCnt(hdl, transLId, &cnt_out);
2622 MkErrorC_Check(hdl, errVal)
2623 jint __retVal__S = cnt_out;
2624 return __retVal__S;
2625error:
2626 return 0;
2627}
2628
2630JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_StorageExport (JNIEnv *env, jobject self) {
2631 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2632 JavaErrorCheck;
2633 MkRtSetup_X(hdl);
2634 MQ_LTR ltid_out;
2635 enum MkErrorE errVal = MqStorageExport(hdl, &ltid_out);
2636 MkErrorC_Check(hdl, errVal)
2637 jint __retVal__S = ltid_out;
2638 return __retVal__S;
2639error:
2640 return 0;
2641}
2642
2644JNIEXPORT jobjectArray JNICALL Java_jvmqmsgque_MqContextC_StorageResolve (JNIEnv *env, jobject self) {
2645 MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
2646 JavaErrorCheck;
2647 MkRtSetup_X(hdl);
2648 MQ_CTX otherCtxP_out;
2649 MQ_LTR otherLIdP_out;
2650 enum MkErrorE errVal = MqStorageResolve(hdl, &otherCtxP_out, &otherLIdP_out);
2651 MkErrorC_Check(hdl, errVal)
2652 jobjectArray __retVal__L = (jobjectArray)(*env)->NewObjectArray(env,2,MK(Class_Object),NULL);
2653 (*env)->SetObjectArrayElement(env,__retVal__L,0,MQ(MqContextC_ObjNew)(MK_RT_CALL env,otherCtxP_out));
2654 (*env)->SetObjectArrayElement(env,__retVal__L,1,pNewIntObj(env,otherLIdP_out));
2655 jobjectArray __retVal__S = __retVal__L;
2656 return __retVal__S;
2657error:
2658 return 0;
2659}
2660
2662// MqContextC_StorageApi_Storage_JV_API
2663
2667
2668// doc-key: MqContextC,MqContextC-TOR,sCc
2669
2671JNIEXPORT jlong JNICALL Java_jvmqmsgque_MqContextC_CTOR (JNIEnv *env, jclass class, jobject tmpl) {
2673 MQ_CTX tmpl_hdl = (MQ_CTX)pObj2Hdl__null_allow(env,tmpl);
2674 JavaErrorCheck;
2675 MQ_CTX __retVal__L = MqContextCreate(MqContextCTT, tmpl_hdl);
2676 if (__retVal__L == NULL) {
2677 (*env)->ThrowNew(env, MK(Class_MkInitError), "MqContextC.CTOR");
2678 goto error;
2679 }
2680 jlong __retVal__S = (jlong)__retVal__L;
2681 return __retVal__S;
2682error:
2683 return 0;
2684}
2685
2687JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_Create (JNIEnv *env, jclass class, jobject tmpl) {
2689 MQ_CTX tmpl_hdl = (MQ_CTX)pObj2Hdl__null_allow(env,tmpl);
2690 JavaErrorCheck;
2691 MQ_CTX __retVal__L = MqContextCreate(MqContextCTT, tmpl_hdl);
2692 if (__retVal__L == NULL) {
2693 (*env)->ThrowNew(env, MK(Class_MkInitError), "MqContextC.Create");
2694 goto error;
2695 }
2696 jobject __retVal__S = MQ(MqContextC_ObjCreate)(MK_RT_CALL env,__retVal__L);
2697 return __retVal__S;
2698error:
2699 return 0;
2700}
2701
2703// MqContextC_TOR_JV_API
2704
2705// END-MqContextC - created by 'jv_MqC.tcl -i NHI1_HOME/theLink/c/gen/c_mqmsgque.meta' - DO NOT change
2706
2707// +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
2708
2709void NS(MqContextC_Init)(MQ_RT_ARGS_ONLY) {
2710 ClassInit
2711
2712 // define type
2713 MqContextCTT = MkTypeDup2(MqContextC_TT,"JvMqContextC");
2714 MqContextCTT->selfCreate = NS(MqContextC_selfCreate) ;
2715 MqContextCTT->selfUnlink = MK(AtomSelfUnlink) ;
2716 MqContextCT->argvFix = true ;
2717 MqContextCT->MqProcessExitCB = sProcessExit ;
2718 MqContextCT->MqThreadExitCB = sThreadExit ;
2719 MqContextCT->MqWaitForPipeCB = sWaitForPipe ;
2720 MqContextCT->Child.fCreate = MqLinkDefault_RT ;
2721 MqContextCT->Parent.fCreate = MqLinkDefault_RT ;
2722 MqContextCT->ignoreFork = true ;
2723 MqContextCT->ignoreDisasterSetup = true ;
2724}
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_INIT(JNIEnv *env, jobject self)
static MK_TYP MqContextCTT
static int sThreadExit(MK_RT mkrt, int exitnum)
static int sProcessExit(MK_RT mkrt, int exitnum)
static bool sWaitForPipe(MK_RT mkrt, MQ_CTX const ctx, const struct MkIdS *idP)
#define ClassInit
struct MkBufferS * MK_BUF
const struct MkBufferS * MK_BUFN
struct MkBufferListS * MK_BFL
const struct MkBufferListS * MK_BFLN
struct MkBufferListS * MK_BAC
const struct MkBufferStreamS * MK_BUSN
static MkBinaryR MkBinaryCreate(MK_SIZE size, MK_BINN data)
#define MK_UNUSED
MK_STRN MkTypeE_ToString(enum MkTypeE value)
MkErrorE
MkTypeE
MK_STRN MkErrorE_ToString(enum MkErrorE value)
static MkStringR MkStringCreate(MK_NUM len, MK_STRN str)
int32_t MK_NUM
float MK_FLT
MK_PTRB * MK_PTR
const MK_STRB * MK_STRN
void * MK_NAT_OBJECT
MK_PTRB * MK_CBP
signed char MK_I8
signed long long MK_I64
bool MK_BOOL
void * MK_NAT_LIST
unsigned char MK_BOL
long MK_SIZE
long MK_LONG
signed short int MK_I16
double MK_DBL
time_t MK_TIME_T
int32_t MK_HDL
MK_BINB const * MK_BINN
signed int MK_I32
const struct MkObjectS * MK_OBJN
MK_ID_THREAD
MK_ID_PROCESS
MK_ID_UNUSED
static MK_I32 MkRuntimeDebugGet(void)
#define MkThreadLocal
#define MK_RT_CALL
#define MkRtSetup_X(x)
#define MK_RT_ARGS
#define MkRtSetup_NULL
#define MkTypeDup2(...)
static MK_ERR MqContextErrorFORMAT(MQ_CTXN const fmtobj)
helper used to access MkErrorDEFAULT from MqContextC
#define MqClassFactorySet(...)
MK_STRN MqClassIdentGet(MQ_CTXN const ctx)
get the application-identification …
#define MqClassIdentSet(...)
MK_STRN MqClassOriginalIdentGet(MQ_CTXN const ctx)
get the MqFactoryS::originalIdent from the MqContextC
MQ_FCT const MqClassFactoryGet(MQ_CTXN const ctx)
get the MqFactoryC used by the MqContextC
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ClassFactorySet(JNIEnv *env, jobject self, jobject item)
Java: ctx.ClassFactorySet(MqFactoryC item) → C-API link the MqContextC to a new MqFactoryC
JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ClassOriginalIdentGet(JNIEnv *env, jobject self)
Java: String ctx.ClassOriginalIdentGet() → C-API get the MqFactoryS::originalIdent from the MqC...
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ClassFactoryGet(JNIEnv *env, jobject self)
Java: MqFactoryC ctx.ClassFactoryGet() → C-API get the MqFactoryC used by the MqContextC
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ClassIdentSet(JNIEnv *env, jobject self, jstring ident)
Java: ctx.ClassIdentSet(String ident) → C-API link the MqContextC to a new MqFactoryC identifie...
JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ClassIdentGet(JNIEnv *env, jobject self)
Java: String ctx.ClassIdentGet() → C-API get the application-identification …
#define MqContextHandleResolve(...)
const struct MqContextS * MQ_CTXN
class-shortcut for const struct MqContextS *, all const shortcut using the XX_YYYC syntax (only for p...
#define MqContextInstances()
struct MqContextS * MQ_CTX
class-shortcut for struct MqContextS *, all shortcut using the XX_YYY syntax (only for public API) …
static MQ_CTX MqContextNext(MQ_CTX const ctx)
get next instance from linked-list of MqContextS type
static MQ_CTX MqContextPrev(MQ_CTX const ctx)
get previous instance from linked-list of MqContextS type
static MQ_CTX MqContextGetNull(void)
Null-Slot - return a MqContextC typed NULL instance …
#define MqContextC_X2obj(x)
#define MqContextCT
class as MqTypeCtxS-class-type for MqContextC in the Target-Programming-Language (TPL) …
#define MqContextC_TT
class as MkTypeS-class-type, useable in a class-macro as: class##_TT …
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_Next(JNIEnv *env, jobject self)
Java: MqContextC ctx.Next() → C-API get next instance from linked-list of MqContextS type
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_Prev(JNIEnv *env, jobject self)
Java: MqContextC ctx.Prev() → C-API get previous instance from linked-list of MqContextS type
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_HandleResolve(JNIEnv *env, jclass class, jint netHdl)
Java: [static] MqContextC MqContextC.HandleResolve(int netHdl) → C-API Handle-Resolve-Slot - ret...
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_Instances(JNIEnv *env, jclass class)
Java: [static] MqContextC MqContextC.Instances() → C-API get head-instance from linked-list of M...
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_GetNull(JNIEnv *env, jclass class)
Java: [static] MqContextC MqContextC.GetNull() → C-API Null-Slot - return a MqContextC typed NUL...
static enum MqStartE MqConfigGetStartAs(MQ_CTX const ctx)
return the MqConfigS::startAs value
static MK_I32 MqConfigGetPkgsize(MQ_CTXN const ctx)
get the maximun size of a BDY package
static MK_STRN MqConfigGetName(MQ_CTXN const ctx)
get the name of the context object
static MK_TIME_T MqConfigGetTimeout(MQ_CTXN const ctx)
get the timeout value of the context object
static bool MqConfigGetIsParent(MQ_CTX const ctx)
does the context object is a parent ? An objext is a parent id the MqConfigS::parent attribute is nul...
#define MqConfigSetConfigFile(...)
static MK_I32 MqConfigGetBuffersize(MQ_CTXN const ctx)
get the minimum of the read/send buffersize of the socket
static MK_STRN MqConfigGetPostfix(MQ_CTXN const ctx)
get the MqConfigS::dispPostfix
static bool MqConfigGetIsServer(MQ_CTX const ctx)
does the context object is a server ?
static MQ_SOCK_HDL MqConfigGetIoPipe(MQ_CTX const ctx)
return the MqIoPipeConfigS
static MK_STRN MqConfigGetPrefix(MQ_CTXN const ctx)
get the MqConfigS::dispPrefix
static MK_STRN MqConfigGetStorage(MQ_CTXN const ctx)
get the storage of the context object
static MK_STRN MqConfigGetIoUds(MQ_CTXN const ctx)
return the MqIoUdsConfigS
enum MkErrorE MqConfigGetIoTcp(MQ_CTX const ctx, MK_STRN *host_out, MK_STRN *port_out, MK_STRN *myhost_out, MK_STRN *myport_out)
get the configuration-data of the tcp-client-server-link …
#define MqConfigGetIoTcpL(...)
static enum MqIdentE MqConfigGetIdentFrom(MQ_CTX const ctx)
get the MqConfigS::identFrom
static enum MqStatusIsEF MqConfigGetStatusIs(MQ_CTX const ctx)
return the MqContextS::statusIs value
static bool MqConfigGetIsString(MQ_CTX const ctx)
does the context object is using the string-mode ?
JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ConfigGetIsString(JNIEnv *env, jobject self)
Java: boolean ctx.ConfigGetIsString() → C-API does the context object is using the string-mode ...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetConfigFile(JNIEnv *env, jobject self, jstring filename)
Java: ctx.ConfigSetConfigFile(String filename) → C-API set the config-file and parse for well-k...
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ConfigGetIoTcpL(JNIEnv *env, jobject self)
Java: MkBufferListC ctx.ConfigGetIoTcpL() → C-API get the configuration-data of the tcp-client-...
JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_ConfigGetBuffersize(JNIEnv *env, jobject self)
Java: int ctx.ConfigGetBuffersize() → C-API get the minimum of the read/send buffersize of the ...
JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ConfigGetIoUds(JNIEnv *env, jobject self)
Java: String ctx.ConfigGetIoUds() → C-API return the MqIoUdsConfigS
JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ConfigGetPostfix(JNIEnv *env, jobject self)
Java: String ctx.ConfigGetPostfix() → C-API get the MqConfigS::dispPostfix
JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ConfigGetName(JNIEnv *env, jobject self)
Java: String ctx.ConfigGetName() → C-API get the name of the context object
JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ConfigGetStorage(JNIEnv *env, jobject self)
Java: String ctx.ConfigGetStorage() → C-API get the storage of the context object
JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ConfigGetIsServer(JNIEnv *env, jobject self)
Java: boolean ctx.ConfigGetIsServer() → C-API does the context object is a server ?
JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_ConfigGetPkgsize(JNIEnv *env, jobject self)
Java: int ctx.ConfigGetPkgsize() → C-API get the maximun size of a BDY package
JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ConfigGetIsParent(JNIEnv *env, jobject self)
Java: boolean ctx.ConfigGetIsParent() → C-API does the context object is a parent ?...
JNIEXPORT jlong JNICALL Java_jvmqmsgque_MqContextC_ConfigGetTimeout(JNIEnv *env, jobject self)
Java: long ctx.ConfigGetTimeout() → C-API get the timeout value of the context object
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ConfigGetIdentFrom(JNIEnv *env, jobject self)
Java: MqIdentE ctx.ConfigGetIdentFrom() → C-API get the MqConfigS::identFrom
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ConfigGetStartAs(JNIEnv *env, jobject self)
Java: MqStartE ctx.ConfigGetStartAs() → C-API return the MqConfigS::startAs value
JNIEXPORT jobjectArray JNICALL Java_jvmqmsgque_MqContextC_ConfigGetIoTcp(JNIEnv *env, jobject self)
Java: {host:String port:String myhost:String myport:String} ctx.ConfigGetIoTcp() → C-API get th...
JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_ConfigGetIoPipe(JNIEnv *env, jobject self)
Java: int ctx.ConfigGetIoPipe() → C-API return the MqIoPipeConfigS
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ConfigGetStatusIs(JNIEnv *env, jobject self)
Java: MqStatusIsEF ctx.ConfigGetStatusIs() → C-API return the MqContextS::statusIs value
JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ConfigGetPrefix(JNIEnv *env, jobject self)
Java: String ctx.ConfigGetPrefix() → C-API get the MqConfigS::dispPrefix
#define MqConfigSetBgError(...)
#define MqConfigSetServerSetup(...)
#define MqConfigSetServerCleanup(...)
#define MqConfigSetEvent(...)
#define MqConfigReset(...)
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigReset(JNIEnv *env, jobject self)
Java: ctx.ConfigReset() → C-API clean the MqContextS::config data
#define MqConfigSetDaemon(...)
#define MqConfigSetPrefix(...)
void MqConfigSetPkgsize(MQ_CTX const ctx, MK_I32 data)
set the MqIoConfigS::pkgsize value
bool MqConfigCheckStartAs(MQ_CTX const ctx, enum MqStartE data)
check if MqConfigS::startAs can be set to data
#define MqConfigSetIoPipe(...)
void MqConfigSetIgnoreExit(MQ_CTX const ctx, bool data)
set the MqSetupS::ignoreExit value
#define MqConfigSetIoTcp(...)
#define MqConfigSetPostfix(...)
#define MqConfigSetName(...)
void MqConfigSetTimeout(MQ_CTX const ctx, MK_TIME_T data)
set the MqIoConfigS::timeout value
enum MkErrorE MqConfigSetStartAsString(MQ_CTX const ctx, MK_STRN data)
set the MqConfigS::startAs value using string default, thread, fork or spawn
void MqConfigSetIsString(MQ_CTX const ctx, bool data)
set the MqConfigS::native value 'S'string or 'L'owEndian or 'B'igEndian
#define MqConfigSetIoUds(...)
void MqConfigSetIdentFrom(MQ_CTX const ctx, enum MqIdentE data)
set the MqConfigS::identFrom value
enum MkErrorE MqConfigSetStartAs(MQ_CTX const ctx, enum MqStartE data)
set the MqConfigS::startAs value
void MqConfigSetBuffersize(MQ_CTX const ctx, MK_I32 data)
set the MqIoConfigS::buffersize value
#define MqConfigSetAllDebug(...)
#define MqConfigSetIoTcpL(...)
#define MqConfigSetStorage(...)
void MqConfigSetIsServer(MQ_CTX const ctx, bool data)
set the MqSetupS::isServer value
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetBuffersize(JNIEnv *env, jobject self, jint data)
Java: ctx.ConfigSetBuffersize(int data) → C-API set the MqIoConfigS::buffersize value
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetIsString(JNIEnv *env, jobject self, jboolean data)
Java: ctx.ConfigSetIsString(boolean data) → C-API set the MqConfigS::native value 'S'string or ...
JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ConfigCheckStartAs(JNIEnv *env, jobject self, jobject data)
Java: boolean ctx.ConfigCheckStartAs(MqStartE data) → C-API check if MqConfigS::startAs can be ...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetDaemon(JNIEnv *env, jobject self, jstring pidfile)
Java: ctx.ConfigSetDaemon(String pidfile) → C-API start the server-context as daemon …
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetStartAs(JNIEnv *env, jobject self, jobject data)
Java: ctx.ConfigSetStartAs(MqStartE data) → C-API set the MqConfigS::startAs value
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetPostfix(JNIEnv *env, jobject self, jstring data)
Java: ctx.ConfigSetPostfix(String data) → C-API set the client-part (2) of the application-id...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetIoTcp__Ljava_lang_String_2Ljava_lang_String_2Ljava_lang_String_2Ljava_lang_String_2(JNIEnv *env, jobject self, jstring host, jstring port, jstring myhost, jstring myport)
Java: ctx.ConfigSetIoTcp(?String host = null?, ?String port = null?, ?String myhost = null?...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetPrefix(JNIEnv *env, jobject self, jstring data)
Java: ctx.ConfigSetPrefix(String data) → C-API set the server-part (1) of the application-ide...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetStorage(JNIEnv *env, jobject self, jstring data)
Java: ctx.ConfigSetStorage(String data) → C-API set the Storage value and cleanup old value
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetIoUds(JNIEnv *env, jobject self, jstring file)
Java: ctx.ConfigSetIoUds(String file) → C-API configure a context to use a uds-client-server-...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetPkgsize(JNIEnv *env, jobject self, jint data)
Java: ctx.ConfigSetPkgsize(int data) → C-API set the MqIoConfigS::pkgsize value
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetStartAsString(JNIEnv *env, jobject self, jstring data)
Java: ctx.ConfigSetStartAsString(String data) → C-API set the MqConfigS::startAs value using st...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetIdentFrom(JNIEnv *env, jobject self, jobject data)
Java: ctx.ConfigSetIdentFrom(MqIdentE data) → C-API set the MqConfigS::identFrom value
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetAllDebug(JNIEnv *env, jobject self, jint data)
Java: ctx.ConfigSetAllDebug(int data) → C-API set the MkRuntimeS::debug value
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetIoTcp__Ljvmkkernel_MkBufferListC_2(JNIEnv *env, jobject self, jobject vals)
Java: ctx.ConfigSetIoTcp(MkBufferListC vals) → C-API configure a context to use a tcp-client-...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetName(JNIEnv *env, jobject self, jstring data)
Java: ctx.ConfigSetName(String data) → C-API set the MqConfigS::dispName value and cleanup old ...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetIoPipe(JNIEnv *env, jobject self, jint fh)
Java: ctx.ConfigSetIoPipe(int fh) → C-API set the pipe configuration data …
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetTimeout(JNIEnv *env, jobject self, jlong data)
Java: ctx.ConfigSetTimeout(long data) → C-API set the MqIoConfigS::timeout value
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetIsServer(JNIEnv *env, jobject self, jboolean data)
Java: ctx.ConfigSetIsServer(boolean data) → C-API set the MqSetupS::isServer value
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ConfigSetIgnoreExit(JNIEnv *env, jobject self, jboolean data)
Java: ctx.ConfigSetIgnoreExit(boolean data) → C-API set the MqSetupS::ignoreExit value
void MqEnvRestore(MQ_CTX ctx)
restore the service-environment
#define MqEnvProtect(...)
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_EnvProtect(JNIEnv *env, jobject self)
Java: ctx.EnvProtect() → C-API protect the service-environment
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_EnvRestore(JNIEnv *env, jobject self)
Java: ctx.EnvRestore() → C-API restore the service-environment
#define MqContextErrorMove(...)
#define MqContextErrorCopy(...)
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ErrorCopy(JNIEnv *env, jobject self, jobject sourceCtx)
Java: MkErrorE targetCtx.ErrorCopy(MqContextC sourceCtx) → C-API copy a MkErrorS from the sourc...
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ErrorFORMAT(JNIEnv *env, jobject self)
Java: MkErrorC fmtobj.ErrorFORMAT() → C-API helper used to access MkErrorDEFAULT from MqContext...
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ErrorMove(JNIEnv *env, jobject self, jobject sourceCtx)
Java: MkErrorE targetCtx.ErrorMove(MqContextC sourceCtx) → C-API move a MkErrorS from the sourc...
#define MqContextLogShort(...)
#define MqContextLogEnv(...)
static MK_STRN MqLogParentOrChild(MQ_CTXN ctx)
is ctx a PARENT or a CHILD ? …
#define MqContextLogConfig(...)
#define MqContextLogSetup(...)
#define MqContextLogLink(...)
#define MqContextLogType(...)
static MK_STRN MqLogServerOrClient(MQ_CTXN const ctx)
is ctx a SERVER or a CLIENT ? …
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_LogType(JNIEnv *env, jobject self, jobject fmtobj, jint debug, jstring callfunc, jint lvl)
Java: ctx.LogType(?MkObjectC fmtobj = null?, ?int debug = 0?, ?String callfunc = null?...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_LogConfig(JNIEnv *env, jobject self, jobject fmtobj, jint debug, jstring callfunc, jint lvl)
Java: ctx.LogConfig(?MkObjectC fmtobj = null?, ?int debug = 0?, ?String callfunc = null?...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_LogShort(JNIEnv *env, jobject self, jobject fmtobj, jint debug, jstring callfunc, jint lvl, jstring label)
Java: ctx.LogShort(?MkObjectC fmtobj = null?, ?int debug = 0?, ?String callfunc = null?...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_LogEnv(JNIEnv *env, jobject self, jobject fmtobj, jint debug, jstring callfunc, jint lvl)
Java: ctx.LogEnv(?MkObjectC fmtobj = null?, ?int debug = 0?, ?String callfunc = null?...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_LogLink(JNIEnv *env, jobject self, jobject fmtobj, jint debug, jstring callfunc, jint lvl)
Java: ctx.LogLink(?MkObjectC fmtobj = null?, ?int debug = 0?, ?String callfunc = null?...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_LogSetup(JNIEnv *env, jobject self, jobject fmtobj, jint debug, jstring callfunc, jint lvl)
Java: ctx.LogSetup(?MkObjectC fmtobj = null?, ?int debug = 0?, ?String callfunc = null?...
JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_LogParentOrChild(JNIEnv *env, jobject self)
Java: String ctx.LogParentOrChild() → C-API is ctx a PARENT or a CHILD ? …
JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_LogServerOrClient(JNIEnv *env, jobject self)
Java: String ctx.LogServerOrClient() → C-API is ctx a SERVER or a CLIENT ? …
#define MqProcessEvent(...)
#define MqExit(...)
#define MqContextGetBuffer(...)
static MQ_CTX MqGetRoot(MQ_CTX ctx)
get the Root (toplevel initial context)
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_GetRoot(JNIEnv *env, jobject self)
Java: MqContextC ctx.GetRoot() → C-API get the Root (toplevel initial context)
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_GetBuffer(JNIEnv *env, jobject self)
Java: MkBufferC ctx.GetBuffer() → C-API get the MqContextS::ctxbuf object
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ProcessEvent(JNIEnv *env, jobject self, jobject wait, jlong timeout)
Java: ctx.ProcessEvent(?MqWaitOnEventE wait = MQ_WAIT_NO?, ?long timeout = MkTimeoutE....
JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_Exit(JNIEnv *env, jobject self, jstring callfunc, jstring callfile, jint callline)
Java: int ctx.Exit(?String callfunc = null?, ?String callfile = null?, ?int callline = -1?...
#define MqProxyItem(...)
#define MqProxyForward(...)
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ProxyForward(JNIEnv *env, jobject self, jobject targetCtx, jobject dump, jlong timeout)
Java: sourceCtx.ProxyForward(MqContextC targetCtx, ?MqDumpC dump = null?, ?long timeout = MkTimeoutE...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ProxyItem(JNIEnv *env, jobject self, jobject targetCtx)
Java: sourceCtx.ProxyItem(MqContextC targetCtx) → C-API Copy a single-data-item from the source...
#define MqReadI64(...)
#define MqReadSTR(...)
#define MqReadI16(...)
#define MqReadDBL(...)
#define MqReadBFL(...)
#define MqReadBUF(...)
#define MqReadHDL(...)
#define MqReadLONG(...)
#define MqReadI8(...)
#define MqReadBIN(...)
#define MqReadFLT(...)
#define MqReadBinaryR(...)
#define MqReadALL(...)
#define MqReadStringR(...)
#define MqReadBOL(...)
#define MqReadI32(...)
JNIEXPORT jbyteArray JNICALL Java_jvmqmsgque_MqContextC_ReadBinaryR(JNIEnv *env, jobject self)
Java: byte[] ctx.ReadBinaryR() → C-API read a MkBinaryR from the read-data-package …
JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ReadSTR(JNIEnv *env, jobject self)
Java: doc_mq_jv_ReadSTR → C-API read a PRIMITIVE TYPE from the read-data-package …
JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_ReadHDL(JNIEnv *env, jobject self)
Java: int ctx.ReadHDL() → C-API read the handle from the read-data-package
JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_ReadI32(JNIEnv *env, jobject self)
Java: doc_mq_jv_ReadI32 → C-API read a PRIMITIVE TYPE from the read-data-package …
JNIEXPORT jdouble JNICALL Java_jvmqmsgque_MqContextC_ReadDBL(JNIEnv *env, jobject self)
Java: doc_mq_jv_ReadDBL → C-API read a PRIMITIVE TYPE from the read-data-package …
JNIEXPORT jfloat JNICALL Java_jvmqmsgque_MqContextC_ReadFLT(JNIEnv *env, jobject self)
Java: doc_mq_jv_ReadFLT → C-API read a PRIMITIVE TYPE from the read-data-package …
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ReadBUF(JNIEnv *env, jobject self)
Java: MkBufferC ctx.ReadBUF() → C-API get a temporary MkBufferC from the read-data-package …
JNIEXPORT jbyte JNICALL Java_jvmqmsgque_MqContextC_ReadI8(JNIEnv *env, jobject self)
Java: doc_mq_jv_ReadI8 → C-API read a PRIMITIVE TYPE from the read-data-package …
JNIEXPORT jlong JNICALL Java_jvmqmsgque_MqContextC_ReadLONG(JNIEnv *env, jobject self)
Java: long ctx.ReadLONG() → C-API read the long native object from the read-data-package
JNIEXPORT jshort JNICALL Java_jvmqmsgque_MqContextC_ReadI16(JNIEnv *env, jobject self)
Java: doc_mq_jv_ReadI16 → C-API read a PRIMITIVE TYPE from the read-data-package …
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ReadALL(JNIEnv *env, jobject self, jobject val_inout)
Java: MkBufferListC ctx.ReadALL(?MkBufferListC val_inout = null?) → C-API get a temporary MkBuf...
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ReadBFL(JNIEnv *env, jobject self)
Java: MkBufferListC ctx.ReadBFL() → C-API get a temporary MkBufferListC from next list-item in ...
JNIEXPORT jbyteArray JNICALL Java_jvmqmsgque_MqContextC_ReadBIN(JNIEnv *env, jobject self)
Java: doc_mq_jv_ReadBIN → C-API generic function to read an MK_BIN object from the read-data-pac...
JNIEXPORT jlong JNICALL Java_jvmqmsgque_MqContextC_ReadI64(JNIEnv *env, jobject self)
Java: doc_mq_jv_ReadI64 → C-API read a PRIMITIVE TYPE from the read-data-package …
JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ReadStringR(JNIEnv *env, jobject self)
Java: String ctx.ReadStringR() → C-API read a MkStringR from the read-data-package …
JNIEXPORT MK_NAT_LIST JNICALL ReadLIST(JNIEnv *env, jobject self)
Java: List<Object> ctx.ReadLIST() → C-API get all arguments as native list …
JNIEXPORT MK_NAT_OBJECT JNICALL ReadNEXT(JNIEnv *env, jobject self)
Java: Object ctx.ReadNEXT() → C-API get the next argument as native object …
JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ReadBOL(JNIEnv *env, jobject self)
Java: doc_mq_jv_ReadBOL → C-API read a PRIMITIVE TYPE from the read-data-package …
#define MqReadT_START(...)
#define MqReadL_START(...)
#define MqReadT_END(...)
#define MqReadL_END(...)
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ReadL_1START(JNIEnv *env, jobject self, jobject buf)
Java: ctx.ReadL_START(?MkBufferC buf = null?) → C-API start to extract a list-items from the re...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ReadT_1START(JNIEnv *env, jobject self)
Java: ctx.ReadT_START() → C-API start to extract a longterm-transaction-item from the read-data...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ReadL_1END(JNIEnv *env, jobject self)
Java: ctx.ReadL_END() → C-API finish to extract a list-items from the read-data-package....
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ReadT_1END(JNIEnv *env, jobject self)
Java: ctx.ReadT_END() → C-API finish to extract a longterm-transaction-item from the read-data-...
#define MqReadDbg(...)
enum MkTypeE MqReadGetNextType(MQ_CTX const ctx)
get the type (MkTypeE) of the next Item in the read-data-buffer or "0" if not available
MK_NUM MqReadGetNumItems(MQ_CTX const ctx)
get the number of items left in the read-data-package …
bool MqReadItemExists(MQ_CTX const ctx)
check if an item exists in the read-data-package …
#define MqReadUndo(...)
JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_ReadGetNumItems(JNIEnv *env, jobject self)
Java: int ctx.ReadGetNumItems() → C-API get the number of items left in the read-data-package …
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ReadUndo(JNIEnv *env, jobject self)
Java: ctx.ReadUndo() → C-API undo the last MqContextC READ API function call …
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ReadDbg(JNIEnv *env, jobject self)
ReadDbg
JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ReadItemExists(JNIEnv *env, jobject self)
Java: boolean ctx.ReadItemExists() → C-API check if an item exists in the read-data-package …
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_ReadGetNextType(JNIEnv *env, jobject self)
Java: MkTypeE ctx.ReadGetNextType() → C-API get the type (MkTypeE) of the next Item in the read...
#define MqRouteDelete(...)
#define MqRouteTraverse(...)
#define MqRouteGetTree(...)
#define MqRouteCreate(...)
#define MqRouteGetPath(...)
#define MqRouteResolve(...)
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_RouteGetTree(JNIEnv *env, jobject self)
Java: MkBufferListC ctx.RouteGetTree() → C-API create an overview about all available routing-t...
JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_RouteGetPath(JNIEnv *env, jobject self)
Java: String ctx.RouteGetPath() → C-API return the absolut route-connection-string up to the cu...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_RouteDelete(JNIEnv *env, jobject self, jstring route, jstring service, jboolean overwrite)
Java: ctx.RouteDelete(String route, String service, ?boolean overwrite = false?) → C-API delete...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_RouteCreate(JNIEnv *env, jobject self, jstring route, jstring service, jboolean overwrite)
Java: ctx.RouteCreate(String route, String service, ?boolean overwrite = false?) → C-API create...
JNIEXPORT jobjectArray JNICALL Java_jvmqmsgque_MqContextC_RouteResolve(JNIEnv *env, jobject self, jstring ident, jint retnum)
Java: MqContextC[] ctx.RouteResolve(String ident, ?int retnum = -1?) → C-API return a list of a...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_RouteTraverse(JNIEnv *env, jobject self, jstring service, jobject args)
Java: ctx.RouteTraverse(String service, ?MkBufferListC args = null?) → C-API traverse a tree do...
#define MqSendBIN(...)
#define MqSendLONG(...)
#define MqSendI8(...)
#define MqSendBOL(...)
#define MqSendI64(...)
#define MqSendI32(...)
#define MqSendBFL(...)
#define MqSendStringR(...)
#define MqSendI16(...)
#define MqSendL_FLAT(...)
#define MqSendSTR(...)
#define MqSendLTR(...)
#define MqSendHDL(...)
#define MqSendFLT(...)
#define MqSendDBL(...)
#define MqSendBUF(...)
#define MqSendBUS_FLAT(...)
#define MqSendBinaryR(...)
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendBIN(JNIEnv *env, jobject self, jbyteArray val)
Java: doc_mq_jv_SendBIN → C-API append a MK_BIN object to the send-data-package....
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendStringR(JNIEnv *env, jobject self, jstring val)
Java: ctx.SendStringR(String val) → C-API MqContextC - append a native PRIMITIVE TYPE value t...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendBUS_1FLAT(JNIEnv *env, jobject self, jobject val)
Java: ctx.SendBUS_FLAT(MkBufferStreamC val) → C-API append a MkBufferStreamC object to the send...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendHDL(JNIEnv *env, jobject self, jint val)
Java: ctx.SendHDL(int val) → C-API send the handle to the send-data-package
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendLTR(JNIEnv *env, jobject self, jint transLId)
SendLTR
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendBUF(JNIEnv *env, jobject self, jobject val)
Java: ctx.SendBUF(MkBufferC val) → C-API append a MkBufferC object to the send-data-package obj...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendBOL(JNIEnv *env, jobject self, jboolean val)
Java: doc_mq_jv_SendBOL → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendI8(JNIEnv *env, jobject self, jbyte val)
Java: doc_mq_jv_SendI8 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-dat...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendBinaryR(JNIEnv *env, jobject self, jbyteArray val)
Java: ctx.SendBinaryR(byte[] val) → C-API append a MkBinaryR object to the send-data-package....
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendI64(JNIEnv *env, jobject self, jlong val)
Java: doc_mq_jv_SendI64 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendDBL(JNIEnv *env, jobject self, jdouble val)
Java: doc_mq_jv_SendDBL → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendI32(JNIEnv *env, jobject self, jint val)
Java: doc_mq_jv_SendI32 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendI16(JNIEnv *env, jobject self, jshort val)
Java: doc_mq_jv_SendI16 → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendLONG(JNIEnv *env, jobject self, jlong val)
Java: ctx.SendLONG(long val) → C-API send the long native object to the send-data-package
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendBFL(JNIEnv *env, jobject self, jobject val)
Java: ctx.SendBFL(MkBufferListC val) → C-API append a MkBufferListC object to the send-data-pac...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendL_1FLAT(JNIEnv *env, jobject self, jobject val)
Java: ctx.SendL_FLAT(MkBufferListC val) → C-API append a MkBufferListC object as flat list of i...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendFLT(JNIEnv *env, jobject self, jfloat val)
Java: doc_mq_jv_SendFLT → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendSTR(JNIEnv *env, jobject self, jstring val)
Java: doc_mq_jv_SendSTR → C-API MqContextC - append a native PRIMITIVE TYPE value to the send-...
#define MqSendSTART(...)
#define MqSendEND_AND_TRANSACTION(...)
#define MqSendEND_AND_CALLBACK(...)
#define MqSendEND_AND_SUB(...)
#define MqSendEND_AND_WAIT(...)
#define MqSendEND(...)
#define MqSendSYNC(...)
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendEND_1AND_1TRANSACTION(JNIEnv *env, jobject self, jstring token, jstring callback, jlong timeout)
Java: ctx.SendEND_AND_TRANSACTION(String token, String callback, ?long timeout = MkTimeoutE....
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendSTART(JNIEnv *env, jobject self)
Java: ctx.SendSTART() → C-API initialize the send-data-package. …
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendEND_1AND_1CALLBACK(JNIEnv *env, jobject self, jstring token, jobject callback, jlong timeout)
Java: ctx.SendEND_AND_CALLBACK(String token, MqServiceIF callback, ?long timeout = MkTimeoutE....
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendEND_1AND_1WAIT(JNIEnv *env, jobject self, jstring token, jlong timeout)
Java: ctx.SendEND_AND_WAIT(String token, ?long timeout = MkTimeoutE.DEFAULT.get()?...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendEND_1AND_1SUB(JNIEnv *env, jobject self, jstring token, jobject callback, jlong timeout)
Java: ctx.SendEND_AND_SUB(String token, MqServiceIF callback, ?long timeout = MkTimeoutE....
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendSYNC(JNIEnv *env, jobject self)
Java: ctx.SendSYNC() → C-API garantee that all pending asynchronous-service-calls are processed...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendEND(JNIEnv *env, jobject self, jstring token, jlong timeout)
Java: ctx.SendEND(String token, ?long timeout = MkTimeoutE.DEFAULT.get()?) → C-API MqContextC -...
#define MqSendL_START(...)
#define MqSendT_END(...)
#define MqSendL_END(...)
#define MqSendT_START(...)
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendT_1START(JNIEnv *env, jobject self)
Java: ctx.SendT_START() → C-API open a longterm-transaction-item …
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendL_1START(JNIEnv *env, jobject self)
Java: ctx.SendL_START() → C-API start to append an embedded body-list-item to the send-data-pac...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendL_1END(JNIEnv *env, jobject self)
Java: ctx.SendL_END() → C-API finish to append an embedded body-list-item to the send-data-pack...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendT_1END(JNIEnv *env, jobject self)
Java: ctx.SendT_END() → C-API closed a longterm-transaction-item …
#define MqSendRETURN_SUB(...)
#define MqSendERROR(...)
#define MqSendRETURN(...)
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendRETURN_1SUB(JNIEnv *env, jobject self)
Java: ctx.SendRETURN_SUB() → C-API return Sub-Data-Blocks required by MqSendEND_AND_SUB …
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendRETURN(JNIEnv *env, jobject self)
Java: ctx.SendRETURN() → C-API MqContextC - finish the send-data-block on the server and option...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SendERROR(JNIEnv *env, jobject self)
Java: ctx.SendERROR() → C-API send the data from the MkErrorC to the link target ....
bool MqServiceTokenCheck(MQ_CTX const ctx, MQ_TOK const token)
in an ongoing-service-call check if the current MqContextC_ServiceApi_Identifer is token …
#define MqServiceStorage(...)
#define MqServiceProxyCtx(...)
bool MqServiceProxyCtxExists(MQ_CTX const ctx, MQ_TOK const token, MQ_CTX const target)
check if service who belongs to token is a proxy-service
MQ_TOK MqServiceTokenGet(MQ_CTX const ctx)
in an ongoing-service-call get the current MqContextC_ServiceApi_Identifer …
static bool MqServiceIsTransaction(MQ_CTX const ctx)
check if the ongoing-service-call belongs to a transaction …
#define MqServiceCreate(...)
#define MqServiceProxy(...)
MK_STRN MQ_TOK
MqContextC - a char[4+1] or hex[8+1] string used to unique identify a service …
#define MqServiceProxyRoundRobin(...)
#define MqServiceDelete(...)
bool MqServiceTokenExists(MQ_CTX const ctx, MQ_TOK const token)
check if the MqContextC_ServiceApi_Identifer token is defined as ctx service …
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ServiceProxy(JNIEnv *env, jobject self, jstring token, jint id)
Java: ctx.ServiceProxy(String token, ?int id = MqSlaveE.OTHER.get()?) → C-API create a service ...
JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ServiceTokenExists(JNIEnv *env, jobject self, jstring token)
Java: boolean ctx.ServiceTokenExists(String token) → C-API check if the MqContextC_ServiceApi_I...
JNIEXPORT jstring JNICALL Java_jvmqmsgque_MqContextC_ServiceTokenGet(JNIEnv *env, jobject self)
Java: String ctx.ServiceTokenGet() → C-API in an ongoing-service-call get the current MqContext...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ServiceProxyCtx(JNIEnv *env, jobject self, jstring token, jobject target)
Java: ctx.ServiceProxyCtx(String token, MqContextC target) → C-API same as MqServiceProxy but u...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ServiceDelete(JNIEnv *env, jobject self, jstring token)
Java: ctx.ServiceDelete(String token) → C-API delete a service. …
JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ServiceTokenCheck(JNIEnv *env, jobject self, jstring token)
Java: boolean ctx.ServiceTokenCheck(String token) → C-API in an ongoing-service-call check if t...
JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ServiceProxyCtxExists(JNIEnv *env, jobject self, jstring token, jobject target)
Java: boolean ctx.ServiceProxyCtxExists(String token, MqContextC target) → C-API check if servi...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ServiceProxyRoundRobin(JNIEnv *env, jobject self, jstring token, jstring ident)
Java: ctx.ServiceProxyRoundRobin(String token, String ident) → C-API create a proxy-service usi...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ServiceStorage(JNIEnv *env, jobject self, jstring token)
Java: ctx.ServiceStorage(String token) → C-API setup a service listen on a MqContextC_ServiceAp...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_ServiceCreate(JNIEnv *env, jobject self, jstring token, jobject callback)
Java: ctx.ServiceCreate(String token, MqServiceIF callback) → C-API create a link between a ser...
JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_ServiceIsTransaction(JNIEnv *env, jobject self)
Java: boolean ctx.ServiceIsTransaction() → C-API check if the ongoing-service-call belongs to a...
#define MqSlaveGet(...)
static bool MqSlaveIs(MQ_CTXN const ctx)
is the context a slave-context ? …
#define MqSlaveGetProxy(...)
#define MqSlaveCreate(...)
static bool MqSlaveCheck(MQ_CTXN const ctx, MQ_SLAVE_ID const id)
check if slave-id is valid
#define MqSlaveGetFilter(...)
static MQ_CTX MqSlaveGetMaster(MQ_CTX const ctx)
opposite function of MqSlaveGetFilter
#define MqSlaveDelete(...)
#define MqSlaveWorker(...)
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SlaveDelete(JNIEnv *env, jobject self, jint id)
Java: ctx.SlaveDelete(int id) → C-API Delete a slave object from a master/slave link identified...
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_SlaveGetMaster(JNIEnv *env, jobject self)
Java: MqContextC ctx.SlaveGetMaster() → C-API opposite function of MqSlaveGetFilter
JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_SlaveCheck(JNIEnv *env, jobject self, jint id)
Java: boolean ctx.SlaveCheck(int id) → C-API check if slave-id is valid
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_SlaveGet(JNIEnv *env, jobject self, jint id)
Java: MqContextC ctx.SlaveGet(int id) → C-API get the slave-context from a master-context …
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_SlaveGetFilter(JNIEnv *env, jobject self)
Java: MqContextC ctx.SlaveGetFilter() → C-API get the filter-ctx or the master-ctx …
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SlaveCreate(JNIEnv *env, jobject self, jint id, jobject slave)
Java: ctx.SlaveCreate(int id, MqContextC slave) → C-API create a master/slave link between the ...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SlaveWorker(JNIEnv *env, jobject self, jint id, jstring fct, jobject args)
Java: ctx.SlaveWorker(int id, ?String fct = "WORKER"?, ?MkBufferListC args = null?...
JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_SlaveIs(JNIEnv *env, jobject self)
Java: boolean ctx.SlaveIs() → C-API is the context a slave-context ? …
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_SlaveGetProxy(JNIEnv *env, jobject self, jint id)
Java: MqContextC ctx.SlaveGetProxy(int id) → C-API on slave return the master and on master ret...
#define MqStorageIncrRef(...)
#define MqStorageResolve(...)
#define MqStorageLog(...)
#define MqStorageExport(...)
#define MqStorageDecrRef(...)
#define MqStorageClose(...)
#define MqStorageOpen(...)
#define MqStorageImport(...)
#define MqStorageCount(...)
#define MqStorageDelete(...)
#define MqStorageErrCnt(...)
JNIEXPORT jobjectArray JNICALL Java_jvmqmsgque_MqContextC_StorageResolve(JNIEnv *env, jobject self)
Java: {otherCtxP:MqContextC otherLIdP:int} ctx.StorageResolve() → C-API extract the context->li...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_StorageIncrRef(JNIEnv *env, jobject self, jint transLId)
Java: ctx.StorageIncrRef(int transLId) → C-API increase the internal refCount lock of the datab...
JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_StorageCount(JNIEnv *env, jobject self)
Java: int ctx.StorageCount() → C-API count the number of storage-rows …
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_StorageOpen(JNIEnv *env, jobject self, jstring storageFile)
Java: ctx.StorageOpen(String storageFile) → C-API switch to a file-based-transaction-database …
JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_StorageErrCnt(JNIEnv *env, jobject self, jint transLId)
Java: int ctx.StorageErrCnt(int transLId) → C-API increment and return the database row-error-c...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_StorageLog(JNIEnv *env, jobject self, jstring callfunc)
Java: ctx.StorageLog(?String callfunc = null?) → C-API log the storage the status of the open t...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_StorageDecrRef(JNIEnv *env, jobject self, jint transLId)
Java: ctx.StorageDecrRef(int transLId) → C-API decrease the internal refCount lock of the datab...
JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_StorageImport(JNIEnv *env, jobject self, jint transLIdP_inout)
Java: int ctx.StorageImport(?int transLIdP_inout = 0?) → C-API import the storage-package into ...
JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_StorageClose(JNIEnv *env, jobject self)
Java: ctx.StorageClose() → C-API close the storage. …
JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_StorageDelete(JNIEnv *env, jobject self, jint transLIdP_inout)
Java: int ctx.StorageDelete(?int transLIdP_inout = 0?) → C-API delete the storage-row identifie...
JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_StorageExport(JNIEnv *env, jobject self)
Java: int ctx.StorageExport() → C-API export the read-data-package into the STORAGE …
#define MqContextCreate(...)
JNIEXPORT jlong JNICALL Java_jvmqmsgque_MqContextC_CTOR(JNIEnv *env, jclass class, jobject tmpl)
Java: [constructor,static] MqContextC MqContextC.Create(?MqContextC tmpl = null?) → C-API create...
JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_Create(JNIEnv *env, jclass class, jobject tmpl)
Java: [constructor,static] MqContextC MqContextC.Create(?MqContextC tmpl = null?) → C-API create...
struct MqDumpS * MQ_DMP
class-shortcut for struct MqDumpS *, all shortcut using the XX_YYY syntax (only for public API) …
struct MqFactoryS * MQ_FCT
class-shortcut for struct MqFactoryS *, all shortcut using the XX_YYY syntax (only for public API) …
MqWaitOnEventE
wait for an event? …
MqIdentE
identify the application using prefix (default) or factory …
MqStartE
User preferences on HOWTO start a new entity.
MqStatusIsEF
Information about how the context was created.
MK_STRN MqIdentE_ToString(enum MqIdentE value)
return the MqIdentE as string …
MK_STRN MqStartE_ToString(enum MqStartE value)
return the MqStartE as string …
int MQ_LTR
32bit longterm transaction token because PHP-32 does NOT support long long
int MQ_SOCK_HDL
#define MQ_RT_ARGS_ONLY
array of MqContextC instances
MQ_CTX * data
MK_SIZE size
MK_BINN data
MK_STRN ptr
MkSelfUnlinkF selfUnlink
MkSelfCreateF selfCreate
PUBLIC data structure for the jvmqmsgque-specific-data
MqDumpC - the class known as dmp or dump is used to export a jvmqmsgque data package as binary …
data used to define a factory