Skip to content

Commit 6e15f5c

Browse files
committed
Map cause in Mqtt3ClientDisconnectedContext
1 parent fb4e70a commit 6e15f5c

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/main/java/com/hivemq/client/internal/mqtt/lifecycle/mqtt3/Mqtt3ClientDisconnectedContextView.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import com.hivemq.client.internal.mqtt.MqttClientConfig;
2121
import com.hivemq.client.internal.mqtt.lifecycle.MqttClientReconnector;
2222
import com.hivemq.client.internal.mqtt.mqtt3.Mqtt3ClientConfigView;
23+
import com.hivemq.client.internal.mqtt.mqtt3.exceptions.Mqtt3ExceptionFactory;
2324
import com.hivemq.client.mqtt.lifecycle.MqttClientDisconnectedContext;
2425
import com.hivemq.client.mqtt.lifecycle.MqttDisconnectSource;
2526
import com.hivemq.client.mqtt.mqtt3.lifecycle.Mqtt3ClientDisconnectedContext;
@@ -34,8 +35,8 @@ public class Mqtt3ClientDisconnectedContextView implements Mqtt3ClientDisconnect
3435
final @NotNull MqttClientConfig clientConfig, final @NotNull MqttDisconnectSource source,
3536
final @NotNull Throwable cause, final @NotNull MqttClientReconnector reconnector) {
3637

37-
return new Mqtt3ClientDisconnectedContextView(
38-
new Mqtt3ClientConfigView(clientConfig), source, cause, new Mqtt3ClientReconnectorView(reconnector));
38+
return new Mqtt3ClientDisconnectedContextView(new Mqtt3ClientConfigView(clientConfig), source,
39+
Mqtt3ExceptionFactory.map(cause), new Mqtt3ClientReconnectorView(reconnector));
3940
}
4041

4142
private final @NotNull Mqtt3ClientConfigView clientConfig;

0 commit comments

Comments
 (0)