MqContextC_Proxy_JV_API

MqContextC - copy data from the read-data-package of the sourceCtx to the send-data-package of the targetCtx More...

Collaboration diagram for MqContextC_Proxy_JV_API:

Functions
native void	jvmqmsgque.MqContextC.ProxyForward (MqContextC targetCtx, MqDumpC dump, long timeout)
	Java: sourceCtx.ProxyForward(MqContextC targetCtx, ?MqDumpC dump = null?, ?long timeout = MkTimeoutE.DEFAULT.get()?) → C-API send the entire read-data-package-data to the link-target …
void	jvmqmsgque.MqContextC.ProxyForward (MqContextC targetCtx)
	Java: sourceCtx.ProxyForward(MqContextC targetCtx, ?MqDumpC dump = null?, ?long timeout = MkTimeoutE.DEFAULT.get()?) → C-API send the entire read-data-package-data to the link-target …
void	jvmqmsgque.MqContextC.ProxyForward (MqContextC targetCtx, MqDumpC dump)
	Java: sourceCtx.ProxyForward(MqContextC targetCtx, ?MqDumpC dump = null?, ?long timeout = MkTimeoutE.DEFAULT.get()?) → C-API send the entire read-data-package-data to the link-target …
native void	jvmqmsgque.MqContextC.ProxyItem (MqContextC targetCtx)
	Java: sourceCtx.ProxyItem(MqContextC targetCtx) → C-API Copy a single-data-item from the sourceCtx to the targetCtx.
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.DEFAULT.get()?) → C-API send the entire read-data-package-data to the link-target …
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 sourceCtx to the targetCtx.

Detailed Description

MqContextC - copy data from the read-data-package of the sourceCtx to the send-data-package of the targetCtx

The proxy-feature is used in a filter-setup to process-and-forward incoming data.

See also

MqDumpC

Example: A typical proxy-setup in pseudo C++ code

void myService () {
  MqContextC *ftr = SlaveGetFilter();     // get the "slave" with id "1" (the filter)
  ...
  ftr->SendSTART();                       // start the FORWARD
  while (ReadItemExists()) {              // read ALL data from the ORIGINAL service-call
    ProxyItem(ftr);                       // forward a SINGEL item from "this" to "ftr"
  }
  ...
  ftr->SendEND_AND_WAIT("MYTK");          // send the data.package to "ftr"
  ...
  SendSTART();                            // start the ANSWER
  while (ftr->ReadItemExists()) {         // read ALL data from the "MYTK" service-call
    ftr->ProxyItem(this);                 // forward a SINGEL item from "ftr" to "this"
  }
  SendRETURN();                           // answer the ORIGINAL service call
}

The proxy-feature is used in a filter-setup to process-and-forward incoming data.

See also

MqDumpC

Example: A typical proxy-setup in pseudo C++ code

void myService () {
  MqContextC *ftr = SlaveGetFilter();     // get the "slave" with id "1" (the filter)
  ...
  ftr->SendSTART();                       // start the FORWARD
  while (ReadItemExists()) {              // read ALL data from the ORIGINAL service-call
    ProxyItem(ftr);                       // forward a SINGEL item from "this" to "ftr"
  }
  ...
  ftr->SendEND_AND_WAIT("MYTK");          // send the data.package to "ftr"
  ...
  SendSTART();                            // start the ANSWER
  while (ftr->ReadItemExists()) {         // read ALL data from the "MYTK" service-call
    ftr->ProxyItem(this);                 // forward a SINGEL item from "ftr" to "this"
  }
  SendRETURN();                           // answer the ORIGINAL service call
}

Function Documentation

Java_jvmqmsgque_MqContextC_ProxyForward()

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.DEFAULT.get()?) → C-API
send the entire read-data-package-data to the link-target …

Definition at line 1243 of file MqContextC_jv.c.

                                                                                                                                            {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  MQ_CTX targetCtx_hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",targetCtx);
  JavaErrorCheck;
  MQ_DMP dump_hdl = (MQ_DMP)pObj2Hdl__null_allow(env,dump);
  JavaErrorCheck;
  enum MkErrorE errVal = MqProxyForward(hdl, targetCtx_hdl, dump_hdl, timeout);
  MkErrorC_Check(hdl, errVal)
error:
  return;
}

Java_jvmqmsgque_MqContextC_ProxyItem()

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 sourceCtx to the targetCtx.

Definition at line 1258 of file MqContextC_jv.c.

                                                                                                            {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  MQ_CTX targetCtx_hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",targetCtx);
  JavaErrorCheck;
  enum MkErrorE errVal = MqProxyItem(hdl, targetCtx_hdl);
  MkErrorC_Check(hdl, errVal)
error:
  return;
}

ProxyForward() [1/3]

void jvmqmsgque.MqContextC.ProxyForward

(

MqContextC

targetCtx

)

Java: sourceCtx.ProxyForward(MqContextC targetCtx, ?MqDumpC dump = null?, ?long timeout = MkTimeoutE.DEFAULT.get()?) → C-API
send the entire read-data-package-data to the link-target …

Definition at line 628 of file MqContextC.java.

                                                  {
    ProxyForward (targetCtx, (MqDumpC) null, MkTimeoutE.DEFAULT.get());
  }

ProxyForward() [2/3]

void jvmqmsgque.MqContextC.ProxyForward	(	MqContextC	targetCtx,
		MqDumpC	dump )

Java: sourceCtx.ProxyForward(MqContextC targetCtx, ?MqDumpC dump = null?, ?long timeout = MkTimeoutE.DEFAULT.get()?) → C-API
send the entire read-data-package-data to the link-target …

Definition at line 633 of file MqContextC.java.

                                                                {
    ProxyForward (targetCtx, dump, MkTimeoutE.DEFAULT.get());
  }

ProxyForward() [3/3]

native void jvmqmsgque.MqContextC.ProxyForward	(	MqContextC	targetCtx,
		MqDumpC	dump,
		long	timeout )

Java: sourceCtx.ProxyForward(MqContextC targetCtx, ?MqDumpC dump = null?, ?long timeout = MkTimeoutE.DEFAULT.get()?) → C-API
send the entire read-data-package-data to the link-target …

Here is the caller graph for this function:

ProxyItem()

native void jvmqmsgque.MqContextC.ProxyItem

(

MqContextC

targetCtx

)

Java: sourceCtx.ProxyItem(MqContextC targetCtx) → C-API
Copy a single-data-item from the sourceCtx to the targetCtx.