diff --git a/bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/handler/BridgePacketHandler.java b/bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/handler/BridgePacketHandler.java deleted file mode 100644 index 965e4c1..0000000 --- a/bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/handler/BridgePacketHandler.java +++ /dev/null @@ -1,8 +0,0 @@ -package com.luminia.bridge.network.codec.packet.handler; - -import com.luminia.bridge.network.codec.packet.BridgePacket; -import com.luminia.bridge.network.codec.packet.BridgePacketDirection; - -public interface BridgePacketHandler { - void handle(BridgePacket packet, BridgePacketDirection direction, String serviceId); -} diff --git a/bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/serializer/BridgePacketSerializer.java b/bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/serializer/BridgePacketSerializer.java deleted file mode 100644 index 56b67e1..0000000 --- a/bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/serializer/BridgePacketSerializer.java +++ /dev/null @@ -1,11 +0,0 @@ -package com.luminia.bridge.network.codec.packet.serializer; - -import com.luminia.bridge.network.codec.packet.BridgePacket; -import com.luminia.bridge.util.ByteBuffer; - -public interface BridgePacketSerializer { - - void serialize(ByteBuffer buffer, T packet); - - void deserialize(ByteBuffer buffer, T packet); -} diff --git a/bridge-common/src/main/java/com/luminia/bridge/exception/BridgeCodecException.java b/bridge-common/src/main/java/com/luminiadev/bridge/exception/BridgeCodecException.java similarity index 88% rename from bridge-common/src/main/java/com/luminia/bridge/exception/BridgeCodecException.java rename to bridge-common/src/main/java/com/luminiadev/bridge/exception/BridgeCodecException.java index e2820b3..dc89bd6 100644 --- a/bridge-common/src/main/java/com/luminia/bridge/exception/BridgeCodecException.java +++ b/bridge-common/src/main/java/com/luminiadev/bridge/exception/BridgeCodecException.java @@ -1,4 +1,4 @@ -package com.luminia.bridge.exception; +package com.luminiadev.bridge.exception; public class BridgeCodecException extends BridgeException { diff --git a/bridge-common/src/main/java/com/luminia/bridge/exception/BridgeException.java b/bridge-common/src/main/java/com/luminiadev/bridge/exception/BridgeException.java similarity index 88% rename from bridge-common/src/main/java/com/luminia/bridge/exception/BridgeException.java rename to bridge-common/src/main/java/com/luminiadev/bridge/exception/BridgeException.java index 743ab9e..45eac32 100644 --- a/bridge-common/src/main/java/com/luminia/bridge/exception/BridgeException.java +++ b/bridge-common/src/main/java/com/luminiadev/bridge/exception/BridgeException.java @@ -1,4 +1,4 @@ -package com.luminia.bridge.exception; +package com.luminiadev.bridge.exception; public class BridgeException extends RuntimeException { diff --git a/bridge-common/src/main/java/com/luminia/bridge/network/AbstractBridgeNetwork.java b/bridge-common/src/main/java/com/luminiadev/bridge/network/AbstractBridgeNetwork.java similarity index 79% rename from bridge-common/src/main/java/com/luminia/bridge/network/AbstractBridgeNetwork.java rename to bridge-common/src/main/java/com/luminiadev/bridge/network/AbstractBridgeNetwork.java index b982d7b..39b2c8f 100644 --- a/bridge-common/src/main/java/com/luminia/bridge/network/AbstractBridgeNetwork.java +++ b/bridge-common/src/main/java/com/luminiadev/bridge/network/AbstractBridgeNetwork.java @@ -1,10 +1,10 @@ -package com.luminia.bridge.network; +package com.luminiadev.bridge.network; -import com.luminia.bridge.exception.BridgeCodecException; -import com.luminia.bridge.network.codec.BridgeCodec; -import com.luminia.bridge.network.codec.packet.handler.BridgePacketHandler; -import com.luminia.bridge.network.codec.packet.BridgePacket; -import com.luminia.bridge.util.ByteBuffer; +import com.luminiadev.bridge.exception.BridgeCodecException; +import com.luminiadev.bridge.network.codec.BridgeCodec; +import com.luminiadev.bridge.network.codec.packet.handler.BridgePacketHandler; +import com.luminiadev.bridge.network.codec.packet.BridgePacket; +import com.luminiadev.bridge.util.ByteBuffer; import org.jetbrains.annotations.Nullable; import org.jetbrains.annotations.UnmodifiableView; diff --git a/bridge-common/src/main/java/com/luminia/bridge/network/BridgeNetwork.java b/bridge-common/src/main/java/com/luminiadev/bridge/network/BridgeNetwork.java similarity index 70% rename from bridge-common/src/main/java/com/luminia/bridge/network/BridgeNetwork.java rename to bridge-common/src/main/java/com/luminiadev/bridge/network/BridgeNetwork.java index 55437fe..9d0fed4 100644 --- a/bridge-common/src/main/java/com/luminia/bridge/network/BridgeNetwork.java +++ b/bridge-common/src/main/java/com/luminiadev/bridge/network/BridgeNetwork.java @@ -1,9 +1,9 @@ -package com.luminia.bridge.network; +package com.luminiadev.bridge.network; -import com.luminia.bridge.network.codec.BridgeCodec; -import com.luminia.bridge.network.codec.packet.handler.BridgePacketHandler; -import com.luminia.bridge.network.codec.packet.BridgePacket; -import com.luminia.bridge.util.ByteBuffer; +import com.luminiadev.bridge.network.codec.BridgeCodec; +import com.luminiadev.bridge.network.codec.packet.handler.BridgePacketHandler; +import com.luminiadev.bridge.network.codec.packet.BridgePacket; +import com.luminiadev.bridge.util.ByteBuffer; import org.jetbrains.annotations.Nullable; import org.jetbrains.annotations.UnmodifiableView; diff --git a/bridge-common/src/main/java/com/luminia/bridge/network/codec/BridgeCodec.java b/bridge-common/src/main/java/com/luminiadev/bridge/network/codec/BridgeCodec.java similarity index 90% rename from bridge-common/src/main/java/com/luminia/bridge/network/codec/BridgeCodec.java rename to bridge-common/src/main/java/com/luminiadev/bridge/network/codec/BridgeCodec.java index 1ad8997..0a12d0a 100644 --- a/bridge-common/src/main/java/com/luminia/bridge/network/codec/BridgeCodec.java +++ b/bridge-common/src/main/java/com/luminiadev/bridge/network/codec/BridgeCodec.java @@ -1,11 +1,11 @@ -package com.luminia.bridge.network.codec; - -import com.luminia.bridge.exception.BridgeCodecException; -import com.luminia.bridge.network.codec.packet.BridgePacket; -import com.luminia.bridge.network.codec.packet.BridgePacketDefinition; -import com.luminia.bridge.network.codec.packet.BridgePacketFactory; -import com.luminia.bridge.network.codec.packet.serializer.BridgePacketSerializer; -import com.luminia.bridge.util.ByteBuffer; +package com.luminiadev.bridge.network.codec; + +import com.luminiadev.bridge.exception.BridgeCodecException; +import com.luminiadev.bridge.network.codec.packet.BridgePacket; +import com.luminiadev.bridge.network.codec.packet.BridgePacketDefinition; +import com.luminiadev.bridge.network.codec.packet.BridgePacketFactory; +import com.luminiadev.bridge.network.codec.packet.serializer.BridgePacketSerializer; +import com.luminiadev.bridge.util.ByteBuffer; import org.jetbrains.annotations.Nullable; import java.util.HashMap; diff --git a/bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/BridgePacket.java b/bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/BridgePacket.java similarity index 67% rename from bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/BridgePacket.java rename to bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/BridgePacket.java index fabf521..5157db2 100644 --- a/bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/BridgePacket.java +++ b/bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/BridgePacket.java @@ -1,4 +1,4 @@ -package com.luminia.bridge.network.codec.packet; +package com.luminiadev.bridge.network.codec.packet; import org.jetbrains.annotations.NotNull; diff --git a/bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/BridgePacketDefinition.java b/bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/BridgePacketDefinition.java similarity index 57% rename from bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/BridgePacketDefinition.java rename to bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/BridgePacketDefinition.java index feb93f5..a11aba4 100644 --- a/bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/BridgePacketDefinition.java +++ b/bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/BridgePacketDefinition.java @@ -1,6 +1,6 @@ -package com.luminia.bridge.network.codec.packet; +package com.luminiadev.bridge.network.codec.packet; -import com.luminia.bridge.network.codec.packet.serializer.BridgePacketSerializer; +import com.luminiadev.bridge.network.codec.packet.serializer.BridgePacketSerializer; import lombok.Value; @Value diff --git a/bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/BridgePacketDirection.java b/bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/BridgePacketDirection.java similarity index 58% rename from bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/BridgePacketDirection.java rename to bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/BridgePacketDirection.java index 3b9e744..2914479 100644 --- a/bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/BridgePacketDirection.java +++ b/bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/BridgePacketDirection.java @@ -1,4 +1,4 @@ -package com.luminia.bridge.network.codec.packet; +package com.luminiadev.bridge.network.codec.packet; public enum BridgePacketDirection { FROM_SERVICE, diff --git a/bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/BridgePacketFactory.java b/bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/BridgePacketFactory.java similarity index 66% rename from bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/BridgePacketFactory.java rename to bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/BridgePacketFactory.java index 25ce62c..48c8626 100644 --- a/bridge-common/src/main/java/com/luminia/bridge/network/codec/packet/BridgePacketFactory.java +++ b/bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/BridgePacketFactory.java @@ -1,4 +1,4 @@ -package com.luminia.bridge.network.codec.packet; +package com.luminiadev.bridge.network.codec.packet; @FunctionalInterface public interface BridgePacketFactory { diff --git a/bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/handler/BridgePacketHandler.java b/bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/handler/BridgePacketHandler.java new file mode 100644 index 0000000..b62b474 --- /dev/null +++ b/bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/handler/BridgePacketHandler.java @@ -0,0 +1,8 @@ +package com.luminiadev.bridge.network.codec.packet.handler; + +import com.luminiadev.bridge.network.codec.packet.BridgePacket; +import com.luminiadev.bridge.network.codec.packet.BridgePacketDirection; + +public interface BridgePacketHandler { + void handle(BridgePacket packet, BridgePacketDirection direction, String serviceId); +} diff --git a/bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/serializer/BridgePacketSerializer.java b/bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/serializer/BridgePacketSerializer.java new file mode 100644 index 0000000..7cb8eba --- /dev/null +++ b/bridge-common/src/main/java/com/luminiadev/bridge/network/codec/packet/serializer/BridgePacketSerializer.java @@ -0,0 +1,11 @@ +package com.luminiadev.bridge.network.codec.packet.serializer; + +import com.luminiadev.bridge.network.codec.packet.BridgePacket; +import com.luminiadev.bridge.util.ByteBuffer; + +public interface BridgePacketSerializer { + + void serialize(ByteBuffer buffer, T packet); + + void deserialize(ByteBuffer buffer, T packet); +} diff --git a/bridge-common/src/main/java/com/luminia/bridge/util/ByteBufVarInts.java b/bridge-common/src/main/java/com/luminiadev/bridge/util/ByteBufVarInts.java similarity index 99% rename from bridge-common/src/main/java/com/luminia/bridge/util/ByteBufVarInts.java rename to bridge-common/src/main/java/com/luminiadev/bridge/util/ByteBufVarInts.java index e807e54..48be62d 100644 --- a/bridge-common/src/main/java/com/luminia/bridge/util/ByteBufVarInts.java +++ b/bridge-common/src/main/java/com/luminiadev/bridge/util/ByteBufVarInts.java @@ -1,4 +1,4 @@ -package com.luminia.bridge.util; +package com.luminiadev.bridge.util; import io.netty.buffer.ByteBuf; import lombok.experimental.UtilityClass; diff --git a/bridge-common/src/main/java/com/luminia/bridge/util/ByteBuffer.java b/bridge-common/src/main/java/com/luminiadev/bridge/util/ByteBuffer.java similarity index 98% rename from bridge-common/src/main/java/com/luminia/bridge/util/ByteBuffer.java rename to bridge-common/src/main/java/com/luminiadev/bridge/util/ByteBuffer.java index 3c3899f..62eb86f 100644 --- a/bridge-common/src/main/java/com/luminia/bridge/util/ByteBuffer.java +++ b/bridge-common/src/main/java/com/luminiadev/bridge/util/ByteBuffer.java @@ -1,4 +1,4 @@ -package com.luminia.bridge.util; +package com.luminiadev.bridge.util; import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBufUtil; diff --git a/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/Main.java b/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/Main.java deleted file mode 100644 index b7f5dfd..0000000 --- a/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/Main.java +++ /dev/null @@ -1,56 +0,0 @@ -package com.luminia.bridge.network; - - -import com.rabbitmq.client.BuiltinExchangeType; -import com.rabbitmq.client.Channel; -import com.rabbitmq.client.Connection; -import com.rabbitmq.client.ConnectionFactory; -import com.rabbitmq.client.impl.DefaultCredentialsProvider; - -import java.nio.charset.StandardCharsets; -import java.util.HashSet; - -public class Main { - - public static final String PACKET_SEND_EXCHANGE = "packet_send_exchange"; - - public static void main(String[] args) { - ConnectionFactory connectionFactory = new ConnectionFactory(); - connectionFactory.setHost("localhost"); - connectionFactory.setCredentialsProvider(new DefaultCredentialsProvider("guest", "guest")); - - try (Connection connection = connectionFactory.newConnection(); - Channel channel = connection.createChannel()) { - - channel.exchangeDeclare(PACKET_SEND_EXCHANGE, BuiltinExchangeType.FANOUT); - - var queues = new HashSet(); - for (int i = 0; i < 3; i++) { - var queueName = channel.queueDeclare().getQueue(); - channel.queueBind(queueName, PACKET_SEND_EXCHANGE, ""); - queues.add(queueName); - - System.out.println("Registered consumer"); - channel.basicConsume(queueName, true, (consumerTag, delivery) -> { - var message = new String(delivery.getBody(), StandardCharsets.UTF_8); - System.out.println(" [x] Received '" + message + "' in queue '" + queueName + "'"); - }, consumerTag -> {}); - } - - for (int i = 0; i < 10; i++) { - var message = "Hello world #%s".formatted(i); - channel.basicPublish(PACKET_SEND_EXCHANGE, "", null, message.getBytes(StandardCharsets.UTF_8)); - } - - Thread.sleep(5000); - - for (var queueName: queues) { - System.out.println(" [x] Deleting queue '" + queueName + "'"); - channel.queueUnbind(queueName, PACKET_SEND_EXCHANGE, ""); - channel.queueDelete(queueName); - } - } catch (Exception e) { - throw new RuntimeException(e); - } - } -} \ No newline at end of file diff --git a/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/Test.java b/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/Test.java deleted file mode 100644 index 5c53915..0000000 --- a/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/Test.java +++ /dev/null @@ -1,42 +0,0 @@ -package com.luminia.bridge.network; - -import com.luminia.bridge.network.codec.BridgeCodec; -import com.luminia.bridge.network.codec.packet.BridgePacketDirection; - -public class Test { - - public static void main(String[] args) { - BridgeCodec codec = BridgeCodec.builder() - .registerPacket(TestPacket.IDENTIFIER, TestPacket::new, new TestPacket.TestPacketSerializer()) - .build(); - - BridgeRabbitMQConfig config = BridgeRabbitMQConfig.builder() - .host("localhost") - .credentials(new BridgeRabbitMQCredentials("guest", "guest")) - .build(); - BridgeNetwork network1 = new BridgeRabbitMQNetwork(config); - BridgeNetwork network2 = new BridgeRabbitMQNetwork(config); - - network1.setCodec(codec); - network1.start(); - network2.setCodec(codec); - network2.start(); - - System.out.println("Init " + network1.getServiceId() + ", " + network2.getServiceId()); - - network2.addPacketHandler((packet, direction, serviceId) -> { - if (direction == BridgePacketDirection.TO_SERVICE) { - System.out.println("Received packet: " + packet + " from service " + serviceId); - } - }); - network1.addPacketHandler((packet, direction, serviceId) -> { - if (direction == BridgePacketDirection.TO_SERVICE) { - System.out.println("Received packet: " + packet + " from service " + serviceId); - } - }); - - TestPacket packet = new TestPacket(); - packet.setTexts(new String[]{"Test", "123"}); - network1.sendPacket(packet); - } -} diff --git a/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/TestCodec.java b/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/TestCodec.java deleted file mode 100644 index a55c520..0000000 --- a/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/TestCodec.java +++ /dev/null @@ -1,10 +0,0 @@ -package com.luminia.bridge.network; - -import com.luminia.bridge.network.codec.BridgeCodec; - -public final class TestCodec { - - public static final BridgeCodec CODEC = BridgeCodec.builder() - .registerPacket(TestPacket.IDENTIFIER, TestPacket::new, new TestPacket.TestPacketSerializer()) - .build(); -} diff --git a/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/TestPacket.java b/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/TestPacket.java deleted file mode 100644 index 235ddc3..0000000 --- a/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/TestPacket.java +++ /dev/null @@ -1,42 +0,0 @@ -package com.luminia.bridge.network; - -import com.luminia.bridge.network.codec.packet.BridgePacket; -import com.luminia.bridge.network.codec.packet.serializer.BridgePacketSerializer; -import com.luminia.bridge.util.ByteBuffer; -import lombok.ToString; -import org.jetbrains.annotations.NotNull; -import lombok.Getter; -import lombok.Setter; - -import java.util.ArrayList; -import java.util.List; - -@Getter -@Setter -@ToString -public class TestPacket implements BridgePacket { - - public static final String IDENTIFIER = "test"; - - private String[] texts; - - @Override - public @NotNull String getId() { - return IDENTIFIER; - } - - public static class TestPacketSerializer implements BridgePacketSerializer { - - @Override - public void serialize(ByteBuffer buffer, TestPacket packet) { - buffer.writeArray(packet.getTexts(), buffer::writeString); - } - - @Override - public void deserialize(ByteBuffer buffer, TestPacket packet) { - List texts = new ArrayList<>(); - buffer.readArray(texts, buffer::readString); - packet.setTexts(texts.toArray(new String[0])); - } - } -} diff --git a/bridge-rabbitmq/src/main/java/com/luminia/bridge/exception/BridgeRabbitMQException.java b/bridge-rabbitmq/src/main/java/com/luminiadev/bridge/exception/BridgeRabbitMQException.java similarity index 89% rename from bridge-rabbitmq/src/main/java/com/luminia/bridge/exception/BridgeRabbitMQException.java rename to bridge-rabbitmq/src/main/java/com/luminiadev/bridge/exception/BridgeRabbitMQException.java index 30393b4..de7ff9a 100644 --- a/bridge-rabbitmq/src/main/java/com/luminia/bridge/exception/BridgeRabbitMQException.java +++ b/bridge-rabbitmq/src/main/java/com/luminiadev/bridge/exception/BridgeRabbitMQException.java @@ -1,4 +1,4 @@ -package com.luminia.bridge.exception; +package com.luminiadev.bridge.exception; public class BridgeRabbitMQException extends BridgeException { diff --git a/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/BridgeRabbitMQConfig.java b/bridge-rabbitmq/src/main/java/com/luminiadev/bridge/network/BridgeRabbitMQConfig.java similarity index 95% rename from bridge-rabbitmq/src/main/java/com/luminia/bridge/network/BridgeRabbitMQConfig.java rename to bridge-rabbitmq/src/main/java/com/luminiadev/bridge/network/BridgeRabbitMQConfig.java index 1b769f1..848d082 100644 --- a/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/BridgeRabbitMQConfig.java +++ b/bridge-rabbitmq/src/main/java/com/luminiadev/bridge/network/BridgeRabbitMQConfig.java @@ -1,4 +1,4 @@ -package com.luminia.bridge.network; +package com.luminiadev.bridge.network; import lombok.Builder; import lombok.Getter; diff --git a/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/BridgeRabbitMQCredentials.java b/bridge-rabbitmq/src/main/java/com/luminiadev/bridge/network/BridgeRabbitMQCredentials.java similarity index 67% rename from bridge-rabbitmq/src/main/java/com/luminia/bridge/network/BridgeRabbitMQCredentials.java rename to bridge-rabbitmq/src/main/java/com/luminiadev/bridge/network/BridgeRabbitMQCredentials.java index 175e363..dd2126c 100644 --- a/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/BridgeRabbitMQCredentials.java +++ b/bridge-rabbitmq/src/main/java/com/luminiadev/bridge/network/BridgeRabbitMQCredentials.java @@ -1,4 +1,4 @@ -package com.luminia.bridge.network; +package com.luminiadev.bridge.network; public record BridgeRabbitMQCredentials(String username, String password) { diff --git a/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/BridgeRabbitMQNetwork.java b/bridge-rabbitmq/src/main/java/com/luminiadev/bridge/network/BridgeRabbitMQNetwork.java similarity index 91% rename from bridge-rabbitmq/src/main/java/com/luminia/bridge/network/BridgeRabbitMQNetwork.java rename to bridge-rabbitmq/src/main/java/com/luminiadev/bridge/network/BridgeRabbitMQNetwork.java index 72d5398..6bed78b 100644 --- a/bridge-rabbitmq/src/main/java/com/luminia/bridge/network/BridgeRabbitMQNetwork.java +++ b/bridge-rabbitmq/src/main/java/com/luminiadev/bridge/network/BridgeRabbitMQNetwork.java @@ -1,10 +1,10 @@ -package com.luminia.bridge.network; +package com.luminiadev.bridge.network; -import com.luminia.bridge.exception.BridgeRabbitMQException; -import com.luminia.bridge.network.codec.packet.BridgePacket; -import com.luminia.bridge.network.codec.packet.BridgePacketDirection; -import com.luminia.bridge.network.codec.packet.handler.BridgePacketHandler; -import com.luminia.bridge.util.ByteBuffer; +import com.luminiadev.bridge.exception.BridgeRabbitMQException; +import com.luminiadev.bridge.network.codec.packet.BridgePacket; +import com.luminiadev.bridge.network.codec.packet.BridgePacketDirection; +import com.luminiadev.bridge.network.codec.packet.handler.BridgePacketHandler; +import com.luminiadev.bridge.util.ByteBuffer; import com.rabbitmq.client.*; import com.rabbitmq.client.impl.DefaultCredentialsProvider; import io.netty.buffer.Unpooled;