Skip to content

Commit

Permalink
Merge pull request #102 from webhead1104/master
Browse files Browse the repository at this point in the history
Remove rabbitmq server declaration and shutdown
  • Loading branch information
webhead1104 authored Jun 17, 2024
2 parents a0a6b90 + 40bf2dd commit 9bfc891
Showing 1 changed file with 0 additions and 12 deletions.
12 changes: 0 additions & 12 deletions src/main/java/net/cytonic/cytosis/messaging/RabbitMQ.java
Original file line number Diff line number Diff line change
Expand Up @@ -33,8 +33,6 @@ public RabbitMQ() {
// do nothing
}

private static final String SERVER_DECLARE_QUEUE = "server-declaration";
private static final String SHUTDOWN_QUEUE = "server-shutdown";
private static final String CHAT_CHANNEL_QUEUE = STR."chat-channel-\{Cytosis.SERVER_ID}";
private static final String PLAYER_KICK_QUEUE = "player-kick";
private static final String CHAT_CHANNEL_EXCHANGE = "chat-exchange";
Expand Down Expand Up @@ -69,16 +67,6 @@ public void initializeConnection() {
*/
public void initializeQueues() {
Logger.info("Initializing RabbitMQ queues...");
try {
channel.queueDeclare(SERVER_DECLARE_QUEUE, false, false, false, null);
} catch (IOException e) {
Logger.error("An error occurred whilst initializing the 'SERVER_DECLARE_QUEUE'.", e);
}
try {
channel.queueDeclare(SHUTDOWN_QUEUE, false, false, false, null);
} catch (IOException e) {
Logger.error("An error occurred whilst initializing the 'SHUTDOWN_QUEUE'.", e);
}
try {
channel.exchangeDeclare(CHAT_CHANNEL_EXCHANGE, BuiltinExchangeType.FANOUT);
channel.queueDeclare(CHAT_CHANNEL_QUEUE, false, false, true, null);
Expand Down

0 comments on commit 9bfc891

Please sign in to comment.