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 |
---|---|
Future<Buffer> |
ConsulConfigStore.get() |
Modifier and Type | Method and Description |
---|---|
Future<Buffer> |
GitConfigStore.get() |
Modifier and Type | Method and Description |
---|---|
Future<JsonObject> |
HoconProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input) |
Modifier and Type | Method and Description |
---|---|
Future<Buffer> |
ConfigMapStore.get() |
Modifier and Type | Method and Description |
---|---|
Future<Buffer> |
RedisConfigStore.get() |
Modifier and Type | Method and Description |
---|---|
default Future<Buffer> |
ConfigStore.get()
Retrieves the configuration store in this store.
|
Modifier and Type | Method and Description |
---|---|
default Future<JsonObject> |
ConfigProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input)
Transforms the given
input into a JsonObject . |
default void |
ConfigProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler)
Deprecated.
implement
ConfigProcessor.process(Vertx, JsonObject, Buffer) instead |
Modifier and Type | Method and Description |
---|---|
default void |
ConfigStore.get(Handler<AsyncResult<Buffer>> completionHandler)
Deprecated.
implement
ConfigStore.get() instead |
Modifier and Type | Method and Description |
---|---|
static Buffer |
JsonObjectHelper.toBuffer(JsonObject json)
Deprecated.
use
JsonObject.toBuffer() instead |
Modifier and Type | Method and Description |
---|---|
Future<Buffer> |
VaultConfigStore.get() |
Modifier and Type | Method and Description |
---|---|
Future<JsonObject> |
YamlProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input) |
Modifier and Type | Method and Description |
---|---|
Future<Buffer> |
ZookeeperConfigStore.get() |
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 |
---|---|
Future<Void> |
DatagramSocket.send(Buffer packet,
int port,
String host)
Like
DatagramSocket.send(Buffer, int, String, Handler) but returns a Future of the asynchronous result |
DatagramSocket |
DatagramSocket.send(Buffer packet,
int port,
String host,
Handler<AsyncResult<Void>> 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 |
---|---|
Future<Buffer> |
AsyncFile.read(Buffer buffer,
int offset,
long position,
int length)
Like
AsyncFile.read(Buffer, int, long, int, Handler) but returns a Future of the asynchronous result |
Future<Buffer> |
FileSystem.readFile(String path)
Like
FileSystem.readFile(String, Handler) but returns a Future of the asynchronous result |
Modifier and Type | Method and Description |
---|---|
Future<Buffer> |
AsyncFile.read(Buffer buffer,
int offset,
long position,
int length)
Like
AsyncFile.read(Buffer, int, long, int, Handler) but returns a Future of the asynchronous result |
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. |
Future<Void> |
AsyncFile.write(Buffer buffer,
long position)
Like
AsyncFile.write(Buffer, long, Handler) but returns a Future of the asynchronous result |
void |
AsyncFile.write(Buffer buffer,
long position,
Handler<AsyncResult<Void>> handler)
Write a
Buffer to the file at position position in the file, asynchronously. |
Future<Void> |
FileSystem.writeFile(String path,
Buffer data)
Like
FileSystem.writeFile(String, Buffer, Handler) but returns a Future of the asynchronous result |
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 |
---|---|
Future<Buffer> |
HttpClientResponse.body()
Convenience method for receiving the entire request body in one piece.
|
Future<Buffer> |
HttpServerRequest.body()
Convenience method for receiving the entire request body in one piece.
|
Future<Buffer> |
HttpConnection.ping(Buffer data)
Same as
HttpConnection.ping(Buffer, Handler) but returns a Future of the asynchronous result |
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
|
Future<Void> |
HttpServerResponse.end(Buffer chunk)
Same as
HttpServerResponse.end() but writes some data to the response body before ending. |
Future<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.
|
Future<Buffer> |
HttpConnection.ping(Buffer data)
Same as
HttpConnection.ping(Buffer, Handler) but returns a Future of the asynchronous result |
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.
|
default Future<Void> |
HttpServerResponse.send(Buffer body)
Like
HttpServerResponse.send(Buffer, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClientRequest.send(Buffer body)
Like
HttpClientRequest.send(Buffer, Handler) but returns a Future of the asynchronous result |
default void |
HttpClientRequest.send(Buffer body,
Handler<AsyncResult<HttpClientResponse>> handler)
Send the request with a buffer
body . |
default void |
HttpServerResponse.send(Buffer body,
Handler<AsyncResult<Void>> handler)
Send the request with a buffer
body . |
GoAway |
GoAway.setDebugData(Buffer debugData)
Set the additional debug data
|
Future<Void> |
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.
|
Future<Void> |
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 |
Future<Void> |
WebSocketBase.writePing(Buffer data)
Like
WebSocketBase.writePing(Buffer, Handler) but with an handler called when the message has been written
or failed to be written. |
WebSocketBase |
WebSocketBase.writePing(Buffer data,
Handler<AsyncResult<Void>> handler)
Writes a ping frame to the connection.
|
Future<Void> |
WebSocketBase.writePong(Buffer data)
Like
WebSocketBase.writePong(Buffer, Handler) but with an handler called when the message has been written
or failed to be written. |
WebSocketBase |
WebSocketBase.writePong(Buffer data,
Handler<AsyncResult<Void>> handler)
Writes a pong frame to the connection.
|
Modifier and Type | Method and Description |
---|---|
default HttpClientResponse |
HttpClientResponse.body(Handler<AsyncResult<Buffer>> handler)
Same as
HttpClientResponse.body() but with an handler called when the operation completes |
default HttpServerRequest |
HttpServerRequest.body(Handler<AsyncResult<Buffer>> handler)
Same as
HttpServerRequest.body() but with an handler called when the operation completes |
default 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.
|
default Future<Void> |
HttpServerResponse.send(ReadStream<Buffer> body)
Like
HttpServerResponse.send(ReadStream, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClientRequest.send(ReadStream<Buffer> body)
Like
HttpClientRequest.send(ReadStream, Handler) but returns a Future of the asynchronous result |
default void |
HttpClientRequest.send(ReadStream<Buffer> body,
Handler<AsyncResult<HttpClientResponse>> handler)
Send the request with a stream
body . |
default void |
HttpServerResponse.send(ReadStream<Buffer> body,
Handler<AsyncResult<Void>> handler)
Send the request with a stream
body . |
Modifier and Type | Method and Description |
---|---|
static Buffer |
Json.encodeToBuffer(Object obj)
Encode a POJO to JSON using the underlying Jackson mapper.
|
Buffer |
JsonArray.getBuffer(int pos)
Get the Buffer at position
pos in the array. |
Buffer |
JsonObject.getBuffer(String key)
Get the
Buffer value with the specified key. |
Buffer |
JsonObject.getBuffer(String key,
Buffer def)
Like
JsonObject.getBuffer(String) but specifying a default value to return if there is no entry. |
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.
|
Buffer |
JsonObject.getBuffer(String key,
Buffer def)
Like
JsonObject.getBuffer(String) but specifying a default value to return if there is no entry. |
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) |
Buffer |
DatabindCodec.toBuffer(Object object,
boolean pretty) |
Modifier and Type | Method and Description |
---|---|
static JsonParser |
JacksonCodec.createParser(Buffer buf) |
static JsonParser |
DatabindCodec.createParser(Buffer buf) |
static <T> T |
JacksonCodec.decodeValue(Buffer buf,
TypeReference<T> type)
Decode a given JSON buffer to a POJO of the given class type.
|
Object |
JacksonCodec.fromBuffer(Buffer buf) |
<T> T |
JacksonCodec.fromBuffer(Buffer json,
Class<T> clazz) |
<T> T |
DatabindCodec.fromBuffer(Buffer buf,
Class<T> clazz) |
<T> T |
JacksonCodec.fromBuffer(Buffer buf,
TypeReference<T> typeRef) |
<T> T |
DatabindCodec.fromBuffer(Buffer buf,
TypeReference<T> typeRef) |
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
|
void |
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 |
---|---|
int |
RegistrationInfo.readFromBuffer(int start,
Buffer buffer) |
int |
NodeInfo.readFromBuffer(int start,
Buffer buffer) |
void |
RegistrationInfo.writeToBuffer(Buffer buffer) |
void |
NodeInfo.writeToBuffer(Buffer buffer) |
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 |
---|---|
Buffer |
PubSecKeyOptions.getBuffer()
The PEM or Secret key buffer.
|
Buffer |
KeyStoreOptions.getValue()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
PubSecKeyOptions |
PubSecKeyOptions.setBuffer(Buffer buffer)
The PEM or Secret key buffer.
|
KeyStoreOptions |
KeyStoreOptions.setValue(Buffer value)
Deprecated.
|
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 |
---|---|
ReadStream<Buffer> |
MailAttachment.getStream()
Gets the data stream.
|
Modifier and Type | Method and Description |
---|---|
MailConfig |
MailConfig.addCrlValue(Buffer crlValue) |
MailAttachment |
MailAttachment.setData(Buffer data)
set the data
|
Modifier and Type | Method and Description |
---|---|
MailAttachment |
MailAttachment.setStream(ReadStream<Buffer> stream)
Sets the data stream.
|
Modifier and Type | Method and Description |
---|---|
ReadStream<Buffer> |
EncodedPart.bodyStream(Context context) |
ReadStream<Buffer> |
EncodedPart.dkimBodyStream(Context context) |
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 |
---|---|
Future<Frame> |
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<AsyncResult<Frame>> receiptHandler)
Sends a
SEND frame to the server. |
Future<Frame> |
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<AsyncResult<Frame>> receiptHandler)
Sends a
SEND frame to the server to the given destination. |
Future<Frame> |
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<AsyncResult<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(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 |
---|---|
default Future<Void> |
RoutingContext.end(Buffer buffer)
Shortcut to the response end.
|
default RoutingContext |
RoutingContext.end(Buffer buffer,
Handler<AsyncResult<Void>> handler)
|
void |
RoutingContext.setBody(Buffer body)
Set the body.
|
Modifier and Type | Method and Description |
---|---|
Buffer |
OperationResponse.getPayload()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static OperationResponse |
OperationResponse.completedWithJson(Buffer json)
Deprecated.
|
static OperationResponse |
OperationResponse.completedWithPlainText(Buffer text)
Deprecated.
|
OperationResponse |
OperationResponse.setPayload(Buffer payload)
Deprecated.
|
Constructor and Description |
---|
OperationResponse(Integer statusCode,
String statusMessage,
Buffer payload,
MultiMap headers)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Buffer |
ServiceResponse.getPayload() |
Modifier and Type | Method and Description |
---|---|
static ServiceResponse |
ServiceResponse.completedWithJson(Buffer json)
Creates a
ServiceResponse with status code 200, status message OK, content type application/json and json as body |
static ServiceResponse |
ServiceResponse.completedWithPlainText(Buffer text)
Creates a
ServiceResponse with status code 200, status message OK, content type text/plain and text as body |
ServiceResponse |
ServiceResponse.setPayload(Buffer payload) |
Constructor and Description |
---|
ServiceResponse(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.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 |
---|---|
CachingWebClientOptions |
CachingWebClientOptions.addCrlValue(Buffer crlValue) |
WebClientOptions |
WebClientOptions.addCrlValue(Buffer crlValue) |
default HttpRequest<T> |
HttpRequest.basicAuthentication(Buffer id,
Buffer password)
Configure the request to perform basic access authentication.
|
default Future<HttpResponse<T>> |
HttpRequest.sendBuffer(Buffer body) |
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 |
---|---|
default Future<HttpResponse<T>> |
HttpRequest.sendStream(ReadStream<Buffer> body) |
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 Future<Buffer> |
TemplateEngine.render(JsonObject context,
String templateFileName) |
default Future<Buffer> |
TemplateEngine.render(Map<String,Object> context,
String templateFileName) |
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 Future<Void> |
SockJSSocket.write(Buffer data) |
void |
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 |
---|---|
Buffer |
RequestParameter.getBuffer() |
Modifier and Type | Method and Description |
---|---|
ReadStream<Buffer> |
Body.stream()
Get stream of the
Body . |
Modifier and Type | Method and Description |
---|---|
static Body |
Body.body(Buffer buffer)
Create a new
Body instance. |
Modifier and Type | Method and Description |
---|---|
static Body |
Body.body(ReadStream<Buffer> stream)
Create a new
Body instance. |
static Body |
Body.body(ReadStream<Buffer> stream,
long len)
Create a new
Body instance. |
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 |
---|---|
Buffer |
MqttWill.getWillMessage() |
Modifier and Type | Method and Description |
---|---|
MqttClientOptions |
MqttClientOptions.addCrlValue(Buffer crlValue) |
MqttServerOptions |
MqttServerOptions.addCrlValue(Buffer crlValue) |
Future<Integer> |
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
|
Future<Integer> |
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
|
Future<Integer> |
MqttEndpoint.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
int messageId)
Like
MqttEndpoint.publish(String, Buffer, MqttQoS, boolean, boolean, int, Handler) but returns a Future of the asynchronous result |
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
|
Future<Integer> |
MqttEndpoint.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
int messageId,
io.netty.handler.codec.mqtt.MqttProperties properties)
Like
MqttEndpoint.publish(String, Buffer, MqttQoS, boolean, boolean, int, MqttProperties, Handler) but returns a Future of the asynchronous result |
MqttEndpoint |
MqttEndpoint.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
int messageId,
io.netty.handler.codec.mqtt.MqttProperties properties,
Handler<AsyncResult<Integer>> publishSentHandler)
Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageId
|
Constructor and Description |
---|
MqttWill(boolean isWillFlag,
String willTopic,
Buffer willMessage,
int willQos,
boolean isWillRetain,
io.netty.handler.codec.mqtt.MqttProperties willProperties)
Constructor
|
Modifier and Type | Method and Description |
---|---|
Buffer |
MqttPublishMessage.payload() |
Modifier and Type | Method and Description |
---|---|
MSSQLConnectOptions |
MSSQLConnectOptions.addCrlValue(Buffer crlValue) |
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 |
---|---|
Future<Void> |
RabbitMQClient.basicPublish(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body)
Like
RabbitMQClient.basicPublish(String, String, BasicProperties, Buffer, Handler) but returns a Future of the asynchronous result |
void |
RabbitMQClient.basicPublish(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body,
Handler<AsyncResult<Void>> resultHandler)
Publish a message.
|
Future<Void> |
RabbitMQClient.basicPublish(String exchange,
String routingKey,
Buffer body)
Like
RabbitMQClient.basicPublish(String, String, Buffer, Handler) but returns a Future of the asynchronous result |
void |
RabbitMQClient.basicPublish(String exchange,
String routingKey,
Buffer body,
Handler<AsyncResult<Void>> resultHandler)
Publish a message.
|
Future<Void> |
RabbitMQClient.basicPublishWithDeliveryTag(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body,
Handler<Long> deliveryTagHandler)
Publish a message.
|
void |
RabbitMQClient.basicPublishWithDeliveryTag(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body,
Handler<Long> deliveryTagHandler,
Handler<AsyncResult<Void>> resultHandler)
Publish a message.
|
Future<Void> |
RabbitMQPublisher.publish(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body)
Like
#basicPublish(String, String, BasicProperties, Buffer, Handler) but returns a Future of the asynchronous result |
void |
RabbitMQPublisher.publish(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body,
Handler<AsyncResult<Void>> resultHandler)
Publish a message.
|
Modifier and Type | Method and Description |
---|---|
static <T> MaybeTransformer<Buffer,T> |
MaybeHelper.unmarshaller(Class<T> mappedType) |
static <T> SingleTransformer<Buffer,T> |
SingleHelper.unmarshaller(Class<T> mappedType) |
static <T> FlowableTransformer<Buffer,T> |
FlowableHelper.unmarshaller(Class<T> mappedType) |
static <T> ObservableTransformer<Buffer,T> |
ObservableHelper.unmarshaller(Class<T> mappedType) |
static <T> MaybeTransformer<Buffer,T> |
MaybeHelper.unmarshaller(Class<T> mappedType,
ObjectCodec mapper) |
static <T> SingleTransformer<Buffer,T> |
SingleHelper.unmarshaller(Class<T> mappedType,
ObjectCodec mapper) |
static <T> FlowableTransformer<Buffer,T> |
FlowableHelper.unmarshaller(Class<T> mappedType,
ObjectCodec mapper) |
static <T> ObservableTransformer<Buffer,T> |
ObservableHelper.unmarshaller(Class<T> mappedType,
ObjectCodec mapper) |
static <T> MaybeTransformer<Buffer,T> |
MaybeHelper.unmarshaller(TypeReference<T> mappedTypeRef) |
static <T> SingleTransformer<Buffer,T> |
SingleHelper.unmarshaller(TypeReference<T> mappedTypeRef) |
static <T> FlowableTransformer<Buffer,T> |
FlowableHelper.unmarshaller(TypeReference<T> mappedTypeRef) |
static <T> ObservableTransformer<Buffer,T> |
ObservableHelper.unmarshaller(TypeReference<T> mappedTypeRef) |
static <T> MaybeTransformer<Buffer,T> |
MaybeHelper.unmarshaller(TypeReference<T> mappedTypeRef,
ObjectCodec mapper) |
static <T> SingleTransformer<Buffer,T> |
SingleHelper.unmarshaller(TypeReference<T> mappedTypeRef,
ObjectCodec mapper) |
static <T> FlowableTransformer<Buffer,T> |
FlowableHelper.unmarshaller(TypeReference<T> mappedTypeRef,
ObjectCodec mapper) |
static <T> ObservableTransformer<Buffer,T> |
ObservableHelper.unmarshaller(TypeReference<T> mappedTypeRef,
ObjectCodec mapper) |
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 |
---|---|
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 |
---|---|
abstract Buffer |
UnmarshallerOperator.unwrap(B buffer) |
Modifier and Type | Method and Description |
---|---|
static <T> Observable.Operator<T,Buffer> |
RxHelper.unmarshaller(Class<T> mappedType)
Returns a json unmarshaller for the specified java type as a
Observable.Operator instance.
The marshaller can be used with the Observable.lift(rx.Observable.Operator) method to transform
a Observable<Buffer> into a Observable<T>.
The unmarshaller buffers the content until onComplete is called, then unmarshalling happens.
Note that the returned observable will emit at most a single object. |
static <T> Observable.Operator<T,Buffer> |
RxHelper.unmarshaller(Class<T> mappedType,
ObjectCodec mapper)
Returns a unmarshaller for the specified java type as a
Observable.Operator instance given the
the provided ObjectMapper
The marshaller can be used with the Observable.lift(rx.Observable.Operator) method to transform
a Observable<Buffer> into a Observable<T>.
The unmarshaller buffers the content until onComplete is called, then unmarshalling happens.
Note that the returned observable will emit at most a single object. |
static <T> Observable.Operator<T,Buffer> |
RxHelper.unmarshaller(TypeReference<T> mappedTypeRef)
Returns a json unmarshaller for the specified java type as a
Observable.Operator instance.
The marshaller can be used with the Observable.lift(rx.Observable.Operator) method to transform
a Observable<Buffer> into a Observable<T>.
The unmarshaller buffers the content until onComplete is called, then unmarshalling happens.
Note that the returned observable will emit at most a single object. |
static <T> Observable.Operator<T,Buffer> |
RxHelper.unmarshaller(TypeReference<T> mappedTypeRef,
ObjectCodec mapper)
Returns a unmarshaller for the specified java type as a
Observable.Operator instance given the
the provided ObjectMapper
The marshaller can be used with the Observable.lift(rx.Observable.Operator) method to transform
a Observable<Buffer> into a Observable<T>.
The unmarshaller buffers the content until onComplete is called, then unmarshalling happens.
Note that the returned observable will emit at most a single object. |
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 |
---|---|
static <T> MaybeTransformer<Buffer,T> |
MaybeHelper.unmarshaller(Class<T> mappedType) |
static <T> SingleTransformer<Buffer,T> |
SingleHelper.unmarshaller(Class<T> mappedType) |
static <T> FlowableTransformer<Buffer,T> |
FlowableHelper.unmarshaller(Class<T> mappedType) |
static <T> ObservableTransformer<Buffer,T> |
ObservableHelper.unmarshaller(Class<T> mappedType) |
static <T> MaybeTransformer<Buffer,T> |
MaybeHelper.unmarshaller(Class<T> mappedType,
ObjectCodec mapper) |
static <T> SingleTransformer<Buffer,T> |
SingleHelper.unmarshaller(Class<T> mappedType,
ObjectCodec mapper) |
static <T> FlowableTransformer<Buffer,T> |
FlowableHelper.unmarshaller(Class<T> mappedType,
ObjectCodec mapper) |
static <T> ObservableTransformer<Buffer,T> |
ObservableHelper.unmarshaller(Class<T> mappedType,
ObjectCodec mapper) |
static <T> MaybeTransformer<Buffer,T> |
MaybeHelper.unmarshaller(TypeReference<T> mappedTypeRef) |
static <T> SingleTransformer<Buffer,T> |
SingleHelper.unmarshaller(TypeReference<T> mappedTypeRef) |
static <T> FlowableTransformer<Buffer,T> |
FlowableHelper.unmarshaller(TypeReference<T> mappedTypeRef) |
static <T> ObservableTransformer<Buffer,T> |
ObservableHelper.unmarshaller(TypeReference<T> mappedTypeRef) |
static <T> MaybeTransformer<Buffer,T> |
MaybeHelper.unmarshaller(TypeReference<T> mappedTypeRef,
ObjectCodec mapper) |
static <T> SingleTransformer<Buffer,T> |
SingleHelper.unmarshaller(TypeReference<T> mappedTypeRef,
ObjectCodec mapper) |
static <T> FlowableTransformer<Buffer,T> |
FlowableHelper.unmarshaller(TypeReference<T> mappedTypeRef,
ObjectCodec mapper) |
static <T> ObservableTransformer<Buffer,T> |
ObservableHelper.unmarshaller(TypeReference<T> mappedTypeRef,
ObjectCodec mapper) |
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 . |
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.
|
Modifier and Type | Method and Description |
---|---|
HttpSenderOptions |
HttpSenderOptions.addCrlValue(Buffer crlValue) |
Copyright © 2022 Eclipse. All rights reserved.