gpt4 book ai didi

org.zeromq.zmq_msg_t类的使用及代码示例

转载 作者:知者 更新时间:2024-03-17 10:23:31 27 4
gpt4 key购买 nike

本文整理了Java中org.zeromq.zmq_msg_t类的一些代码示例,展示了zmq_msg_t类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。zmq_msg_t类的具体详情如下:
包路径:org.zeromq.zmq_msg_t
类名称:zmq_msg_t

zmq_msg_t介绍

暂无

代码示例

代码示例来源:origin: org.zeromq/zeromq-scala-binding_2.10

private zmq_msg_t newZmqMessage() {
 zmq_msg_t message = new zmq_msg_t();
 if (zmq.zmq_msg_init(message) != 0)
  raiseZMQException();
 return message;
}

代码示例来源:origin: org.spark-project.zeromq/zeromq-scala-binding_2.10

private zmq_msg_t newZmqMessage() {
 zmq_msg_t message = new zmq_msg_t();
 if (zmq.zmq_msg_init(message) != 0)
  raiseZMQException();
 return message;
}

代码示例来源:origin: org.zeromq/zeromq-scala-binding

private zmq_msg_t newZmqMessage() {
 zmq_msg_t message = new zmq_msg_t();
 if (zmq.zmq_msg_init(message) != 0)
  raiseZMQException();
 return message;
}

代码示例来源:origin: org.spark-project.zeromq/zeromq-scala-binding

private zmq_msg_t newZmqMessage() {
 zmq_msg_t message = new zmq_msg_t();
 if (zmq.zmq_msg_init(message) != 0)
  raiseZMQException();
 return message;
}

代码示例来源:origin: org.zeromq/zeromq-scala-binding_2.10

private zmq_msg_t newZmqMessage(byte[] msg) {
 zmq_msg_t message = new zmq_msg_t();
 if (msg.length == 0) {
  if (zmq.zmq_msg_init_size(message, new NativeLong(msg.length)) != 0) {
   raiseZMQException();
  }
 } else {
  Memory mem = new Memory(msg.length);
  mem.write(0, msg, 0, msg.length);
  if (zmq.zmq_msg_init_data(message, mem, new NativeLong(msg.length), messageDataBuffer, mem) == 0) {
   messageDataBuffer.add(mem);
  } else {
   raiseZMQException();
  }
 }
 return message;
}

代码示例来源:origin: org.spark-project.zeromq/zeromq-scala-binding

private zmq_msg_t newZmqMessage(byte[] msg) {
 zmq_msg_t message = new zmq_msg_t();
 if (msg.length == 0) {
  if (zmq.zmq_msg_init_size(message, new NativeLong(msg.length)) != 0) {
   raiseZMQException();
  }
 } else {
  Memory mem = new Memory(msg.length);
  mem.write(0, msg, 0, msg.length);
  if (zmq.zmq_msg_init_data(message, mem, new NativeLong(msg.length), messageDataBuffer, mem) == 0) {
   messageDataBuffer.add(mem);
  } else {
   raiseZMQException();
  }
 }
 return message;
}

代码示例来源:origin: org.zeromq/zeromq-scala-binding

private zmq_msg_t newZmqMessage(byte[] msg) {
 zmq_msg_t message = new zmq_msg_t();
 if (msg.length == 0) {
  if (zmq.zmq_msg_init_size(message, new NativeLong(msg.length)) != 0) {
   raiseZMQException();
  }
 } else {
  Memory mem = new Memory(msg.length);
  mem.write(0, msg, 0, msg.length);
  if (zmq.zmq_msg_init_data(message, mem, new NativeLong(msg.length), messageDataBuffer, mem) == 0) {
   messageDataBuffer.add(mem);
  } else {
   raiseZMQException();
  }
 }
 return message;
}

代码示例来源:origin: org.spark-project.zeromq/zeromq-scala-binding_2.10

private zmq_msg_t newZmqMessage(byte[] msg) {
 zmq_msg_t message = new zmq_msg_t();
 if (msg.length == 0) {
  if (zmq.zmq_msg_init_size(message, new NativeLong(msg.length)) != 0) {
   raiseZMQException();
  }
 } else {
  Memory mem = new Memory(msg.length);
  mem.write(0, msg, 0, msg.length);
  if (zmq.zmq_msg_init_data(message, mem, new NativeLong(msg.length), messageDataBuffer, mem) == 0) {
   messageDataBuffer.add(mem);
  } else {
   raiseZMQException();
  }
 }
 return message;
}

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com