first commit
This commit is contained in:
@@ -1,5 +1,6 @@
|
|||||||
package ActiveMQ
|
package ActiveMQ
|
||||||
|
|
||||||
|
import config
|
||||||
import jakarta.jms.BytesMessage
|
import jakarta.jms.BytesMessage
|
||||||
import jakarta.jms.Connection
|
import jakarta.jms.Connection
|
||||||
import jakarta.jms.MapMessage
|
import jakarta.jms.MapMessage
|
||||||
@@ -14,7 +15,7 @@ import org.tinylog.Logger
|
|||||||
import java.util.function.Consumer
|
import java.util.function.Consumer
|
||||||
|
|
||||||
@Suppress("unused")
|
@Suppress("unused")
|
||||||
class ActiveMQClient(BrokerURL: String, username: String, password: String, queueName: String) {
|
class ActiveMQClient {
|
||||||
private lateinit var connection: Connection
|
private lateinit var connection: Connection
|
||||||
private lateinit var session: Session
|
private lateinit var session: Session
|
||||||
private lateinit var destination : Queue
|
private lateinit var destination : Queue
|
||||||
@@ -22,10 +23,10 @@ class ActiveMQClient(BrokerURL: String, username: String, password: String, queu
|
|||||||
var MessageConsumer : Consumer<Message>?= null
|
var MessageConsumer : Consumer<Message>?= null
|
||||||
init{
|
init{
|
||||||
try{
|
try{
|
||||||
connection = ActiveMQConnectionFactory(BrokerURL, username, password).createConnection()
|
connection = ActiveMQConnectionFactory(config.ActiveMQ_BrokerURL, config.ActiveMQ_Username, config.ActiveMQ_Password).createConnection()
|
||||||
connection.start()
|
connection.start()
|
||||||
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)
|
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)
|
||||||
destination = session.createQueue(queueName)
|
destination = session.createQueue(config.ActiveMQ_QueueName)
|
||||||
consumer = session.createConsumer(destination)
|
consumer = session.createConsumer(destination)
|
||||||
consumer.messageListener = MessageListener { message ->
|
consumer.messageListener = MessageListener { message ->
|
||||||
MessageConsumer?.accept(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){
|
} catch (e : Exception){
|
||||||
Logger.error { "Failed to create connection, Message : ${e.message}" }
|
Logger.error { "Failed to create connection, Message : ${e.message}" }
|
||||||
}
|
}
|
||||||
|
|||||||
16
src/Main.kt
16
src/Main.kt
@@ -4,19 +4,13 @@ import Web.WebUI
|
|||||||
import database.MySQLInjector
|
import database.MySQLInjector
|
||||||
import java.util.function.Consumer
|
import java.util.function.Consumer
|
||||||
|
|
||||||
//TIP To <b>Run</b> code, press <shortcut actionId="Run"/> or
|
lateinit var config : Config
|
||||||
// click the <icon src="AllIcons.Actions.Execute"/> icon in the gutter.
|
|
||||||
fun main() {
|
fun main() {
|
||||||
val config = Config()
|
config = Config()
|
||||||
config.Load()
|
config.Load()
|
||||||
val webUI = WebUI(config)
|
val webUI = WebUI()
|
||||||
val activeclient = ActiveMQClient(
|
val activeclient = ActiveMQClient()
|
||||||
config.ActiveMQ_BrokerURL,
|
val mysql = MySQLInjector()
|
||||||
config.ActiveMQ_Username,
|
|
||||||
config.ActiveMQ_Password,
|
|
||||||
config.ActiveMQ_QueueName
|
|
||||||
)
|
|
||||||
val mysql = MySQLInjector(config)
|
|
||||||
|
|
||||||
activeclient.MessageConsumer = Consumer{ message ->
|
activeclient.MessageConsumer = Consumer{ message ->
|
||||||
|
|
||||||
|
|||||||
@@ -1,13 +1,13 @@
|
|||||||
package Web
|
package Web
|
||||||
|
|
||||||
import Other.Config
|
import config
|
||||||
import io.javalin.Javalin
|
import io.javalin.Javalin
|
||||||
|
|
||||||
@Suppress("unused")
|
@Suppress("unused")
|
||||||
/**
|
/**
|
||||||
* Start WebUI Server
|
* Start WebUI Server
|
||||||
*/
|
*/
|
||||||
class WebUI(config: Config) {
|
class WebUI{
|
||||||
private var app : Javalin = Javalin.create { config ->
|
private var app : Javalin = Javalin.create { config ->
|
||||||
config.staticFiles.add("/html")
|
config.staticFiles.add("/html")
|
||||||
}.start(config.WebPort)
|
}.start(config.WebPort)
|
||||||
|
|||||||
@@ -1,8 +1,7 @@
|
|||||||
package database
|
package database
|
||||||
|
|
||||||
import Other.Config
|
|
||||||
|
|
||||||
class MySQLInjector(config: Config) {
|
class MySQLInjector {
|
||||||
|
|
||||||
fun Stop(){
|
fun Stop(){
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user