diff --git a/docker-compose.yml b/docker-compose.yml index a71b7a2..305c130 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -6,7 +6,7 @@ services: image: "postgres:12" restart: "always" volumes: - - "ktor-data:/var/lib/postgresql/data" + - "input-ktor-data:/var/lib/postgresql/data" ports: - "127.0.0.1:54321:5432" environment: @@ -40,8 +40,8 @@ services: RABBITMQ_DEFAULT_PASS: "rabbitmq" RABBITMQ_DEFAULT_VHOST: "/" ports: - - "127.0.0.1:15672:15672" + - "127.0.0.1:15672:15672" - "127.0.0.1:5672:5672" volumes: - ktor-data: \ No newline at end of file + input-ktor-data: \ No newline at end of file diff --git a/src/api/route/InputServiceServer.kt b/src/api/route/InputServiceServer.kt index 62455f8..29128f1 100644 --- a/src/api/route/InputServiceServer.kt +++ b/src/api/route/InputServiceServer.kt @@ -106,11 +106,7 @@ class InputServiceServer { resultObjectService.addOne(currentApiObject) } - connection.confirmChannel { - publish { - publishWithConfirm(OutboundMessage(rabbitExchangeName, "", MessageProperties.PERSISTENT_BASIC, tag.toString())) - } - } + channel.basicPublish("",queueName, null, tag.toString().toByteArray()) call.respond(currentApiObject) } diff --git a/src/database/service/InputObjectService.kt b/src/database/service/InputObjectService.kt index 01ea3ef..37c44e0 100644 --- a/src/database/service/InputObjectService.kt +++ b/src/database/service/InputObjectService.kt @@ -8,7 +8,6 @@ import org.jetbrains.exposed.sql.ResultRow import org.jetbrains.exposed.sql.select import org.jetbrains.exposed.sql.selectAll import org.jetbrains.exposed.sql.transactions.transaction -import java.time.LocalDate import java.util.*