byte/symphony
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

queues, and posting to db works

Browse Source
This commit is contained in:
Daniel
2024-12-13 00:03:48 +02:00
parent 20b7465d6b
commit b11cfc852b
3 changed files with 0 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
SymphonyManager/src/main/java/io/github/lumijiez/AddressHolder.java
View File

@@ -1,16 +1,5 @@
package io.github.lumijiez; package io.github.lumijiez;
import java.net.HttpURLConnection;
import java.net.URL;
import java.nio.charset.StandardCharsets;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.Random;
import java.util.Timer;
import java.util.TimerTask;
import static io.github.lumijiez.Main.logger;
public class AddressHolder { public class AddressHolder {
private String host; private String host;
private int port; private int port;

2
SymphonyManager/src/main/java/io/github/lumijiez/BrokerConnector.java
View File

@@ -15,8 +15,6 @@ import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import static io.github.lumijiez.Main.logger;
public class BrokerConnector { public class BrokerConnector {
private static final String QUEUE_NAME = "random_sha"; private static final String QUEUE_NAME = "random_sha";
private static final String RABBITMQ_HOST = "rabbitmq"; private static final String RABBITMQ_HOST = "rabbitmq";

2
SymphonyProducer/src/main/java/io/github/lumijiez/BrokerConnector.java
View File

@@ -1,7 +1,5 @@
package io.github.lumijiez; package io.github.lumijiez;
import com.google.gson.JsonObject;
import com.google.gson.JsonPrimitive;
import com.rabbitmq.client.Channel; import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection; import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.ConnectionFactory;