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 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. |
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) |
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.
|
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
|
WebSocketBase |
WebSocketBase.writePing(Buffer data)
Writes a ping to the connection.
|
WebSocketBase |
WebSocketBase.writePong(Buffer data)
Writes a pong 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 <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)
Decode a given JSON buffer to a POJO of the given class type.
|
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 |
PemKeyCertOptions.getCertValue()
Get the first certificate as a buffer
|
Buffer |
PemKeyCertOptions.getKeyValue()
Get the first key as a buffer
|
Buffer |
PfxOptions.getValue()
Get the store as a buffer
|
Buffer |
JksOptions.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
|
PfxOptions |
PfxOptions.setValue(Buffer value)
Set the 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 |
---|---|
int |
AbstractUser.readFromBuffer(int pos,
Buffer buffer) |
void |
AbstractUser.writeToBuffer(Buffer buff) |
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)
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.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,
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,
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) |
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.
|
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 |
---|---|
SockJSSocket |
SockJSSocket.write(Buffer data) |
Modifier and Type | Method and Description |
---|---|
SockJSSocket |
SockJSSocket.handler(Handler<Buffer> handler) |
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
|
Modifier and Type | Method and Description |
---|---|
Buffer |
MqttPublishMessage.payload() |
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)
Set the binary string value of a key - without encoding as utf-8
|
RedisClient |
RedisClient.setBinary(String key,
Buffer value,
Handler<AsyncResult<Void>> handler)
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)
Set the string value of a key
|
RedisClient |
RedisClient.setBinaryWithOptions(String key,
Buffer value,
SetOptions options,
Handler<AsyncResult<Void>> handler)
Set the string value of a key
|
Modifier and Type | Method and Description |
---|---|
RedisTransaction |
RedisTransaction.getBinary(String key,
Handler<AsyncResult<Buffer>> handler)
Get the value of a key - without decoding as utf-8
|
RedisClient |
RedisClient.getBinary(String key,
Handler<AsyncResult<Buffer>> handler)
Get the value of a key - without decoding as utf-8
|
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) |
Copyright © 2018 Eclipse. All rights reserved.