Skip to content

Commit c02020a

Browse files
committed
Fixed MqttChannelInitializerSslTest
1 parent 6a15873 commit c02020a

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

src/test/java/com/hivemq/client/internal/mqtt/handler/MqttChannelInitializerSslTest.java

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@
2626
import com.hivemq.client.internal.mqtt.handler.disconnect.MqttDisconnectHandler;
2727
import com.hivemq.client.internal.mqtt.handler.websocket.MqttWebSocketInitializer;
2828
import com.hivemq.client.internal.mqtt.message.connect.MqttConnect;
29-
import com.hivemq.client.mqtt.MqttVersion;
3029
import dagger.Lazy;
3130
import io.netty.channel.Channel;
3231
import io.netty.channel.embedded.EmbeddedChannel;
@@ -36,8 +35,6 @@
3635
import org.mockito.Mock;
3736
import org.mockito.MockitoAnnotations;
3837

39-
import java.util.Optional;
40-
4138
import static org.junit.Assert.assertNotNull;
4239
import static org.mockito.Mockito.mock;
4340
import static org.mockito.Mockito.when;
@@ -71,15 +68,13 @@ public class MqttChannelInitializerSslTest {
7168
public void before() {
7269
MockitoAnnotations.initMocks(this);
7370
channel = new EmbeddedChannel();
74-
when(clientData.getSslConfig()).thenReturn(Optional.empty());
7571
}
7672

7773
@Test
7874
public void test_initialize_default_ssldata() throws Exception {
79-
when(clientData.getMqttVersion()).thenReturn(MqttVersion.MQTT_5_0);
8075
final MqttClientTransportConfigImpl transportConfig = mock(MqttClientTransportConfigImpl.class);
8176
final MqttClientSslConfigImpl sslConfig = mock(MqttClientSslConfigImpl.class);
82-
when(clientData.getTransportConfig()).thenReturn(transportConfig);
77+
when(connAckFlow.getTransportConfig()).thenReturn(transportConfig);
8378
when(transportConfig.getRawSslConfig()).thenReturn(sslConfig);
8479

8580
final MqttChannelInitializer mqttChannelInitializer =

0 commit comments

Comments
 (0)