diff --git a/src/ActiveMQ/ActiveMQClient.kt b/src/ActiveMQ/ActiveMQClient.kt index 727be9e..0bd47c2 100644 --- a/src/ActiveMQ/ActiveMQClient.kt +++ b/src/ActiveMQ/ActiveMQClient.kt @@ -1,5 +1,6 @@ package ActiveMQ +import config import jakarta.jms.BytesMessage import jakarta.jms.Connection import jakarta.jms.MapMessage @@ -14,7 +15,7 @@ import org.tinylog.Logger import java.util.function.Consumer @Suppress("unused") -class ActiveMQClient(BrokerURL: String, username: String, password: String, queueName: String) { +class ActiveMQClient { private lateinit var connection: Connection private lateinit var session: Session private lateinit var destination : Queue @@ -22,10 +23,10 @@ class ActiveMQClient(BrokerURL: String, username: String, password: String, queu var MessageConsumer : Consumer?= null init{ try{ - connection = ActiveMQConnectionFactory(BrokerURL, username, password).createConnection() + connection = ActiveMQConnectionFactory(config.ActiveMQ_BrokerURL, config.ActiveMQ_Username, config.ActiveMQ_Password).createConnection() connection.start() session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE) - destination = session.createQueue(queueName) + destination = session.createQueue(config.ActiveMQ_QueueName) consumer = session.createConsumer(destination) consumer.messageListener = MessageListener { message -> MessageConsumer?.accept(message) @@ -53,7 +54,7 @@ class ActiveMQClient(BrokerURL: String, username: String, password: String, queu } } - Logger.info { "ActiveMQ Connection created to Broker : $BrokerURL" } + Logger.info { "ActiveMQ Connection created to Broker : ${config.ActiveMQ_BrokerURL}" } } catch (e : Exception){ Logger.error { "Failed to create connection, Message : ${e.message}" } } diff --git a/src/Main.kt b/src/Main.kt index 720d520..5627178 100644 --- a/src/Main.kt +++ b/src/Main.kt @@ -4,19 +4,13 @@ import Web.WebUI import database.MySQLInjector import java.util.function.Consumer -//TIP To Run code, press or -// click the icon in the gutter. +lateinit var config : Config fun main() { - val config = Config() + config = Config() config.Load() - val webUI = WebUI(config) - val activeclient = ActiveMQClient( - config.ActiveMQ_BrokerURL, - config.ActiveMQ_Username, - config.ActiveMQ_Password, - config.ActiveMQ_QueueName - ) - val mysql = MySQLInjector(config) + val webUI = WebUI() + val activeclient = ActiveMQClient() + val mysql = MySQLInjector() activeclient.MessageConsumer = Consumer{ message -> diff --git a/src/Web/WebUI.kt b/src/Web/WebUI.kt index 3c663dc..21c1057 100644 --- a/src/Web/WebUI.kt +++ b/src/Web/WebUI.kt @@ -1,13 +1,13 @@ package Web -import Other.Config +import config import io.javalin.Javalin @Suppress("unused") /** * Start WebUI Server */ -class WebUI(config: Config) { +class WebUI{ private var app : Javalin = Javalin.create { config -> config.staticFiles.add("/html") }.start(config.WebPort) diff --git a/src/database/MySQLInjector.kt b/src/database/MySQLInjector.kt index 3e8c50e..91bc383 100644 --- a/src/database/MySQLInjector.kt +++ b/src/database/MySQLInjector.kt @@ -1,8 +1,7 @@ package database -import Other.Config -class MySQLInjector(config: Config) { +class MySQLInjector { fun Stop(){