This commit is contained in:
parent
1e7d50d2c4
commit
36b60752af
@ -13,13 +13,13 @@ import model.OutputModel
|
|||||||
import kotlin.random.Random
|
import kotlin.random.Random
|
||||||
|
|
||||||
class GlueConsumer() : Consumer {
|
class GlueConsumer() : Consumer {
|
||||||
val envConfig = EnvConfig()
|
private val envConfig = EnvConfig()
|
||||||
val factory = ConnectionFactory()
|
private val factory = ConnectionFactory()
|
||||||
|
|
||||||
val outputConnection:Connection
|
private val outputConnection:Connection
|
||||||
val outputChannel:Channel
|
private val outputChannel:Channel
|
||||||
|
|
||||||
val gson = Gson()
|
private val gson = Gson()
|
||||||
override fun handleConsumeOk(consumerTag : String?) {
|
override fun handleConsumeOk(consumerTag : String?) {
|
||||||
}
|
}
|
||||||
override fun handleCancelOk(p0 : String?) {
|
override fun handleCancelOk(p0 : String?) {
|
||||||
|
@ -6,7 +6,7 @@ import consumer.GlueConsumer
|
|||||||
|
|
||||||
|
|
||||||
class Glue {
|
class Glue {
|
||||||
val envConfig = EnvConfig()
|
private val envConfig = EnvConfig()
|
||||||
|
|
||||||
fun recieve(){
|
fun recieve(){
|
||||||
val factory = ConnectionFactory()
|
val factory = ConnectionFactory()
|
||||||
|
Loading…
Reference in New Issue
Block a user