Compare commits
3 Commits
0809386bc3
...
master
Author | SHA1 | Date | |
---|---|---|---|
f6e664f0f7 | |||
4b57850635 | |||
7b0281af10
|
12
.drone.yml
12
.drone.yml
@ -30,6 +30,18 @@ steps:
|
|||||||
- latest
|
- latest
|
||||||
- ${DRONE_BUILD_NUMBER}
|
- ${DRONE_BUILD_NUMBER}
|
||||||
|
|
||||||
|
- name: dockerhub
|
||||||
|
image: plugins/docker
|
||||||
|
settings:
|
||||||
|
repo: birbnetes/${DRONE_REPO_NAME}
|
||||||
|
username:
|
||||||
|
from_secret: DOCKERHUB_USER
|
||||||
|
password:
|
||||||
|
from_secret: DOCKERHUB_PASSWORD
|
||||||
|
tags:
|
||||||
|
- latest
|
||||||
|
- ${DRONE_BUILD_NUMBER}
|
||||||
|
|
||||||
- name: ms-teams
|
- name: ms-teams
|
||||||
image: kuperiu/drone-teams
|
image: kuperiu/drone-teams
|
||||||
settings:
|
settings:
|
||||||
|
@ -7,5 +7,5 @@ data class EnvConfig (
|
|||||||
var mqExchange: String = System.getenv("MQ_EXCHANGE") ?: "rabbitmq",
|
var mqExchange: String = System.getenv("MQ_EXCHANGE") ?: "rabbitmq",
|
||||||
var dbJdbc: String = System.getenv("DB_JDBC") ?: "input",
|
var dbJdbc: String = System.getenv("DB_JDBC") ?: "input",
|
||||||
var dbUsername: String = System.getenv("DB_USERNAME") ?: "output",
|
var dbUsername: String = System.getenv("DB_USERNAME") ?: "output",
|
||||||
var dbPassowrd: String = System.getenv("DB_PASSOWRD") ?: "output"
|
var dbPassowrd: String = System.getenv("DB_PASSWORD") ?: "output"
|
||||||
)
|
)
|
@ -30,7 +30,7 @@ class DatabaseConsumer(channel: Channel): Consumer, KoinComponent {
|
|||||||
override fun handleDelivery(consumerTag : String?, envelope : Envelope?, basicProperties : AMQP.BasicProperties?, body : ByteArray?) {
|
override fun handleDelivery(consumerTag : String?, envelope : Envelope?, basicProperties : AMQP.BasicProperties?, body : ByteArray?) {
|
||||||
try {
|
try {
|
||||||
val rawJson = body!!.toString(Charsets.UTF_8)
|
val rawJson = body!!.toString(Charsets.UTF_8)
|
||||||
val apiObject = Json.decodeFromString<ApiObject>(rawJson)
|
val apiObject = Json{ ignoreUnknownKeys = true }.decodeFromString<ApiObject>(rawJson)
|
||||||
resultObjectService.addOne(apiObject)
|
resultObjectService.addOne(apiObject)
|
||||||
basicChannel.basicAck(envelope!!.deliveryTag, false)
|
basicChannel.basicAck(envelope!!.deliveryTag, false)
|
||||||
} catch (e: Exception) {
|
} catch (e: Exception) {
|
||||||
|
Reference in New Issue
Block a user