org.apache.qpid.proton.amqp.Binary.create()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(1.7k)|赞(0)|评价(0)|浏览(140)

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

Binary.create介绍

暂无

代码示例

代码示例来源:origin: Azure/azure-event-hubs-java

  1. public EventDataImpl(ByteBuffer buffer) {
  2. this();
  3. if (buffer == null) {
  4. throw new IllegalArgumentException("data cannot be null");
  5. }
  6. this.bodyData = Binary.create(buffer);
  7. }

代码示例来源:origin: org.apache.qpid/proton-j-impl

  1. TransportFrame frame = new TransportFrame(channel, (FrameBody) frameBody, Binary.create(originalPayload));
  2. TransportImpl.log(_logCtx, TransportImpl.OUTGOING, frame);

代码示例来源:origin: com.microsoft.azure.iot/proton-j-azure-iot

  1. Binary payloadBin = Binary.create(originalPayload);
  2. FrameBody body = null;
  3. if (frameBody == null)

代码示例来源:origin: org.apache.qpid/proton

  1. _protocolTracer.sentFrame(new TransportFrame(channel, (FrameBody) frameBody, Binary.create(originalPayload)));

代码示例来源:origin: org.apache.qpid/proton-j

  1. private void logFrame(int channel, Object frameBody, ReadableBuffer payload, int payloadSize) {
  2. if (frameType == AMQP_FRAME_TYPE) {
  3. ReadableBuffer originalPayload = null;
  4. if (payload != null) {
  5. originalPayload = payload.slice();
  6. originalPayload.limit(payloadSize);
  7. }
  8. Binary payloadBin = Binary.create(originalPayload);
  9. FrameBody body = null;
  10. if (frameBody == null) {
  11. body = EmptyFrame.INSTANCE;
  12. } else {
  13. body = (FrameBody) frameBody;
  14. }
  15. TransportFrame frame = new TransportFrame(channel, body, payloadBin);
  16. transport.log(TransportImpl.OUTGOING, frame);
  17. ProtocolTracer tracer = transport.getProtocolTracer();
  18. if (tracer != null) {
  19. tracer.sentFrame(frame);
  20. }
  21. }
  22. }
  23. }

代码示例来源:origin: apache/activemq-artemis

  1. String value = message.getStringProperty(key);
  2. if (value != null) {
  3. properties.setUserId(Binary.create(StandardCharsets.UTF_8.encode(value)));

相关文章