Modifier and Type | Method and Description |
---|---|
Object |
SymbolTypeConstructor.construct(QpidByteBuffer in,
boolean isCopy,
ValueHandler handler) |
abstract Object |
VariableWidthTypeConstructor.construct(QpidByteBuffer in,
boolean isCopy,
ValueHandler handler) |
Object |
BinaryTypeConstructor.construct(QpidByteBuffer in,
boolean isCopy,
ValueHandler handler) |
Object |
CompoundTypeConstructor.construct(QpidByteBuffer in,
boolean isCopy,
ValueHandler delegate) |
Object |
StringTypeConstructor.construct(QpidByteBuffer in,
boolean isCopy,
ValueHandler handler) |
Object |
CharTypeConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
T |
TypeConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object |
DoubleTypeConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object |
UUIDTypeConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object |
VariableWidthTypeConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object |
SmallLongConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object |
LongTypeConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object |
IntTypeConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object |
ByteTypeConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object[] |
ArrayTypeConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object |
UIntTypeConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object |
ULongTypeConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object |
SmallULongConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object |
ShortTypeConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object |
UByteTypeConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object |
SmallUIntConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object |
SmallIntConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object |
UShortTypeConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object |
TimestampTypeConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
Object |
FloatTypeConstructor.construct(QpidByteBuffer in,
ValueHandler handler) |
ProtocolHandler |
ProtocolHeaderHandler.parse(QpidByteBuffer in) |
Object |
ValueHandler.parse(QpidByteBuffer in) |
ProtocolHandler |
ProtocolHandler.parse(QpidByteBuffer in) |
TypeConstructor |
ValueHandler.readConstructor(QpidByteBuffer in) |
protected void |
SymbolArrayWriter.writeBytes(QpidByteBuffer buf,
int offset,
int length) |
protected void |
SimpleVariableWidthWriter.writeBytes(QpidByteBuffer buf,
int offset,
int length) |
protected abstract void |
VariableWidthWriter.writeBytes(QpidByteBuffer buf,
int offset,
int length) |
protected void |
SymbolWriter.writeBytes(QpidByteBuffer buf,
int offset,
int length) |
int |
FixedEightWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
FrameWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
UnsignedByteWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
FixedTwoWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
AbstractDescribedTypeWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
CompoundWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
DelegatingValueWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
FixedFourWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
UnsignedLongWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
BooleanWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
IntegerWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
UnsignedIntegerWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
LongWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
ValueWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
ArrayWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
ListWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
ListWriter.EmptyListValueWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
NullWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
FixedOneWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
ByteWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
VariableWidthWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
FixedSixteenWriter.writeToBuffer(QpidByteBuffer buffer) |
int |
CompoundWriter.writeToBuffer(QpidByteBuffer buffer,
boolean large) |
Modifier and Type | Method and Description |
---|---|
QpidByteBuffer |
AMQFrame.getPayload() |
Modifier and Type | Method and Description |
---|---|
static TransportFrame |
AMQFrame.createAMQFrame(short channel,
FrameBody frameBody,
QpidByteBuffer payload) |
ProtocolHandler |
SASLProtocolHeaderHandler.parse(QpidByteBuffer in) |
ProtocolHandler |
SASLFrameHandler.parse(QpidByteBuffer in) |
ProtocolHandler |
FrameHandler.parse(QpidByteBuffer in) |
ProtocolHandler |
AMQPProtocolHeaderHandler.parse(QpidByteBuffer in) |
Constructor and Description |
---|
AMQFrame(T frameBody,
QpidByteBuffer payload) |
TransportFrame(short channel,
FrameBody frameBody,
QpidByteBuffer payload) |
Modifier and Type | Method and Description |
---|---|
List<Section> |
SectionDecoderImpl.parseAll(QpidByteBuffer buf) |
List<Section> |
SectionDecoder.parseAll(QpidByteBuffer buf) |
Section |
SectionDecoderImpl.readSection(QpidByteBuffer buf) |
Section |
SectionDecoder.readSection(QpidByteBuffer buf) |
Modifier and Type | Method and Description |
---|---|
int |
ConnectionEndpoint.send(short channel,
FrameBody body,
QpidByteBuffer payload) |
Modifier and Type | Method and Description |
---|---|
QpidByteBuffer |
Transfer.getPayload() |
Modifier and Type | Method and Description |
---|---|
void |
Transfer.setPayload(QpidByteBuffer payload) |
Modifier and Type | Method and Description |
---|---|
static QpidByteBuffer |
QpidByteBuffer.allocate(int size) |
static QpidByteBuffer |
QpidByteBuffer.allocateDirect(int size) |
QpidByteBuffer |
QpidByteBuffer.asReadOnlyBuffer() |
QpidByteBuffer |
QpidByteBuffer.clear() |
QpidByteBuffer |
QpidByteBuffer.compact() |
QpidByteBuffer |
QpidByteBuffer.duplicate() |
QpidByteBuffer |
QpidByteBuffer.flip() |
QpidByteBuffer |
QpidByteBuffer.get(byte[] dst) |
QpidByteBuffer |
QpidByteBuffer.get(byte[] dst,
int offset,
int length) |
QpidByteBuffer |
QpidByteBuffer.get(ByteBuffer dst) |
QpidByteBuffer |
QpidByteBuffer.limit(int newLimit) |
QpidByteBuffer |
QpidByteBuffer.mark() |
QpidByteBuffer |
QpidByteBuffer.position(int newPosition) |
QpidByteBuffer |
QpidByteBuffer.put(byte b) |
QpidByteBuffer |
QpidByteBuffer.put(byte[] src) |
QpidByteBuffer |
QpidByteBuffer.put(byte[] src,
int offset,
int length) |
QpidByteBuffer |
QpidByteBuffer.put(ByteBuffer src) |
QpidByteBuffer |
QpidByteBuffer.put(int index,
byte b) |
QpidByteBuffer |
QpidByteBuffer.put(QpidByteBuffer src) |
QpidByteBuffer |
QpidByteBuffer.putChar(char value) |
QpidByteBuffer |
QpidByteBuffer.putChar(int index,
char value) |
QpidByteBuffer |
QpidByteBuffer.putDouble(double value) |
QpidByteBuffer |
QpidByteBuffer.putDouble(int index,
double value) |
QpidByteBuffer |
QpidByteBuffer.putFloat(float value) |
QpidByteBuffer |
QpidByteBuffer.putFloat(int index,
float value) |
QpidByteBuffer |
QpidByteBuffer.putInt(int value) |
QpidByteBuffer |
QpidByteBuffer.putInt(int index,
int value) |
QpidByteBuffer |
QpidByteBuffer.putLong(int index,
long value) |
QpidByteBuffer |
QpidByteBuffer.putLong(long value) |
QpidByteBuffer |
QpidByteBuffer.putShort(int index,
short value) |
QpidByteBuffer |
QpidByteBuffer.putShort(short value) |
QpidByteBuffer |
QpidByteBuffer.reset() |
QpidByteBuffer |
QpidByteBuffer.rewind() |
QpidByteBuffer |
QpidByteBuffer.slice() |
QpidByteBuffer |
QpidByteBuffer.view(int offset,
int length) |
static QpidByteBuffer |
QpidByteBuffer.wrap(byte[] data) |
static QpidByteBuffer |
QpidByteBuffer.wrap(byte[] data,
int offset,
int length) |
static QpidByteBuffer |
QpidByteBuffer.wrap(ByteBuffer wrap) |
Modifier and Type | Method and Description |
---|---|
static Collection<QpidByteBuffer> |
QpidByteBuffer.allocateDirectCollection(int size) |
static Collection<QpidByteBuffer> |
QpidByteBuffer.deflate(Collection<QpidByteBuffer> uncompressedBuffers) |
Collection<QpidByteBuffer> |
QpidByteBufferOutputStream.fetchAccumulatedBuffers() |
static Collection<QpidByteBuffer> |
QpidByteBuffer.inflate(Collection<QpidByteBuffer> compressedBuffers) |
Modifier and Type | Method and Description |
---|---|
SSLEngineResult |
QpidByteBuffer.decryptSSL(SSLEngine engine,
QpidByteBuffer dest) |
static SSLEngineResult |
QpidByteBuffer.encryptSSL(SSLEngine engine,
Collection<QpidByteBuffer> buffers,
QpidByteBuffer dest) |
QpidByteBuffer |
QpidByteBuffer.put(QpidByteBuffer src) |
void |
QpidByteBuffer.putCopyOf(QpidByteBuffer buf) |
Modifier and Type | Method and Description |
---|---|
static Collection<QpidByteBuffer> |
QpidByteBuffer.deflate(Collection<QpidByteBuffer> uncompressedBuffers) |
static SSLEngineResult |
QpidByteBuffer.encryptSSL(SSLEngine engine,
Collection<QpidByteBuffer> buffers,
QpidByteBuffer dest) |
static Collection<QpidByteBuffer> |
QpidByteBuffer.inflate(Collection<QpidByteBuffer> compressedBuffers) |
static long |
QpidByteBuffer.write(GatheringByteChannel channel,
Collection<QpidByteBuffer> buffers) |
Modifier and Type | Method and Description |
---|---|
protected AbstractJMSMessage |
AbstractJMSMessageFactory.create010MessageWithBody(long messageNbr,
MessageProperties msgProps,
DeliveryProperties deliveryProps,
Collection<QpidByteBuffer> body) |
AbstractJMSMessage |
AbstractJMSMessageFactory.createMessage(long messageNbr,
boolean redelivered,
MessageProperties msgProps,
DeliveryProperties deliveryProps,
Collection<QpidByteBuffer> body) |
Modifier and Type | Method and Description |
---|---|
QpidByteBuffer |
MarkableDataInput.readAsByteBuffer(int len) |
Modifier and Type | Method and Description |
---|---|
void |
ServerDecoder.decodeBuffer(QpidByteBuffer buf) |
Modifier and Type | Method and Description |
---|---|
QpidByteBuffer |
ContentBody.getPayload() |
QpidByteBuffer |
ByteBufferListDataInput.readAsByteBuffer(int len) |
QpidByteBuffer |
ByteBufferDataInput.readAsByteBuffer(int len) |
QpidByteBuffer |
ByteArrayDataInput.readAsByteBuffer(int len) |
Modifier and Type | Method and Description |
---|---|
void |
ChannelMethodProcessor.receiveMessageContent(QpidByteBuffer data) |
long |
ContentHeaderBody.writePayload(QpidByteBuffer buf) |
long |
BasicContentHeaderProperties.writePropertyListPayload(QpidByteBuffer buffer) |
static void |
EncodingUtils.writeShortStringBytes(QpidByteBuffer buffer,
AMQShortString s) |
void |
AMQShortString.writeToBuffer(QpidByteBuffer buffer) |
static void |
EncodingUtils.writeUnsignedInteger(QpidByteBuffer buffer,
long l) |
static void |
EncodingUtils.writeUnsignedShort(QpidByteBuffer buffer,
int s) |
Constructor and Description |
---|
ContentBody(QpidByteBuffer payload) |
FieldTable(QpidByteBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
Collection<QpidByteBuffer> |
MessageContentSource.getContent() |
Collection<QpidByteBuffer> |
AbstractServerMessageImpl.getContent() |
Modifier and Type | Method and Description |
---|---|
Collection<QpidByteBuffer> |
InternalMessageMetaData.asByteBuffers() |
Modifier and Type | Method and Description |
---|---|
InternalMessageMetaData |
InternalMessageMetaDataType.createMetaData(QpidByteBuffer buf) |
int |
InternalMessageMetaData.writeToBuffer(QpidByteBuffer dest) |
Modifier and Type | Method and Description |
---|---|
M |
MessageMetaDataType.createMetaData(QpidByteBuffer buf) |
M |
MessageMetaDataType.Factory.createMetaData(QpidByteBuffer buf) |
Modifier and Type | Method and Description |
---|---|
QpidByteBuffer |
ServerFrame.getBody() |
QpidByteBuffer |
ServerEncoder.getBuffer() |
Modifier and Type | Method and Description |
---|---|
Collection<QpidByteBuffer> |
MessageMetaData_0_10.asByteBuffers() |
Collection<QpidByteBuffer> |
MessageTransferMessage.getBody() |
Modifier and Type | Method and Description |
---|---|
MessageMetaData_0_10 |
MessageMetaDataType_0_10.createMetaData(QpidByteBuffer buf) |
void |
ServerInputHandler.received(QpidByteBuffer buf) |
void |
AMQPConnection_0_10.received(QpidByteBuffer buf) |
int |
MessageMetaData_0_10.writeToBuffer(QpidByteBuffer dest) |
Constructor and Description |
---|
ServerFrame(byte flags,
SegmentType type,
byte track,
int channel,
QpidByteBuffer body) |
Modifier and Type | Method and Description |
---|---|
Collection<QpidByteBuffer> |
MessageMetaData.asByteBuffers() |
Modifier and Type | Method and Description |
---|---|
MessageMetaData |
MessageMetaDataType_0_8.createMetaData(QpidByteBuffer buf) |
void |
AMQPConnection_0_8.received(QpidByteBuffer msg) |
void |
AMQChannel.receiveMessageContent(QpidByteBuffer data) |
int |
MessageMetaData.writeToBuffer(QpidByteBuffer dest) |
Modifier and Type | Method and Description |
---|---|
Collection<QpidByteBuffer> |
MessageMetaData_1_0.asByteBuffers() |
Collection<QpidByteBuffer> |
Message_1_0.getFragments() |
Modifier and Type | Method and Description |
---|---|
MessageMetaData_1_0 |
MessageMetaDataType_1_0.createMetaData(QpidByteBuffer buf) |
void |
AMQPConnection_1_0.received(QpidByteBuffer msg) |
int |
MessageMetaData_1_0.writeToBuffer(QpidByteBuffer dest) |
Constructor and Description |
---|
MessageMetaData_1_0(QpidByteBuffer[] fragments,
SectionDecoder decoder) |
MessageMetaData_1_0(QpidByteBuffer[] fragments,
SectionDecoder decoder,
List<QpidByteBuffer> immutableSections) |
Constructor and Description |
---|
MessageMetaData_1_0(QpidByteBuffer[] fragments,
SectionDecoder decoder,
List<QpidByteBuffer> immutableSections) |
Modifier and Type | Method and Description |
---|---|
Collection<QpidByteBuffer> |
StorableMessageMetaData.asByteBuffers() |
Collection<QpidByteBuffer> |
StoredMessage.getContent() |
Collection<QpidByteBuffer> |
StoredMemoryMessage.getContent() |
Modifier and Type | Method and Description |
---|---|
void |
StoredMemoryMessage.addContent(QpidByteBuffer src) |
void |
MessageHandle.addContent(QpidByteBuffer src) |
int |
StorableMessageMetaData.writeToBuffer(QpidByteBuffer dest) |
Modifier and Type | Method and Description |
---|---|
QpidByteBuffer |
ByteBufferBinding.entryToObject(com.sleepycat.bind.tuple.TupleInput input) |
Modifier and Type | Method and Description |
---|---|
void |
ByteBufferBinding.objectToEntry(QpidByteBuffer data,
com.sleepycat.bind.tuple.TupleOutput output) |
Modifier and Type | Method and Description |
---|---|
QpidByteBuffer |
NonBlockingConnectionTLSDelegate.getNetInputBuffer() |
QpidByteBuffer |
NonBlockingConnectionPlainDelegate.getNetInputBuffer() |
QpidByteBuffer |
NonBlockingConnectionUndecidedDelegate.getNetInputBuffer() |
Modifier and Type | Method and Description |
---|---|
void |
NonBlockingConnection.processAmqpData(QpidByteBuffer applicationData) |
void |
ProtocolEngine.received(QpidByteBuffer msg) |
void |
MultiVersionProtocolEngine.received(QpidByteBuffer msg) |
void |
NonBlockingConnection.send(QpidByteBuffer msg) |
Modifier and Type | Method and Description |
---|---|
boolean |
NonBlockingConnectionTLSDelegate.doWrite(Collection<QpidByteBuffer> bufferArray) |
boolean |
NonBlockingConnectionPlainDelegate.doWrite(Collection<QpidByteBuffer> bufferArray) |
boolean |
NonBlockingConnectionUndecidedDelegate.doWrite(Collection<QpidByteBuffer> buffers) |
Modifier and Type | Method and Description |
---|---|
QpidByteBuffer |
ProtocolHeader.toByteBuffer() |
Modifier and Type | Method and Description |
---|---|
Collection<QpidByteBuffer> |
MessageTransfer.getBody() |
Collection<QpidByteBuffer> |
Method.getBody() |
Modifier and Type | Method and Description |
---|---|
void |
ByteBufferSender.send(QpidByteBuffer msg) |
Modifier and Type | Method and Description |
---|---|
MessageTransfer |
MessageTransfer.body(List<QpidByteBuffer> body) |
void |
MessageTransfer.setBody(Collection<QpidByteBuffer> body) |
void |
Method.setBody(Collection<QpidByteBuffer> body) |
Constructor and Description |
---|
MessageTransfer(String destination,
MessageAcceptMode acceptMode,
MessageAcquireMode acquireMode,
Header header,
Collection<QpidByteBuffer> body,
Option... _options) |
Modifier and Type | Method and Description |
---|---|
void |
IoSender.send(QpidByteBuffer buf) |
Modifier and Type | Method and Description |
---|---|
void |
SASLSender.send(QpidByteBuffer buf) |
Modifier and Type | Method and Description |
---|---|
void |
SSLSender.send(QpidByteBuffer appData) |
Modifier and Type | Method and Description |
---|---|
static String |
Functions.hex(QpidByteBuffer bytes,
int limit) |
static String |
Functions.hex(QpidByteBuffer bytes,
int limit,
CharSequence separator) |
static String |
Functions.str(QpidByteBuffer buf) |
static String |
Functions.str(QpidByteBuffer buf,
int limit) |
static String |
Functions.str(QpidByteBuffer buf,
int limit,
int start) |
Modifier and Type | Method and Description |
---|---|
static String |
Functions.str(Collection<QpidByteBuffer> buf,
int limit) |
static String |
Functions.str(Collection<QpidByteBuffer> buf,
int limit,
int start) |
Modifier and Type | Method and Description |
---|---|
static ByteBuffer |
ByteBufferUtils.combine(Collection<QpidByteBuffer> bufs) |
static int |
ByteBufferUtils.remaining(Collection<QpidByteBuffer> bufs) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.