Fixed method names and log messages

amitjoy · Dec 12, 2023 · 2c03858 · 2c03858
1 parent 607ebe2
commit 2c03858
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...tt5.provider/src/main/java/in/bytehue/messaging/mqtt5/provider/MessageClientProvider.java b/...tt5.provider/src/main/java/in/bytehue/messaging/mqtt5/provider/MessageClientProvider.java
@@ -333,11 +333,11 @@ private void disconnect(final boolean isNormalDisconnection) {
     	          .reasonCode(reasonCode)
                   .reasonString(reasonDescription);
 
-		if (config.useSessionExpiryIntervalForDisconnect()) {
+		if (config.useSessionExpiryForDisconnect()) {
 			logger.debug("Applying Session Expiry Interval for Disconnect: {}", config.sessionExpiryIntervalForDisconnect());
 			disconnectParams.sessionExpiryInterval(config.sessionExpiryIntervalForDisconnect());
 		} else {
-			logger.debug("Session Expiry Interval for Disconnect is not enabled");
+			logger.debug("Session Expiry for Disconnect is not enabled");
 			disconnectParams.noSessionExpiry();
 		}
 		disconnectParams.send();
@@ -541,11 +541,11 @@ private void connect() {
 		           .cleanStart(config.cleanStart())
 		           .keepAlive(config.keepAliveInterval());
 
-		if (config.useSessionExpiryInterval()) {
+		if (config.useSessionExpiry()) {
 			logger.debug("Applying Session Expiry Interval: {}", config.sessionExpiryInterval());
 			connectionParams.sessionExpiryInterval(config.sessionExpiryInterval());
 		} else {
-			logger.debug("Session Expiry Interval is not enabled");
+			logger.debug("Session Expiry is not enabled");
 			connectionParams.noSessionExpiry();
 		}