Modifier and Type | Method and Description |
---|---|
Buffer |
AmqpMessage.bodyAsBinary() |
Modifier and Type | Method and Description |
---|---|
AmqpClientOptions |
AmqpClientOptions.addCrlValue(Buffer crlValue) |
AmqpMessageBuilder |
AmqpMessageBuilder.withBufferAsBody(Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
AmqpBridgeOptions |
AmqpBridgeOptions.addCrlValue(Buffer crlValue) |
Modifier and Type | Method and Description |
---|---|
void |
ConsulConfigStore.get(Handler<AsyncResult<Buffer>> completionHandler) |
Modifier and Type | Method and Description |
---|---|
void |
GitConfigStore.get(Handler<AsyncResult<Buffer>> completionHandler) |
Modifier and Type | Method and Description |
---|---|
void |
HoconProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler) |
Modifier and Type | Method and Description |
---|---|
void |
ConfigMapStore.get(Handler<AsyncResult<Buffer>> completionHandler) |
Modifier and Type | Method and Description |
---|---|
void |
RedisConfigStore.get(Handler<AsyncResult<Buffer>> completionHandler) |
Modifier and Type | Method and Description |
---|---|
void |
ConfigProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler)
Transforms the given
input into a JsonObject . |
Modifier and Type | Method and Description |
---|---|
void |
ConfigStore.get(Handler<AsyncResult<Buffer>> completionHandler)
Retrieves the configuration store in this store.
|
Modifier and Type | Method and Description |
---|---|
static Buffer |
JsonObjectHelper.toBuffer(JsonObject json)
Deprecated.
use
JsonObject.toBuffer() instead |
Modifier and Type | Method and Description |
---|---|
void |
VaultConfigStore.get(Handler<AsyncResult<Buffer>> completionHandler) |
Modifier and Type | Method and Description |
---|---|
void |
YamlProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler) |
Modifier and Type | Method and Description |
---|---|
void |
ZookeeperConfigStore.get(Handler<AsyncResult<Buffer>> completionHandler) |
Modifier and Type | Method and Description |
---|---|
Buffer |
Buffer.appendBuffer(Buffer buff)
Appends the specified
Buffer to the end of this Buffer. |
Buffer |
Buffer.appendBuffer(Buffer buff,
int offset,
int len)
Appends the specified
Buffer starting at the offset using len to the end of this Buffer. |
Buffer |
Buffer.appendByte(byte b)
Appends the specified
byte to the end of the Buffer. |
Buffer |
Buffer.appendBytes(byte[] bytes)
Appends the specified
byte[] to the end of the Buffer. |
Buffer |
Buffer.appendBytes(byte[] bytes,
int offset,
int len)
Appends the specified number of bytes from
byte[] to the end of the Buffer, starting at the given offset. |
Buffer |
Buffer.appendDouble(double d)
Appends the specified
double to the end of the Buffer. |
Buffer |
Buffer.appendFloat(float f)
Appends the specified
float to the end of the Buffer. |
Buffer |
Buffer.appendInt(int i)
Appends the specified
int to the end of the Buffer. |
Buffer |
Buffer.appendIntLE(int i)
Appends the specified
int to the end of the Buffer in the Little Endian Byte Order. |
Buffer |
Buffer.appendLong(long l)
Appends the specified
long to the end of the Buffer. |
Buffer |
Buffer.appendLongLE(long l)
Appends the specified
long to the end of the Buffer in the Little Endian Byte Order. |
Buffer |
Buffer.appendMedium(int i)
Appends the specified 24bit
int to the end of the Buffer. |
Buffer |
Buffer.appendMediumLE(int i)
Appends the specified 24bit
int to the end of the Buffer in the Little Endian Byte Order. |
Buffer |
Buffer.appendShort(short s)
Appends the specified
short to the end of the Buffer.The buffer will expand as necessary to accommodate any bytes written. |
Buffer |
Buffer.appendShortLE(short s)
Appends the specified
short to the end of the Buffer in the Little Endian Byte Order.The buffer will expand as necessary to accommodate any bytes written. |
Buffer |
Buffer.appendString(String str)
Appends the specified
String str to the end of the Buffer with UTF-8 encoding. |
Buffer |
Buffer.appendString(String str,
String enc)
Appends the specified
String to the end of the Buffer with the encoding as specified by enc . |
Buffer |
Buffer.appendUnsignedByte(short b)
Appends the specified unsigned
byte to the end of the Buffer. |
Buffer |
Buffer.appendUnsignedInt(long i)
Appends the specified unsigned
int to the end of the Buffer. |
Buffer |
Buffer.appendUnsignedIntLE(long i)
Appends the specified unsigned
int to the end of the Buffer in the Little Endian Byte Order. |
Buffer |
Buffer.appendUnsignedShort(int s)
Appends the specified unsigned
short to the end of the Buffer.The buffer will expand as necessary to accommodate any bytes written. |
Buffer |
Buffer.appendUnsignedShortLE(int s)
Appends the specified unsigned
short to the end of the Buffer in the Little Endian Byte Order.The buffer will expand as necessary to accommodate any bytes written. |
static Buffer |
Buffer.buffer()
Create a new, empty buffer.
|
static Buffer |
Buffer.buffer(byte[] bytes)
Create a new buffer from a byte[].
|
static Buffer |
Buffer.buffer(io.netty.buffer.ByteBuf byteBuf)
Create a new buffer from a Netty
ByteBuf . |
static Buffer |
Buffer.buffer(int initialSizeHint)
Create a new buffer given the initial size hint.
|
static Buffer |
Buffer.buffer(String string)
Create a new buffer from a string.
|
static Buffer |
Buffer.buffer(String string,
String enc)
Create a new buffer from a string and using the specified encoding.
|
Buffer |
Buffer.copy()
Returns a copy of the entire Buffer.
|
Buffer |
Buffer.getBuffer(int start,
int end)
Returns a copy of a sub-sequence the Buffer as a
Buffer starting at position start
and ending at position end - 1 |
Buffer |
Buffer.getBytes(byte[] dst)
Transfers the content of the Buffer into a
byte[] . |
Buffer |
Buffer.getBytes(byte[] dst,
int dstIndex)
Transfers the content of the Buffer into a
byte[] at the specific destination. |
Buffer |
Buffer.getBytes(int start,
int end,
byte[] dst)
Transfers the content of the Buffer starting at position
start and ending at position end - 1
into a byte[] . |
Buffer |
Buffer.getBytes(int start,
int end,
byte[] dst,
int dstIndex)
Transfers the content of the Buffer starting at position
start and ending at position end - 1
into a byte[] at the specific destination. |
Buffer |
Buffer.setBuffer(int pos,
Buffer b)
Sets the bytes at position
pos in the Buffer to the bytes represented by the Buffer b . |
Buffer |
Buffer.setBuffer(int pos,
Buffer b,
int offset,
int len)
Sets the bytes at position
pos in the Buffer to the bytes represented by the Buffer b on the given offset and len . |
Buffer |
Buffer.setByte(int pos,
byte b)
Sets the
byte at position pos in the Buffer to the value b . |
Buffer |
Buffer.setBytes(int pos,
byte[] b)
Sets the bytes at position
pos in the Buffer to the bytes represented by the byte[] b . |
Buffer |
Buffer.setBytes(int pos,
byte[] b,
int offset,
int len)
Sets the given number of bytes at position
pos in the Buffer to the bytes represented by the byte[] b . |
Buffer |
Buffer.setBytes(int pos,
ByteBuffer b)
Sets the bytes at position
pos in the Buffer to the bytes represented by the ByteBuffer b . |
Buffer |
Buffer.setDouble(int pos,
double d)
Sets the
double at position pos in the Buffer to the value d . |
Buffer |
Buffer.setFloat(int pos,
float f)
Sets the
float at position pos in the Buffer to the value f . |
Buffer |
Buffer.setInt(int pos,
int i)
Sets the
int at position pos in the Buffer to the value i . |
Buffer |
Buffer.setIntLE(int pos,
int i)
Sets the
int at position pos in the Buffer to the value i in the Little Endian Byte Order. |
Buffer |
Buffer.setLong(int pos,
long l)
Sets the
long at position pos in the Buffer to the value l . |
Buffer |
Buffer.setLongLE(int pos,
long l)
Sets the
long at position pos in the Buffer to the value l in the Little Endian Byte Order. |
Buffer |
Buffer.setMedium(int pos,
int i)
Sets the 24bit
int at position pos in the Buffer to the value i . |
Buffer |
Buffer.setMediumLE(int pos,
int i)
Sets the 24bit
int at position pos in the Buffer to the value i . |
Buffer |
Buffer.setShort(int pos,
short s)
Sets the
short at position pos in the Buffer to the value s . |
Buffer |
Buffer.setShortLE(int pos,
short s)
Sets the
short at position pos in the Buffer to the value s in the Little Endian Byte Order. |
Buffer |
Buffer.setString(int pos,
String str)
Sets the bytes at position
pos in the Buffer to the value of str encoded in UTF-8. |
Buffer |
Buffer.setString(int pos,
String str,
String enc)
Sets the bytes at position
pos in the Buffer to the value of str encoded in encoding enc . |
Buffer |
Buffer.setUnsignedByte(int pos,
short b)
Sets the unsigned
byte at position pos in the Buffer to the value b . |
Buffer |
Buffer.setUnsignedInt(int pos,
long i)
Sets the unsigned
int at position pos in the Buffer to the value i . |
Buffer |
Buffer.setUnsignedIntLE(int pos,
long i)
Sets the unsigned
int at position pos in the Buffer to the value i in the Little Endian Byte Order. |
Buffer |
Buffer.setUnsignedShort(int pos,
int s)
Sets the unsigned
short at position pos in the Buffer to the value s . |
Buffer |
Buffer.setUnsignedShortLE(int pos,
int s)
Sets the unsigned
short at position pos in the Buffer to the value s in the Little Endian Byte Order. |
Buffer |
Buffer.slice()
Returns a slice of this buffer.
|
Buffer |
Buffer.slice(int start,
int end)
Returns a slice of this buffer.
|
Modifier and Type | Method and Description |
---|---|
Buffer |
Buffer.appendBuffer(Buffer buff)
Appends the specified
Buffer to the end of this Buffer. |
Buffer |
Buffer.appendBuffer(Buffer buff,
int offset,
int len)
Appends the specified
Buffer starting at the offset using len to the end of this Buffer. |
Buffer |
Buffer.setBuffer(int pos,
Buffer b)
Sets the bytes at position
pos in the Buffer to the bytes represented by the Buffer b . |
Buffer |
Buffer.setBuffer(int pos,
Buffer b,
int offset,
int len)
Sets the bytes at position
pos in the Buffer to the bytes represented by the Buffer b on the given offset and len . |
Modifier and Type | Method and Description |
---|---|
Buffer |
DatagramPacket.data()
Returns the data of the
DatagramPacket |
Modifier and Type | Method and Description |
---|---|
WriteStream<Buffer> |
DatagramSocket.sender(int port,
String host)
|
Modifier and Type | Method and Description |
---|---|
DatagramSocket |
DatagramSocket.send(Buffer packet,
int port,
String host,
Handler<AsyncResult<DatagramSocket>> handler)
Write the given
Buffer to the SocketAddress . |
Modifier and Type | Method and Description |
---|---|
Buffer |
AddressResolverOptions.getHostsValue() |
Modifier and Type | Method and Description |
---|---|
AddressResolverOptions |
AddressResolverOptions.setHostsValue(Buffer hostsValue)
Set an alternate hosts configuration file to use instead of the one provided by the os.
|
Modifier and Type | Method and Description |
---|---|
EventBusOptions |
EventBusOptions.addCrlValue(Buffer crlValue) |
R |
MessageCodec.decodeFromWire(int pos,
Buffer buffer)
Called by Vert.x when a message is decoded from the wire.
|
void |
MessageCodec.encodeToWire(Buffer buffer,
S s)
Called by Vert.x when marshalling a message to the wire.
|
Modifier and Type | Method and Description |
---|---|
Buffer |
FileSystem.readFileBlocking(String path)
Blocking version of
FileSystem.readFile(String, Handler) |
Modifier and Type | Method and Description |
---|---|
AsyncFile |
AsyncFile.read(Buffer buffer,
int offset,
long position,
int length,
Handler<AsyncResult<Buffer>> handler)
Reads
length bytes of data from the file at position position in the file, asynchronously. |
AsyncFile |
AsyncFile.write(Buffer data) |
AsyncFile |
AsyncFile.write(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as
AsyncFile.write(Buffer) but with an handler called when the operation completes |
AsyncFile |
AsyncFile.write(Buffer buffer,
long position,
Handler<AsyncResult<Void>> handler)
Write a
Buffer to the file at position position in the file, asynchronously. |
FileSystem |
FileSystem.writeFile(String path,
Buffer data,
Handler<AsyncResult<Void>> handler)
Creates the file, and writes the specified
Buffer data to the file represented by the path path ,
asynchronously. |
FileSystem |
FileSystem.writeFileBlocking(String path,
Buffer data)
Blocking version of
FileSystem.writeFile(String, Buffer, Handler) |
Modifier and Type | Method and Description |
---|---|
AsyncFile |
AsyncFile.handler(Handler<Buffer> handler) |
AsyncFile |
AsyncFile.read(Buffer buffer,
int offset,
long position,
int length,
Handler<AsyncResult<Buffer>> handler)
Reads
length bytes of data from the file at position position in the file, asynchronously. |
FileSystem |
FileSystem.readFile(String path,
Handler<AsyncResult<Buffer>> handler)
Reads the entire file as represented by the path
path as a Buffer , asynchronously. |
Modifier and Type | Method and Description |
---|---|
Buffer |
WebSocketFrame.binaryData() |
Buffer |
GoAway.getDebugData() |
Buffer |
HttpFrame.payload() |
Modifier and Type | Method and Description |
---|---|
HttpClientOptions |
HttpClientOptions.addCrlValue(Buffer crlValue) |
HttpServerOptions |
HttpServerOptions.addCrlValue(Buffer crlValue) |
static WebSocketFrame |
WebSocketFrame.binaryFrame(Buffer data,
boolean isFinal)
Create a binary WebSocket frame.
|
static WebSocketFrame |
WebSocketFrame.continuationFrame(Buffer data,
boolean isFinal)
Create a continuation frame
|
void |
HttpServerResponse.end(Buffer chunk)
Same as
HttpServerResponse.end() but writes some data to the response body before ending. |
void |
HttpClientRequest.end(Buffer chunk)
Same as
HttpClientRequest.end() but writes some data to the request body before ending. |
void |
HttpServerResponse.end(Buffer chunk,
Handler<AsyncResult<Void>> handler)
Same as
HttpServerResponse.end(Buffer) but with an handler called when the operation completes |
void |
HttpClientRequest.end(Buffer chunk,
Handler<AsyncResult<Void>> handler)
Same as
HttpClientRequest.end(String) but with an handler called when the operation completes |
HttpConnection |
HttpConnection.goAway(long errorCode,
int lastStreamId,
Buffer debugData)
Send a go away frame to the remote endpoint of the connection.
|
HttpConnection |
HttpConnection.ping(Buffer data,
Handler<AsyncResult<Buffer>> pongHandler)
Send a PING frame to the remote endpoint.
|
static WebSocketFrame |
WebSocketFrame.pingFrame(Buffer data)
Create a ping WebSocket frame.
|
static WebSocketFrame |
WebSocketFrame.pongFrame(Buffer data)
Create a pong WebSocket frame.
|
GoAway |
GoAway.setDebugData(Buffer debugData)
Set the additional debug data
|
HttpServerResponse |
HttpServerResponse.write(Buffer data) |
ServerWebSocket |
ServerWebSocket.write(Buffer data) |
HttpClientRequest |
HttpClientRequest.write(Buffer data) |
WebSocket |
WebSocket.write(Buffer data) |
WebSocketBase |
WebSocketBase.write(Buffer data) |
HttpServerResponse |
HttpServerResponse.write(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as
HttpServerResponse.write(Buffer) but with an handler called when the operation completes |
ServerWebSocket |
ServerWebSocket.write(Buffer data,
Handler<AsyncResult<Void>> handler) |
HttpClientRequest |
HttpClientRequest.write(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as
HttpClientRequest.write(Buffer) but with an handler called when the operation completes |
WebSocket |
WebSocket.write(Buffer data,
Handler<AsyncResult<Void>> handler) |
WebSocketBase |
WebSocketBase.write(Buffer data,
Handler<AsyncResult<Void>> handler) |
ServerWebSocket |
ServerWebSocket.writeBinaryMessage(Buffer data) |
WebSocket |
WebSocket.writeBinaryMessage(Buffer data) |
WebSocketBase |
WebSocketBase.writeBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.
|
ServerWebSocket |
ServerWebSocket.writeBinaryMessage(Buffer data,
Handler<AsyncResult<Void>> handler) |
WebSocket |
WebSocket.writeBinaryMessage(Buffer data,
Handler<AsyncResult<Void>> handler) |
WebSocketBase |
WebSocketBase.writeBinaryMessage(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as
WebSocketBase.writeBinaryMessage(Buffer) but with an handler called when the operation completes |
HttpServerResponse |
HttpServerResponse.writeCustomFrame(int type,
int flags,
Buffer payload)
Write an HTTP/2 frame to the response, allowing to extend the HTTP/2 protocol.
|
HttpClientRequest |
HttpClientRequest.writeCustomFrame(int type,
int flags,
Buffer payload)
Write an HTTP/2 frame to the request, allowing to extend the HTTP/2 protocol.
|
ServerWebSocket |
ServerWebSocket.writeFinalBinaryFrame(Buffer data) |
WebSocket |
WebSocket.writeFinalBinaryFrame(Buffer data) |
WebSocketBase |
WebSocketBase.writeFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connection
|
ServerWebSocket |
ServerWebSocket.writeFinalBinaryFrame(Buffer data,
Handler<AsyncResult<Void>> handler) |
WebSocket |
WebSocket.writeFinalBinaryFrame(Buffer data,
Handler<AsyncResult<Void>> handler) |
WebSocketBase |
WebSocketBase.writeFinalBinaryFrame(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as
WebSocketBase.writeFinalBinaryFrame(Buffer, Handler) but with an handler called when the operation completes |
WebSocketBase |
WebSocketBase.writePing(Buffer data)
Writes a ping frame to the connection.
|
WebSocketBase |
WebSocketBase.writePong(Buffer data)
Writes a pong frame to the connection.
|
Modifier and Type | Method and Description |
---|---|
HttpClientResponse |
HttpClientResponse.bodyHandler(Handler<Buffer> bodyHandler)
Convenience method for receiving the entire request body in one piece.
|
HttpClientResponse |
HttpClientResponse.handler(Handler<Buffer> handler) |
ServerWebSocket |
ServerWebSocket.handler(Handler<Buffer> handler) |
WebSocket |
WebSocket.handler(Handler<Buffer> handler) |
HttpServerFileUpload |
HttpServerFileUpload.handler(Handler<Buffer> handler) |
HttpServerRequest |
HttpServerRequest.handler(Handler<Buffer> handler) |
WebSocketBase |
WebSocketBase.handler(Handler<Buffer> handler) |
HttpConnection |
HttpConnection.ping(Buffer data,
Handler<AsyncResult<Buffer>> pongHandler)
Send a PING frame to the remote endpoint.
|
Modifier and Type | Method and Description |
---|---|
static Buffer |
Json.encodeToBuffer(Object obj)
Encode a POJO to JSON using the underlying Jackson mapper.
|
Buffer |
JsonArray.toBuffer()
Encode this JSON object as buffer.
|
Buffer |
JsonObject.toBuffer()
Encode this JSON object as buffer.
|
Modifier and Type | Method and Description |
---|---|
static Object |
Json.decodeValue(Buffer buf)
Decode a given JSON buffer.
|
static <T> T |
Json.decodeValue(Buffer buf,
Class<T> clazz)
Decode a given JSON buffer to a POJO of the given class type.
|
static <T> T |
Json.decodeValue(Buffer buf,
TypeReference<T> type)
Deprecated.
Instead use
JacksonCodec.decodeValue(Buffer, TypeReference) |
int |
JsonArray.readFromBuffer(int pos,
Buffer buffer) |
int |
JsonObject.readFromBuffer(int pos,
Buffer buffer) |
void |
JsonArray.writeToBuffer(Buffer buffer) |
void |
JsonObject.writeToBuffer(Buffer buffer) |
Constructor and Description |
---|
JsonArray(Buffer buf)
Create an instance from a Buffer of JSON.
|
JsonObject(Buffer buf)
Create an instance from a buffer.
|
Modifier and Type | Method and Description |
---|---|
Buffer |
JacksonCodec.toBuffer(Object object,
boolean pretty) |
Modifier and Type | Method and Description |
---|---|
static <T> T |
JacksonCodec.decodeValue(Buffer buf,
TypeReference<T> type)
Decode a given JSON buffer to a POJO of the given class type.
|
<T> T |
JacksonCodec.fromBuffer(Buffer buf,
Class<T> clazz) |
static <T> T |
JacksonCodec.fromBuffer(Buffer buf,
TypeReference<T> type) |
Modifier and Type | Method and Description |
---|---|
Buffer |
PemKeyCertOptions.getCertValue()
Get the first certificate as a buffer
|
Buffer |
PemKeyCertOptions.getKeyValue()
Get the first key as a buffer
|
Buffer |
KeyStoreOptionsBase.getValue()
Get the key store as a buffer
|
Modifier and Type | Method and Description |
---|---|
List<Buffer> |
PemKeyCertOptions.getCertValues()
Get all the certificates as a list of buffer
|
List<Buffer> |
PemTrustOptions.getCertValues() |
List<Buffer> |
TCPSSLOptions.getCrlValues()
Get the CRL values
|
List<Buffer> |
PemKeyCertOptions.getKeyValues()
Get all the keys as a list of buffer
|
Modifier and Type | Method and Description |
---|---|
PemKeyCertOptions |
PemKeyCertOptions.addCertValue(Buffer certValue)
Add a certificate as a buffer
|
PemTrustOptions |
PemTrustOptions.addCertValue(Buffer certValue)
Add a certificate value
|
TCPSSLOptions |
TCPSSLOptions.addCrlValue(Buffer crlValue)
Add a CRL value
|
NetServerOptions |
NetServerOptions.addCrlValue(Buffer crlValue) |
ClientOptionsBase |
ClientOptionsBase.addCrlValue(Buffer crlValue) |
NetClientOptions |
NetClientOptions.addCrlValue(Buffer crlValue) |
PemKeyCertOptions |
PemKeyCertOptions.addKeyValue(Buffer keyValue)
Add a key as a buffer
|
PemKeyCertOptions |
PemKeyCertOptions.setCertValue(Buffer certValue)
Set the first certificate as a buffer, replacing the previous certificates buffers
|
PemKeyCertOptions |
PemKeyCertOptions.setKeyValue(Buffer keyValue)
Set the first key a a buffer, replacing the previous keys buffers
|
KeyStoreOptionsBase |
KeyStoreOptionsBase.setValue(Buffer value)
Set the key store as a buffer
|
KeyStoreOptions |
KeyStoreOptions.setValue(Buffer value) |
PfxOptions |
PfxOptions.setValue(Buffer value)
Set the key store as a buffer
|
JksOptions |
JksOptions.setValue(Buffer value)
Set the key store as a buffer
|
NetSocket |
NetSocket.write(Buffer data) |
NetSocket |
NetSocket.write(Buffer message,
Handler<AsyncResult<Void>> handler)
Like
WriteStream.write(Object) but with an handler called when the message has been written
or failed to be written. |
Modifier and Type | Method and Description |
---|---|
NetSocket |
NetSocket.handler(Handler<Buffer> handler) |
PemKeyCertOptions |
PemKeyCertOptions.setCertValues(List<Buffer> certValues)
Set all the certificates as a list of buffer
|
PemKeyCertOptions |
PemKeyCertOptions.setKeyValues(List<Buffer> keyValues)
Set all the keys as a list of buffer
|
Modifier and Type | Method and Description |
---|---|
Buffer |
JsonEvent.binaryValue()
Return the binary value.
|
Modifier and Type | Method and Description |
---|---|
void |
RecordParser.delimitedMode(Buffer delim)
Flip the parser into delimited mode, and where the delimiter can be represented
by the delimiter
delim . |
void |
RecordParser.handle(Buffer buffer)
This method is called to provide the parser with data.
|
static RecordParser |
RecordParser.newDelimited(Buffer delim)
Create a new
RecordParser instance, initially in delimited mode, and where the delimiter can be represented
by the Buffer delim. |
static RecordParser |
RecordParser.newDelimited(Buffer delim,
Handler<Buffer> output)
Like
RecordParser.newDelimited(Buffer) but set the output that will receive whole records
which have been parsed. |
static RecordParser |
RecordParser.newDelimited(Buffer delim,
ReadStream<Buffer> stream)
Like
RecordParser.newDelimited(Buffer) but wraps the stream . |
JsonParser |
JsonParser.write(Buffer buffer)
Handle a
Buffer , pretty much like calling Handler.handle(Object) . |
Modifier and Type | Method and Description |
---|---|
RecordParser |
RecordParser.handler(Handler<Buffer> handler) |
static RecordParser |
RecordParser.newDelimited(Buffer delim,
Handler<Buffer> output)
Like
RecordParser.newDelimited(Buffer) but set the output that will receive whole records
which have been parsed. |
static RecordParser |
RecordParser.newDelimited(Buffer delim,
ReadStream<Buffer> stream)
Like
RecordParser.newDelimited(Buffer) but wraps the stream . |
static RecordParser |
RecordParser.newDelimited(String delim,
Handler<Buffer> output)
Like
RecordParser.newDelimited(String) but set the output that will receive whole records
which have been parsed. |
static RecordParser |
RecordParser.newDelimited(String delim,
ReadStream<Buffer> stream)
Like
RecordParser.newDelimited(String) but wraps the stream . |
static RecordParser |
RecordParser.newFixed(int size,
Handler<Buffer> output)
Like
RecordParser.newFixed(int) but set the output that will receive whole records
which have been parsed. |
static RecordParser |
RecordParser.newFixed(int size,
ReadStream<Buffer> stream)
Like
RecordParser.newFixed(int) but wraps the stream . |
static JsonParser |
JsonParser.newParser(ReadStream<Buffer> stream)
Create a new
JsonParser instance. |
void |
RecordParser.setOutput(Handler<Buffer> output) |
Modifier and Type | Method and Description |
---|---|
Buffer |
BufferFactory.buffer() |
Buffer |
BufferFactory.buffer(byte[] bytes) |
Buffer |
BufferFactory.buffer(io.netty.buffer.ByteBuf byteBuffer) |
Buffer |
BufferFactory.buffer(int initialSizeHint) |
Buffer |
BufferFactory.buffer(String str) |
Buffer |
BufferFactory.buffer(String str,
String enc) |
Buffer |
BufferFactory.directBuffer(byte[] bytes)
Create a direct buffer, use this with care as Vert.x buffers are not releasable (unpooled) and you would need
to release the underlying Netty wrapped
ByteBuf . |
Buffer |
BufferFactory.directBuffer(String str,
String enc) |
Modifier and Type | Method and Description |
---|---|
WebSocketFrame |
WebSocketFrameFactory.binaryFrame(Buffer data,
boolean isFinal) |
WebSocketFrame |
WebSocketFrameFactory.continuationFrame(Buffer data,
boolean isFinal) |
WebSocketFrame |
WebSocketFrameFactory.pingFrame(Buffer data) |
WebSocketFrame |
WebSocketFrameFactory.pongFrame(Buffer data) |
Modifier and Type | Method and Description |
---|---|
default Buffer |
JsonCodec.toBuffer(Object object)
Like
JsonCodec.toString(Object) but with a json Buffer |
Buffer |
JsonCodec.toBuffer(Object object,
boolean pretty)
Like
JsonCodec.toString(Object, boolean) but with a json Buffer |
Modifier and Type | Method and Description |
---|---|
<T> T |
JsonCodec.fromBuffer(Buffer json,
Class<T> clazz)
Like
JsonCodec.fromString(String, Class) but with a json Buffer |
Modifier and Type | Method and Description |
---|---|
int |
AbstractUser.readFromBuffer(int pos,
Buffer buffer)
Deprecated.
|
void |
AbstractUser.writeToBuffer(Buffer buff)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Buffer |
OAuth2Response.body()
The HTTP response body as a buffer
|
Modifier and Type | Method and Description |
---|---|
AccessToken |
AccessToken.fetch(HttpMethod method,
String resource,
JsonObject headers,
Buffer payload,
Handler<AsyncResult<OAuth2Response>> callback)
Deprecated.
Fetches a JSON resource using this Access Token.
|
Modifier and Type | Method and Description |
---|---|
ConsulClientOptions |
ConsulClientOptions.addCrlValue(Buffer crlValue)
Add a CRL value
|
Modifier and Type | Method and Description |
---|---|
Buffer |
MailAttachment.getData()
get the data
|
Modifier and Type | Method and Description |
---|---|
MailAttachment |
MailAttachment.setData(Buffer data)
set the data
|
Modifier and Type | Method and Description |
---|---|
static Buffer |
HttpTermOptions.defaultShellHtmlResource() |
static Buffer |
HttpTermOptions.defaultTermJsResource() |
static Buffer |
HttpTermOptions.defaultVertxShellJsResource() |
Buffer |
HttpTermOptions.getShellHtmlResource() |
Buffer |
HttpTermOptions.getTermJsResource() |
Buffer |
HttpTermOptions.getVertsShellJsResource() |
Modifier and Type | Method and Description |
---|---|
HttpTermOptions |
HttpTermOptions.addCrlValue(Buffer crlValue) |
TelnetTermOptions |
TelnetTermOptions.addCrlValue(Buffer crlValue) |
HttpTermOptions |
HttpTermOptions.setShellHtmlResource(Buffer shellHtmlResource)
Set
shell.html resource to use. |
HttpTermOptions |
HttpTermOptions.setTermJsResource(Buffer termJsResource)
Set
term.js resource to use. |
HttpTermOptions |
HttpTermOptions.setVertsShellJsResource(Buffer vertsShellJsResource)
Set
vertxshell.js resource to use. |
Modifier and Type | Method and Description |
---|---|
Buffer |
Frame.getBody() |
Buffer |
Frame.toBuffer()
This method does not enforce the trailing line option.
|
Buffer |
Frame.toBuffer(boolean trailingLine)
Creates a buffer for the current frame.
|
Modifier and Type | Method and Description |
---|---|
StompClientConnection |
StompClientConnection.send(Map<String,String> headers,
Buffer body)
Sends a
SEND frame to the server. |
StompClientConnection |
StompClientConnection.send(Map<String,String> headers,
Buffer body,
Handler<Frame> receiptHandler)
Sends a
SEND frame to the server. |
StompClientConnection |
StompClientConnection.send(String destination,
Buffer body)
Sends a
SEND frame to the server to the given destination. |
StompClientConnection |
StompClientConnection.send(String destination,
Buffer body,
Handler<Frame> receiptHandler)
Sends a
SEND frame to the server to the given destination. |
StompClientConnection |
StompClientConnection.send(String destination,
Map<String,String> headers,
Buffer body)
Sends a
SEND frame to the server to the given destination. |
StompClientConnection |
StompClientConnection.send(String destination,
Map<String,String> headers,
Buffer body,
Handler<Frame> receiptHandler)
Sends a
SEND frame to the server to the given destination. |
Frame |
Frame.setBody(Buffer body)
Sets the body of the frame.
|
StompServerConnection |
StompServerConnection.write(Buffer buffer)
Writes the given buffer to the socket.
|
Constructor and Description |
---|
Frame(Frame.Command command,
Map<String,String> headers,
Buffer body)
Creates a new instance of
Frame . |
Modifier and Type | Method and Description |
---|---|
Buffer |
RoutingContext.getBody() |
Modifier and Type | Method and Description |
---|---|
void |
RoutingContext.setBody(Buffer body)
Set the body.
|
Modifier and Type | Method and Description |
---|---|
Buffer |
OperationResponse.getPayload() |
Modifier and Type | Method and Description |
---|---|
static OperationResponse |
OperationResponse.completedWithJson(Buffer json) |
static OperationResponse |
OperationResponse.completedWithPlainText(Buffer text) |
OperationResponse |
OperationResponse.setPayload(Buffer payload) |
Constructor and Description |
---|
OperationResponse(Integer statusCode,
String statusMessage,
Buffer payload,
MultiMap headers) |
Modifier and Type | Method and Description |
---|---|
Buffer |
HttpResponse.bodyAsBuffer() |
Modifier and Type | Method and Description |
---|---|
HttpRequest<Buffer> |
WebClient.delete(int port,
String host,
String requestURI)
Create an HTTP DELETE request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.delete(String requestURI)
Create an HTTP DELETE request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.delete(String host,
String requestURI)
Create an HTTP DELETE request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.deleteAbs(String absoluteURI)
Create an HTTP DELETE request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.get(int port,
String host,
String requestURI)
Create an HTTP GET request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.get(String requestURI)
Create an HTTP GET request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.get(String host,
String requestURI)
Create an HTTP GET request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.getAbs(String absoluteURI)
Create an HTTP GET request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.head(int port,
String host,
String requestURI)
Create an HTTP HEAD request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.head(String requestURI)
Create an HTTP HEAD request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.head(String host,
String requestURI)
Create an HTTP HEAD request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.headAbs(String absoluteURI)
Create an HTTP HEAD request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.patch(int port,
String host,
String requestURI)
Create an HTTP PATCH request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.patch(String requestURI)
Create an HTTP PATCH request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.patch(String host,
String requestURI)
Create an HTTP PATCH request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.patchAbs(String absoluteURI)
Create an HTTP PATCH request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.post(int port,
String host,
String requestURI)
Create an HTTP POST request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.post(String requestURI)
Create an HTTP POST request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.post(String host,
String requestURI)
Create an HTTP POST request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.postAbs(String absoluteURI)
Create an HTTP POST request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.put(int port,
String host,
String requestURI)
Create an HTTP PUT request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.put(String requestURI)
Create an HTTP PUT request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.put(String host,
String requestURI)
Create an HTTP PUT request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.putAbs(String absoluteURI)
Create an HTTP PUT request to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.raw(String customHttpMethod,
int port,
String host,
String requestURI)
Create a request with a custom HTTP method to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.raw(String customHttpMethod,
String requestURI)
Create a request with a custom HTTP method to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.raw(String customHttpMethod,
String host,
String requestURI)
Create a request with a custom HTTP method to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.rawAbs(String customHttpMethod,
String absoluteURI)
Create a request with a custom HTTP method to send to the server using an absolute URI, specifying a response handler to receive
the response
|
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
int port,
String host,
String requestURI)
Create an HTTP request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
RequestOptions options)
Create an HTTP request to send to the server at the specified host and port.
|
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
SocketAddress serverAddress,
int port,
String host,
String requestURI)
Like
WebClient.request(HttpMethod, int, String, String) using the serverAddress parameter to connect to the
server instead of the port and host parameters. |
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
SocketAddress serverAddress,
RequestOptions options)
Like
WebClient.request(HttpMethod, RequestOptions) using the serverAddress parameter to connect to the
server instead of the options parameter. |
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
SocketAddress serverAddress,
String requestURI)
Like
WebClient.request(HttpMethod, String) using the serverAddress parameter to connect to the
server instead of the default port and default host. |
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
SocketAddress serverAddress,
String host,
String requestURI)
Like
WebClient.request(HttpMethod, String, String) using the serverAddress parameter to connect to the
server instead of the default port and host parameter. |
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
String requestURI)
Create an HTTP request to send to the server at the default host and port.
|
HttpRequest<Buffer> |
WebClient.request(HttpMethod method,
String host,
String requestURI)
Create an HTTP request to send to the server at the specified host and default port.
|
HttpRequest<Buffer> |
WebClient.requestAbs(HttpMethod method,
SocketAddress serverAddress,
String absoluteURI)
Like
WebClient.requestAbs(HttpMethod, String) using the serverAddress parameter to connect to the
server instead of the absoluteURI parameter. |
HttpRequest<Buffer> |
WebClient.requestAbs(HttpMethod method,
String absoluteURI)
Create an HTTP request to send to the server using an absolute URI
|
Modifier and Type | Method and Description |
---|---|
WebClientOptions |
WebClientOptions.addCrlValue(Buffer crlValue) |
HttpRequest<T> |
HttpRequest.basicAuthentication(Buffer id,
Buffer password)
Configure the request to perform basic access authentication.
|
void |
HttpRequest.sendBuffer(Buffer body,
Handler<AsyncResult<HttpResponse<T>>> handler)
Like
HttpRequest.send(Handler) but with an HTTP request body buffer. |
Modifier and Type | Method and Description |
---|---|
void |
HttpRequest.sendStream(ReadStream<Buffer> body,
Handler<AsyncResult<HttpResponse<T>>> handler)
Like
HttpRequest.send(Handler) but with an HTTP request body stream. |
Modifier and Type | Method and Description |
---|---|
static BodyCodec<Buffer> |
BodyCodec.buffer() |
Modifier and Type | Method and Description |
---|---|
static <T> BodyCodec<T> |
BodyCodec.create(java.util.function.Function<Buffer,T> decode)
Create a codec that buffers the entire body and then apply the
decode function and returns the result. |
static BodyCodec<Void> |
BodyCodec.pipe(WriteStream<Buffer> stream)
A body codec that pipes the body to a write stream.
|
static BodyCodec<Void> |
BodyCodec.pipe(WriteStream<Buffer> stream,
boolean close)
A body codec that pipes the body to a write stream.
|
Modifier and Type | Method and Description |
---|---|
default void |
TemplateEngine.render(JsonObject context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Render the template.
|
void |
TemplateEngine.render(Map<String,Object> context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Render the template.
|
Modifier and Type | Method and Description |
---|---|
default SockJSSocket |
SockJSSocket.write(Buffer data) |
SockJSSocket |
SockJSSocket.write(Buffer data,
Handler<AsyncResult<Void>> handler) |
Modifier and Type | Method and Description |
---|---|
SockJSSocket |
SockJSSocket.handler(Handler<Buffer> handler) |
Modifier and Type | Method and Description |
---|---|
Buffer |
FormDataPart.content() |
Modifier and Type | Method and Description |
---|---|
MultipartForm |
MultipartForm.binaryFileUpload(String name,
String filename,
Buffer content,
String mediaType)
Add a binary file upload form data part.
|
MultipartForm |
MultipartForm.textFileUpload(String name,
String filename,
Buffer content,
String mediaType)
Add a text file upload form data part.
|
Modifier and Type | Method and Description |
---|---|
default void |
TemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
default void |
FreeMarkerTemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
default void |
PebbleTemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
default void |
JadeTemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
default void |
ThymeleafTemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
default void |
HandlebarsTemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
default void |
RockerTemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
default void |
MVELTemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
default void |
TemplateEngine.render(RoutingContext context,
String templateDirectory,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Buffer |
KafkaHeader.value() |
Modifier and Type | Method and Description |
---|---|
KafkaProducerRecord<K,V> |
KafkaProducerRecord.addHeader(String key,
Buffer value)
Like
KafkaProducerRecord.addHeader(KafkaHeader) but with a key/value pair |
static KafkaHeader |
KafkaHeader.header(String key,
Buffer value) |
Modifier and Type | Method and Description |
---|---|
Buffer |
BufferDeserializer.deserialize(String topic,
byte[] data) |
Modifier and Type | Method and Description |
---|---|
static org.apache.kafka.common.serialization.Serde<Buffer> |
VertxSerdes.Buffer() |
Modifier and Type | Method and Description |
---|---|
byte[] |
BufferSerializer.serialize(String topic,
Buffer data) |
Modifier and Type | Method and Description |
---|---|
MqttClientOptions |
MqttClientOptions.addCrlValue(Buffer crlValue) |
MqttServerOptions |
MqttServerOptions.addCrlValue(Buffer crlValue) |
MqttClient |
MqttClient.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain)
Sends the PUBLISH message to the remote MQTT server
|
MqttEndpoint |
MqttEndpoint.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain)
Sends the PUBLISH message to the remote MQTT client
|
MqttClient |
MqttClient.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
Handler<AsyncResult<Integer>> publishSentHandler)
Sends the PUBLISH message to the remote MQTT server
|
MqttEndpoint |
MqttEndpoint.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
Handler<AsyncResult<Integer>> publishSentHandler)
Sends the PUBLISH message to the remote MQTT server
|
MqttEndpoint |
MqttEndpoint.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
int messageId,
Handler<AsyncResult<Integer>> publishSentHandler)
Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageId
|
Modifier and Type | Method and Description |
---|---|
Buffer |
MqttPublishMessage.payload() |
Modifier and Type | Method and Description |
---|---|
Buffer |
MySQLConnectOptions.getServerRsaPublicKeyValue()
Get the value of the server RSA public key.
|
Buffer |
MySQLAuthOptions.getServerRsaPublicKeyValue()
Get the value of the server RSA public key.
|
Modifier and Type | Method and Description |
---|---|
MySQLConnectOptions |
MySQLConnectOptions.addCrlValue(Buffer crlValue) |
MySQLConnectOptions |
MySQLConnectOptions.setServerRsaPublicKeyValue(Buffer serverRsaPublicKeyValue)
Set the value of server RSA public key which is mostly used for encrypting password under insecure connections when performing authentication.
|
MySQLAuthOptions |
MySQLAuthOptions.setServerRsaPublicKeyValue(Buffer serverRsaPublicKeyValue)
Set the value of server RSA public key which is mostly used for encrypting password under insecure connections when performing authentication.
|
Modifier and Type | Method and Description |
---|---|
PgConnectOptions |
PgConnectOptions.addCrlValue(Buffer crlValue) |
Modifier and Type | Method and Description |
---|---|
Buffer |
RabbitMQMessage.body() |
Modifier and Type | Method and Description |
---|---|
Buffer |
Buffer.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static Buffer |
Buffer.newInstance(Buffer arg) |
int |
Buffer.readFromBuffer(int pos,
Buffer buffer) |
void |
Buffer.writeToBuffer(Buffer buffer) |
Constructor and Description |
---|
Buffer(Buffer delegate) |
Modifier and Type | Method and Description |
---|---|
RedisTransaction |
RedisTransaction.setBinary(String key,
Buffer value,
Handler<AsyncResult<String>> handler)
Deprecated.
Set the binary string value of a key - without encoding as utf-8
|
RedisClient |
RedisClient.setBinary(String key,
Buffer value,
Handler<AsyncResult<Void>> handler)
Deprecated.
Set the binary string value of a key - without encoding as utf-8
|
RedisTransaction |
RedisTransaction.setBinaryWithOptions(String key,
Buffer value,
SetOptions options,
Handler<AsyncResult<String>> handler)
Deprecated.
Set the string value of a key
|
RedisClient |
RedisClient.setBinaryWithOptions(String key,
Buffer value,
SetOptions options,
Handler<AsyncResult<Void>> handler)
Deprecated.
Set the string value of a key
|
Modifier and Type | Method and Description |
---|---|
RedisTransaction |
RedisTransaction.getBinary(String key,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
Get the value of a key - without decoding as utf-8
|
RedisClient |
RedisClient.getBinary(String key,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
Get the value of a key - without decoding as utf-8
|
Modifier and Type | Method and Description |
---|---|
default Buffer |
Response.toBuffer()
Get this response as Buffer.
|
Modifier and Type | Method and Description |
---|---|
Request |
Request.arg(Buffer arg)
Adds a String key argument
|
Modifier and Type | Method and Description |
---|---|
Buffer |
Buffer.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static Buffer |
Buffer.newInstance(Buffer arg) |
int |
Buffer.readFromBuffer(int pos,
Buffer buffer) |
void |
Buffer.writeToBuffer(Buffer buffer) |
Constructor and Description |
---|
Buffer(Buffer delegate) |
Modifier and Type | Method and Description |
---|---|
ServiceException |
ServiceExceptionMessageCodec.decodeFromWire(int pos,
Buffer buffer) |
void |
ServiceExceptionMessageCodec.encodeToWire(Buffer buffer,
ServiceException body) |
Modifier and Type | Method and Description |
---|---|
default Buffer[] |
Tuple.getArrayOfBuffers(int pos)
Get an array of
Buffer value at pos . |
default Buffer[] |
Row.getArrayOfBuffers(String column)
Get an array of
Buffer value for the given column . |
default Buffer |
Tuple.getBuffer(int pos)
Get a buffer value at
pos . |
default Buffer |
Row.getBuffer(String column)
Get a buffer value for the given
column . |
default Buffer[] |
Tuple.getBufferArray(int pos)
Deprecated.
instead use
Tuple.getArrayOfBuffers(int) |
default Buffer[] |
Row.getBufferArray(String column)
Deprecated.
instead use
Row.getArrayOfBuffers(String) |
Modifier and Type | Method and Description |
---|---|
default Tuple |
Tuple.addArrayOfBuffer(Buffer[] value)
Add an array of
Buffer value at the end of the tuple. |
default Tuple |
Tuple.addBuffer(Buffer value)
Add a buffer value at the end of the tuple.
|
default Tuple |
Tuple.addBufferArray(Buffer[] value)
Deprecated.
instead use
Tuple.addArrayOfBuffer(Buffer[]) |
Copyright © 2023 Eclipse. All rights reserved.