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

WritableBuffer.put介绍

暂无

代码示例

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

private int processHeader(WritableBuffer buffer)
{
  if(!_headerWritten)
  {
    buffer.put(HEADER, 0, HEADER.length);
    _headerWritten = true;
    return HEADER.length;
  }
  else
  {
    return 0;
  }
}

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

private void endFrame(int channel)
{
  int frameSize = _buffer.position() - _frameStart;
  int limit = _buffer.position();
  _buffer.position(_frameStart);
  _buffer.putInt(frameSize);
  _buffer.put((byte) 2);
  _buffer.put(_frameType);
  _buffer.putShort((short) channel);
  _buffer.position(limit);
}

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

@Override
public void writeBoolean(final boolean bool)
{
  if (bool)
  {
    _buffer.put(EncodingCodes.BOOLEAN_TRUE);
  }
  else
  {
    _buffer.put(EncodingCodes.BOOLEAN_FALSE);
  }
}

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

@Override
public ReadableBuffer get(WritableBuffer target) {
  target.put(buffer);
  return this;
}

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

@Override
public void writeNull()
{
  _buffer.put(EncodingCodes.NULL);
}

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

@Override
public void put(byte b)
{
  (_first.hasRemaining() ? _first : _second).put(b);
}

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

@Override
public ReadableBuffer get(WritableBuffer target) {
 int start = target.position();
 if (buffer.hasArray()) {
   target.put(buffer.array(), buffer.arrayOffset() + buffer.readerIndex(), buffer.readableBytes());
 } else {
   target.put(buffer.nioBuffer());
 }
 int written = target.position() - start;
 buffer.readerIndex(buffer.readerIndex() + written);
 return this;
}

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

@Override
public ReadableBuffer get(WritableBuffer target) {
  int start = target.position();
  if (buffer.hasArray()) {
    target.put(buffer.array(), buffer.arrayOffset() + buffer.readerIndex(), buffer.readableBytes());
  } else {
    target.put(buffer.nioBuffer());
  }
  int written = target.position() - start;
  buffer.readerIndex(buffer.readerIndex() + written);
  return this;
}

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

@Override
public ReadableBuffer get(WritableBuffer target) {
 int start = target.position();
 if (buffer.hasArray()) {
   target.put(buffer.array(), buffer.arrayOffset() + buffer.readerIndex(), buffer.readableBytes());
 } else {
   target.put(buffer.nioBuffer());
 }
 int written = target.position() - start;
 buffer.readerIndex(buffer.readerIndex() + written);
 return this;
}

代码示例来源：origin: io.vertx/vertx-proton

@Override
public ReadableBuffer get(WritableBuffer target) {
 int start = target.position();
 if (buffer.hasArray()) {
  target.put(buffer.array(), buffer.arrayOffset() + buffer.readerIndex(), buffer.readableBytes());
 } else {
  target.put(buffer.nioBuffer());
 }
 int written = target.position() - start;
 buffer.readerIndex(buffer.readerIndex() + written);
 return this;
}

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

@Override
public void write(Data data) {
  WritableBuffer buffer = getEncoder().getBuffer();
  buffer.put(EncodingCodes.DESCRIBED_TYPE_INDICATOR);
  buffer.put(EncodingCodes.SMALLULONG);
  buffer.put(DESCRIPTOR_CODE);
  getEncoder().writeBinary(data.getValue());
}

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

@Override
public void write(AmqpValue value) {
  WritableBuffer buffer = getEncoder().getBuffer();
  buffer.put(EncodingCodes.DESCRIBED_TYPE_INDICATOR);
  buffer.put(EncodingCodes.SMALLULONG);
  buffer.put(DESCRIPTOR_CODE);
  getEncoder().writeObject(value.getValue());
}

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

@Override
public void write(AmqpSequence sequence) {
  WritableBuffer buffer = getEncoder().getBuffer();
  buffer.put(EncodingCodes.DESCRIBED_TYPE_INDICATOR);
  buffer.put(EncodingCodes.SMALLULONG);
  buffer.put(DESCRIPTOR_CODE);
  getEncoder().writeObject(sequence.getValue());
}

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

@Override
public void write(Accepted accepted) {
  WritableBuffer buffer = getEncoder().getBuffer();
  buffer.put(ACCEPTED_ENCODED_BYTES, 0, ACCEPTED_ENCODED_BYTES.length);
}

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

@Override
public void write(Footer val) {
  WritableBuffer buffer = getEncoder().getBuffer();
  buffer.put(EncodingCodes.DESCRIBED_TYPE_INDICATOR);
  buffer.put(EncodingCodes.SMALLULONG);
  buffer.put(DESCRIPTOR_CODE);
  MapType mapType = (MapType) getEncoder().getType(val.getValue());
  mapType.write(val.getValue());
}

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

@Override
public void write(DeliveryAnnotations val) {
  WritableBuffer buffer = getEncoder().getBuffer();
  buffer.put(EncodingCodes.DESCRIBED_TYPE_INDICATOR);
  buffer.put(EncodingCodes.SMALLULONG);
  buffer.put(DESCRIPTOR_CODE);
  MapType mapType = (MapType) getEncoder().getType(val.getValue());
  mapType.setKeyEncoding(symbolType);
  mapType.write(val.getValue());
  mapType.setKeyEncoding(null);
}

代码示例来源：origin: org.apache.activemq/activemq-all

@Override
  public void writeSize(UTF8Buffer value) {
    getEncoder().getBuffer().put((byte) value.getLength());
  }
}

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

@Override
public void write(MessageAnnotations val) {
  WritableBuffer buffer = getEncoder().getBuffer();
  buffer.put(EncodingCodes.DESCRIBED_TYPE_INDICATOR);
  buffer.put(EncodingCodes.SMALLULONG);
  buffer.put(DESCRIPTOR_CODE);
  MapType mapType = (MapType) getEncoder().getType(val.getValue());
  mapType.setKeyEncoding(symbolType);
  mapType.write(val.getValue());
  mapType.setKeyEncoding(null);
}

代码示例来源：origin: org.apache.activemq/activemq-osgi

@Override
  public void writeSize(UTF8Buffer value) {
    getEncoder().getBuffer().put((byte) value.getLength());
  }
}

代码示例来源：origin: org.apache.activemq/activemq-all

@Override
public void writeValue(UTF8Buffer value) {
  writeSize(value);
  WritableBuffer buffer = getEncoder().getBuffer();
  buffer.put(value.getData(), value.getOffset(), value.getLength());
}