Compare commits
2 Commits
489bd376e3
...
874480aadb
Author | SHA1 | Date | |
---|---|---|---|
874480aadb | |||
1529649389 |
@ -1,7 +1,7 @@
|
|||||||
package mq
|
package mq
|
||||||
|
|
||||||
import api.ApiObject
|
import api.ApiObject
|
||||||
import com.google.gson.Gson
|
import com.google.gson.GsonBuilder
|
||||||
import com.rabbitmq.client.*
|
import com.rabbitmq.client.*
|
||||||
import database.service.ISampleObjectService
|
import database.service.ISampleObjectService
|
||||||
import org.koin.core.component.KoinComponent
|
import org.koin.core.component.KoinComponent
|
||||||
@ -9,7 +9,7 @@ import org.koin.core.component.inject
|
|||||||
|
|
||||||
class DatabaseConsumer (channel: Channel) : Consumer, KoinComponent {
|
class DatabaseConsumer (channel: Channel) : Consumer, KoinComponent {
|
||||||
private val resultObjectService: ISampleObjectService by inject()
|
private val resultObjectService: ISampleObjectService by inject()
|
||||||
private val gson = Gson()
|
private val gson = GsonBuilder().setDateFormat("yyyy-MM-dd'T'HH:mm:ssz").create()
|
||||||
private val basicChannel = channel
|
private val basicChannel = channel
|
||||||
override fun handleConsumeOk(consumerTag: String?) {
|
override fun handleConsumeOk(consumerTag: String?) {
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user