Compare commits

...

3 Commits

Author SHA1 Message Date
f6e664f0f7 upload to docker hub
All checks were successful
continuous-integration/drone/push Build is passing
2022-01-31 23:12:05 +01:00
4b57850635 ez is jolet
Signed-off-by: Pünkösd Marcell <marcsello@sch.bme.hu>
2021-09-28 20:10:31 +02:00
7b0281af10 fix typo
All checks were successful
continuous-integration/drone/push Build is passing
2021-08-18 17:02:00 +02:00
3 changed files with 14 additions and 2 deletions

View File

@ -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:

View File

@ -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"
) )

View File

@ -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) {