Skip to content

Add localAddress and remoteAddress for MqttClient #256

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
zhou-hao wants to merge 4 commits into
base: master
Choose a base branch
from
Open

Add localAddress and remoteAddress for MqttClient #256

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
424fbc1
Update MqttClient.java
zhou-hao Jun 9, 2025
04c0908
Update MqttClientImpl.java
zhou-hao Jun 9, 2025
7255081
Update MqttClient.java
zhou-hao Jun 10, 2025
fc36be1
Update MqttClientImpl.java
zhou-hao Jun 10, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 16 additions & 0 deletions src/main/java/io/vertx/mqtt/MqttClient.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,10 +19,12 @@
import io.netty.handler.codec.mqtt.MqttQoS;
import io.vertx.codegen.annotations.Fluent;
import io.vertx.codegen.annotations.VertxGen;
import io.vertx.codegen.annotations.CacheReturn;
import io.vertx.core.Future;
import io.vertx.core.Handler;
import io.vertx.core.Vertx;
import io.vertx.core.buffer.Buffer;
import io.vertx.core.net.SocketAddress;
import io.vertx.mqtt.impl.MqttClientImpl;
import io.vertx.mqtt.messages.MqttAuthenticationExchangeMessage;
import io.vertx.mqtt.messages.MqttConnAckMessage;
Expand Down Expand Up @@ -268,4 +270,18 @@ static MqttClient create(Vertx vertx) {
* @return if the connection between client and remote server is established/open
*/
boolean isConnected();

/**
* @return the remote address for this connection, possibly {@code null} (e.g a server bound on a domain socket).
* If {@code useProxyProtocol} is set to {@code true}, the address returned will be of the actual connecting client.
*/
@CacheReturn
SocketAddress remoteAddress();

/**
* @return the local address for this connection, possibly {@code null} (e.g a server bound on a domain socket)
* If {@code useProxyProtocol} is set to {@code true}, the address returned will be of the proxy.
*/
@CacheReturn
SocketAddress localAddress();
}
13 changes: 13 additions & 0 deletions src/main/java/io/vertx/mqtt/impl/MqttClientImpl.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@
import io.vertx.core.internal.logging.Logger;
import io.vertx.core.internal.logging.LoggerFactory;
import io.vertx.core.net.NetClient;
import io.vertx.core.net.SocketAddress;
import io.vertx.mqtt.MqttClient;
import io.vertx.mqtt.MqttClientOptions;
import io.vertx.mqtt.MqttConnectionException;
Expand Down Expand Up @@ -168,6 +169,18 @@ int getInFlightMessagesCount() {
}
}


@Override
public SocketAddress localAddress() {
return connection.localAddress();
}

@Override
public SocketAddress remoteAddress() {
return connection.remoteAddress();
}


@Override
public Future<MqttConnAckMessage> connect(int port, String host) {

Expand Down