| Package | Description |
|---|---|
| io.vertx.core.impl | |
| io.vertx.core.net.impl | |
| io.vertx.db2client.impl | |
| io.vertx.mqtt.impl | |
| io.vertx.mysqlclient.impl | |
| io.vertx.pgclient.impl | |
| io.vertx.sqlclient.impl |
| Modifier and Type | Method and Description |
|---|---|
NetSocketInternal |
NetSocketInternal.messageHandler(Handler<Object> handler)
Set a
handler on this socket to process the messages produced by this socket. |
NetSocketInternal |
NetSocketInternal.writeMessage(Object message)
Write a message in the channel pipeline.
|
NetSocketInternal |
NetSocketInternal.writeMessage(Object message,
Handler<AsyncResult<Void>> handler)
Like
writeMessage(Object) but with an handler called when the message has been written
or failed to be written. |
| Modifier and Type | Class and Description |
|---|---|
class |
NetSocketImpl
This class is optimised for performance when used on the same event loop that is was passed to the handler with.
|
| Modifier and Type | Method and Description |
|---|---|
NetSocketInternal |
NetSocketImpl.messageHandler(Handler<Object> handler) |
NetSocketInternal |
NetSocketImpl.writeMessage(Object message) |
NetSocketInternal |
NetSocketImpl.writeMessage(Object message,
Handler<AsyncResult<Void>> handler) |
| Constructor and Description |
|---|
DB2SocketConnection(NetSocketInternal socket,
boolean cachePreparedStatements,
int preparedStatementCacheSize,
int preparedStatementCacheSqlLimit,
int pipeliningLimit,
Context context) |
| Constructor and Description |
|---|
MqttEndpointImpl(NetSocketInternal conn,
String clientIdentifier,
MqttAuth auth,
MqttWill will,
boolean isCleanSession,
int protocolVersion,
String protocolName,
int keepAliveTimeoutSeconds)
Constructor
|
MqttServerConnection(NetSocketInternal so,
MqttServerOptions options) |
| Constructor and Description |
|---|
MySQLSocketConnection(NetSocketInternal socket,
boolean cachePreparedStatements,
int preparedStatementCacheSize,
int preparedStatementCacheSqlLimit,
Context context) |
| Constructor and Description |
|---|
PgSocketConnection(NetSocketInternal socket,
boolean cachePreparedStatements,
int preparedStatementCacheSize,
int preparedStatementCacheSqlLimit,
int pipeliningLimit,
Context context) |
| Modifier and Type | Field and Description |
|---|---|
protected NetSocketInternal |
SocketConnectionBase.socket |
| Modifier and Type | Method and Description |
|---|---|
NetSocketInternal |
SocketConnectionBase.socket() |
| Constructor and Description |
|---|
SocketConnectionBase(NetSocketInternal socket,
boolean cachePreparedStatements,
int preparedStatementCacheSize,
int preparedStatementCacheSqlLimit,
int pipeliningLimit,
Context context) |
Copyright © 2020. All rights reserved.