artin/OBP-API
1
0
Fork 0
mirror of https://github.com/OpenBankProject/OBP-API.git synced 2026-02-06 15:27:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

feature/added the rabbitmq_connector.virtual_host

Browse Source
This commit is contained in:
hongwei 2024-11-12 16:04:31 +01:00
parent 21b629a392
commit 348164afab
4 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
obp-api/src/main/resources/props/sample.props.template
View File

@ -838,6 +838,7 @@ featured_apis=elasticSearchWarehouseV300
# rabbitmq_connector.port=5672
# rabbitmq_connector.username=obp
# rabbitmq_connector.password=obp
# rabbitmq_connector.virtual_host=/
# -- RabbitMQ Adapter --------------------------------------------
#rabbitmq.adapter.enabled=false

1
obp-api/src/main/scala/code/bankconnectors/rabbitmq/Adapter/MockedRabbitMqAdapter.scala
View File

@ -3082,6 +3082,7 @@ object MockedRabbitMqAdapter extends App with MdcLoggable{
factory.setPort(port)
factory.setUsername(username)
factory.setPassword(password)
factory.setVirtualHost(virtualHost)
if (APIUtil.getPropsAsBoolValue("rabbitmq.use.ssl", false)){
factory.useSslProtocol(RabbitMQUtils.createSSLContext(
keystorePath,

1
obp-api/src/main/scala/code/bankconnectors/rabbitmq/RabbitMQConnectionPool.scala
View File

@ -17,6 +17,7 @@ class RabbitMQConnectionFactory extends BasePooledObjectFactory[Connection] {
factory.setPort(port)
factory.setUsername(username)
factory.setPassword(password)
factory.setVirtualHost(virtualHost)
if (APIUtil.getPropsAsBoolValue("rabbitmq.use.ssl", false)){
factory.useSslProtocol(RabbitMQUtils.createSSLContext(
keystorePath,

1
obp-api/src/main/scala/code/bankconnectors/rabbitmq/RabbitMQUtils.scala
View File

@ -28,6 +28,7 @@ object RabbitMQUtils extends MdcLoggable{
val port = APIUtil.getPropsAsIntValue("rabbitmq_connector.port").openOrThrowException("mandatory property rabbitmq_connector.port is missing!")
val username = APIUtil.getPropsValue("rabbitmq_connector.username").openOrThrowException("mandatory property rabbitmq_connector.username is missing!")
val password = APIUtil.getPropsValue("rabbitmq_connector.password").openOrThrowException("mandatory property rabbitmq_connector.password is missing!")
val virtualHost = APIUtil.getPropsValue("rabbitmq_connector.virtual_host").openOrThrowException("mandatory property rabbitmq_connector.virtual_host is missing!")
val keystorePath = APIUtil.getPropsValue("keystore.path").getOrElse("")
val keystorePassword = APIUtil.getPropsValue("keystore.password").getOrElse(APIUtil.initPasswd)