Skip to content

Commit 917d68f

Browse files
committed
[reactor] improved package structure (mqtt.reactor.mqtt5 -> mqtt.mqtt5.reactor)
1 parent 5063e3c commit 917d68f

File tree

4 files changed

+6
-6
lines changed

4 files changed

+6
-6
lines changed

reactor/src/main/java/com/hivemq/client/internal/mqtt/reactor/mqtt3/Mqtt3ReactorClientView.java renamed to reactor/src/main/java/com/hivemq/client/internal/mqtt/mqtt3/reactor/Mqtt3ReactorClientView.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
*
1616
*/
1717

18-
package com.hivemq.client.internal.mqtt.reactor.mqtt3;
18+
package com.hivemq.client.internal.mqtt.mqtt3.reactor;
1919

2020
import com.hivemq.client.mqtt.MqttGlobalPublishFilter;
2121
import com.hivemq.client.mqtt.mqtt3.Mqtt3AsyncClient;
@@ -30,7 +30,7 @@
3030
import com.hivemq.client.mqtt.mqtt3.message.subscribe.suback.Mqtt3SubAck;
3131
import com.hivemq.client.mqtt.mqtt3.message.unsubscribe.Mqtt3Unsubscribe;
3232
import com.hivemq.client.mqtt.mqtt3.message.unsubscribe.unsuback.Mqtt3UnsubAck;
33-
import com.hivemq.client.mqtt.reactor.mqtt3.Mqtt3ReactorClient;
33+
import com.hivemq.client.mqtt.mqtt3.reactor.Mqtt3ReactorClient;
3434
import com.hivemq.client.rx.reactor.FluxWithSingle;
3535
import io.reactivex.Flowable;
3636
import org.jetbrains.annotations.NotNull;

reactor/src/main/java/com/hivemq/client/internal/mqtt/reactor/MqttReactorClient.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
import com.hivemq.client.mqtt.mqtt5.message.subscribe.suback.Mqtt5SubAck;
3232
import com.hivemq.client.mqtt.mqtt5.message.unsubscribe.Mqtt5Unsubscribe;
3333
import com.hivemq.client.mqtt.mqtt5.message.unsubscribe.unsuback.Mqtt5UnsubAck;
34-
import com.hivemq.client.mqtt.reactor.mqtt5.Mqtt5ReactorClient;
34+
import com.hivemq.client.mqtt.mqtt5.reactor.Mqtt5ReactorClient;
3535
import com.hivemq.client.rx.reactor.FluxWithSingle;
3636
import io.reactivex.Flowable;
3737
import org.jetbrains.annotations.NotNull;

reactor/src/main/java/com/hivemq/client/mqtt/reactor/mqtt3/Mqtt3ReactorClient.java renamed to reactor/src/main/java/com/hivemq/client/mqtt/mqtt3/reactor/Mqtt3ReactorClient.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -15,14 +15,14 @@
1515
*
1616
*/
1717

18-
package com.hivemq.client.mqtt.reactor.mqtt3;
18+
package com.hivemq.client.mqtt.mqtt3.reactor;
1919

2020
import com.hivemq.client.annotations.DoNotImplement;
2121
import com.hivemq.client.internal.mqtt.message.connect.mqtt3.Mqtt3ConnectView;
2222
import com.hivemq.client.internal.mqtt.message.connect.mqtt3.Mqtt3ConnectViewBuilder;
2323
import com.hivemq.client.internal.mqtt.message.subscribe.mqtt3.Mqtt3SubscribeViewBuilder;
2424
import com.hivemq.client.internal.mqtt.message.unsubscribe.mqtt3.Mqtt3UnsubscribeViewBuilder;
25-
import com.hivemq.client.internal.mqtt.reactor.mqtt3.Mqtt3ReactorClientView;
25+
import com.hivemq.client.internal.mqtt.mqtt3.reactor.Mqtt3ReactorClientView;
2626
import com.hivemq.client.mqtt.MqttGlobalPublishFilter;
2727
import com.hivemq.client.mqtt.mqtt3.Mqtt3Client;
2828
import com.hivemq.client.mqtt.mqtt3.message.connect.Mqtt3Connect;

reactor/src/main/java/com/hivemq/client/mqtt/reactor/mqtt5/Mqtt5ReactorClient.java renamed to reactor/src/main/java/com/hivemq/client/mqtt/mqtt5/reactor/Mqtt5ReactorClient.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
*
1616
*/
1717

18-
package com.hivemq.client.mqtt.reactor.mqtt5;
18+
package com.hivemq.client.mqtt.mqtt5.reactor;
1919

2020
import com.hivemq.client.annotations.DoNotImplement;
2121
import com.hivemq.client.internal.mqtt.message.connect.MqttConnect;

0 commit comments

Comments
 (0)