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

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

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

Binary.getLength介绍

暂无

代码示例

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

  1. @Override
  2. public BinaryEncoding getEncoding(final Binary val)
  3. {
  4. return val.getLength() <= 255 ? _shortBinaryEncoding : _binaryEncoding;
  5. }

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

  1. @Override
  2. protected int getEncodedValueSize(final Binary val)
  3. {
  4. return val.getLength();
  5. }

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

  1. @Override
  2. protected int getEncodedValueSize(final Binary val)
  3. {
  4. return val.getLength();
  5. }

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

  1. @Override
  2. protected int getEncodedValueSize(final Binary val)
  3. {
  4. return val.getLength();
  5. }

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

  1. @Override
  2. protected int getEncodedValueSize(final Binary val)
  3. {
  4. return val.getLength();
  5. }

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

  1. BinaryElement(Element parent, Element prev, Binary b)
  2. {
  3. super(parent, prev);
  4. byte[] data = new byte[b.getLength()];
  5. System.arraycopy(b.getArray(),b.getArrayOffset(),data,0,b.getLength());
  6. _value = new Binary(data);
  7. }

代码示例来源:origin: org.apache.qpid/qpid-jms-client

  1. @Override
  2. public byte[] copyBody() {
  3. Binary content = getBinaryFromBody();
  4. byte[] result = new byte[content.getLength()];
  5. System.arraycopy(content.getArray(), content.getArrayOffset(), result, 0, content.getLength());
  6. return result;
  7. }

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

  1. BinaryElement(Element parent, Element prev, Binary b)
  2. {
  3. super(parent, prev);
  4. byte[] data = new byte[b.getLength()];
  5. System.arraycopy(b.getArray(),b.getArrayOffset(),data,0,b.getLength());
  6. _value = new Binary(data);
  7. }

代码示例来源:origin: org.apache.qpid/qpid-jms-client

  1. @Override
  2. public Object get(String key) {
  3. Object value = messageBodyMap.get(key);
  4. if (value instanceof Binary) {
  5. // Copy to a byte[], ensure we copy only the required portion.
  6. Binary bin = ((Binary) value);
  7. value = Arrays.copyOfRange(bin.getArray(), bin.getArrayOffset(), bin.getLength());
  8. }
  9. return value;
  10. }

代码示例来源:origin: org.apache.qpid/qpid-jms-client

  1. @Override
  2. public String getUserId() {
  3. String userId = null;
  4. if (properties != null && properties.getUserId() != null) {
  5. Binary userIdBytes = properties.getUserId();
  6. if (userIdBytes.getLength() != 0) {
  7. userId = new String(userIdBytes.getArray(), userIdBytes.getArrayOffset(), userIdBytes.getLength(), StandardCharsets.UTF_8);
  8. }
  9. }
  10. return userId;
  11. }

代码示例来源:origin: org.apache.qpid/qpid-jms-client

  1. @Override
  2. public boolean hasBody() {
  3. if (bytesOut != null) {
  4. return bytesOut.writtenBytes() > 0;
  5. } else {
  6. return getBinaryFromBody().getLength() != 0;
  7. }
  8. }

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

  1. @Override
  2. protected void writeEncodedValue(final Binary val)
  3. {
  4. getEncoder().getBuffer().ensureRemaining(val.getLength());
  5. getEncoder().writeRaw(val.getArray(), val.getArrayOffset(), val.getLength());
  6. }

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

  1. @Override
  2. protected void writeEncodedValue(final Binary val)
  3. {
  4. getEncoder().getBuffer().ensureRemaining(val.getLength());
  5. getEncoder().writeRaw(val.getArray(), val.getArrayOffset(), val.getLength());
  6. }

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

  1. @Override
  2. protected void writeEncodedValue(final Binary val)
  3. {
  4. getEncoder().writeRaw(val.getArray(), val.getArrayOffset(), val.getLength());
  5. }

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

  1. @Override
  2. protected void writeEncodedValue(final Binary val)
  3. {
  4. getEncoder().writeRaw(val.getArray(), val.getArrayOffset(), val.getLength());
  5. }

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

  1. @Override
  2. protected void writeEncodedValue(final Binary val)
  3. {
  4. getEncoder().writeRaw(val.getArray(), val.getArrayOffset(), val.getLength());
  5. }

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

  1. @Override
  2. protected void writeEncodedValue(final Binary val)
  3. {
  4. getEncoder().writeRaw(val.getArray(), val.getArrayOffset(), val.getLength());
  5. }

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

  1. @Override
  2. public void encode() throws Exception {
  3. super.encode();
  4. getInnerMessage().getBodyBuffer().writeInt(payload.getLength());
  5. getInnerMessage().getBodyBuffer().writeBytes(payload.getArray(), payload.getArrayOffset(), payload.getLength());
  6. }

代码示例来源:origin: org.apache.activemq/artemis-amqp-protocol

  1. @Override
  2. public void encode() throws Exception {
  3. super.encode();
  4. getInnerMessage().getBodyBuffer().writeInt(payload.getLength());
  5. getInnerMessage().getBodyBuffer().writeBytes(payload.getArray(), payload.getArrayOffset(), payload.getLength());
  6. }

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

  1. /**
  2. * Converts a Binary value to a long assuming that the contained value is
  3. * stored in Big Endian encoding.
  4. *
  5. * @param value the Binary object whose payload is converted to a long.
  6. * @return a long value constructed from the bytes of the Binary instance.
  7. */
  8. public static long toLong(Binary value) {
  9. Buffer buffer = new Buffer(value.getArray(), value.getArrayOffset(), value.getLength());
  10. return buffer.bigEndianEditor().readLong();
  11. }

相关文章