SMTP server

SymphonyProducer/src/main/java/io/github/lumijiez/Main.java

@@ -1,5 +1,7 @@
 package io.github.lumijiez;
 
+import io.github.lumijiez.broker.BrokerConnector;
+import io.github.lumijiez.ftp.FTPProducer;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 

SymphonyProducer/src/main/java/io/github/lumijiez/broker/BrokerConnector.java

@@ -1,4 +1,4 @@
-package io.github.lumijiez;
+package io.github.lumijiez.broker;
 
 import com.rabbitmq.client.Channel;
 import com.rabbitmq.client.Connection;
@@ -13,6 +13,8 @@ import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
+
+import io.github.lumijiez.Main;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 

SymphonyProducer/src/main/java/io/github/lumijiez/ftp/FTPProducer.java

@@ -1,7 +1,8 @@
-package io.github.lumijiez;
+package io.github.lumijiez.ftp;
 
 import com.google.gson.Gson;
 import com.google.gson.JsonObject;
+import io.github.lumijiez.Main;
 import org.apache.commons.net.ftp.FTPClient;
 
 import java.io.ByteArrayInputStream;
@@ -18,7 +19,7 @@ public class FTPProducer {
     String ftpPass = "symphony";
     String ftpDir = "/";
 
-    FTPProducer() {
+    public FTPProducer() {
         Timer timer = new Timer();
         timer.scheduleAtFixedRate(new TimerTask() {
             @Override