* Signature: (JIILjava/lang/String;Ljava/lang/String;ILorg/ocera/orte/types/MessageData;Lorg/ocera/orte/types/NtpTime;Lorg/ocera/orte/types/NtpTime;Lorg/ocera/orte/SubscriptionCallback;J)J
*/
JNIEXPORT jlong JNICALL Java_org_ocera_orte_Subscription_jORTESubscriptionCreate
- (JNIEnv *, jobject, jlong, jint, jint, jstring, jstring, jobject, jobject, jobject, jobject, jobject, jlong);
+ (JNIEnv *, jobject, jlong, jint, jint, jstring, jstring, jobject, jint, jobject, jobject, jobject, jobject, jlong);
/*
* Class: org_ocera_orte_Subscription
package org.ocera.orte;
import java.nio.ByteBuffer;
+import java.nio.ByteOrder;
import org.ocera.orte.types.*;
PublProp publProp,
MessageData instance)
{
+ instance.getBuffer().order(ByteOrder.nativeOrder());
this.handle = jORTEPublicationCreate(d.handle,
publProp.getTopic(),
publProp.getTypeName(),
package org.ocera.orte;
import java.nio.ByteBuffer;
+import java.nio.ByteOrder;
import org.ocera.orte.types.*;
subsProp.getTopic(),
subsProp.getTypeName(),
message.getBuffer(),
+ message.getBuffer().order().equals(ByteOrder.BIG_ENDIAN) ? 0 : 1,
message,
subsProp.getDeadline(),
subsProp.getMinSeparation(),
String topic,
String typeName,
ByteBuffer buffer,
+ int byte_order,
MessageData message,
NtpTime deadline,
NtpTime minSeparation,
jstring jtopic, // subs topic
jstring jtname, // subs typeName
jobject jinstance, // direct ByteBuffer
+ jint jbyteOrder,// byte order of ByteBuffer
jobject obj_msg, // messageData instance
jobject jdeadline,
jobject jminSeparation,
#endif
}
callback_cont->jvm = jvm;
- callback_cont->cur_endian = FLAG_ENDIANNESS;
+ callback_cont->cur_endian = (CDR_Endianness) jbyteOrder;
// create global references
callback_cont->obj = (*env)->NewGlobalRef(env, obj_callback);
//