thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 08:40:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #28683 from vitlibar/allow-macros-in-rabbitmq-settings

Browse Source 
Expand macros in RabbitMQ settings
This commit is contained in:
Vitaly Baranov 2021-09-13 03:21:18 +03:00 committed by GitHub
commit 81b8062f3c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/Storages/RabbitMQ/StorageRabbitMQ.cpp
View File

@ -77,27 +77,27 @@ StorageRabbitMQ::StorageRabbitMQ(
: IStorage(table_id_)
, WithContext(context_->getGlobalContext())
, rabbitmq_settings(std::move(rabbitmq_settings_))
, exchange_name(rabbitmq_settings->rabbitmq_exchange_name.value)
, format_name(rabbitmq_settings->rabbitmq_format.value)
, exchange_type(defineExchangeType(rabbitmq_settings->rabbitmq_exchange_type.value))
, routing_keys(parseSettings(rabbitmq_settings->rabbitmq_routing_key_list.value))
, exchange_name(getContext()->getMacros()->expand(rabbitmq_settings->rabbitmq_exchange_name))
, format_name(getContext()->getMacros()->expand(rabbitmq_settings->rabbitmq_format))
, exchange_type(defineExchangeType(getContext()->getMacros()->expand(rabbitmq_settings->rabbitmq_exchange_type)))
, routing_keys(parseSettings(getContext()->getMacros()->expand(rabbitmq_settings->rabbitmq_routing_key_list)))
, row_delimiter(rabbitmq_settings->rabbitmq_row_delimiter.value)
, schema_name(rabbitmq_settings->rabbitmq_schema.value)
, schema_name(getContext()->getMacros()->expand(rabbitmq_settings->rabbitmq_schema))
, num_consumers(rabbitmq_settings->rabbitmq_num_consumers.value)
, num_queues(rabbitmq_settings->rabbitmq_num_queues.value)
, queue_base(rabbitmq_settings->rabbitmq_queue_base.value)
, queue_settings_list(parseSettings(rabbitmq_settings->rabbitmq_queue_settings_list.value))
, queue_base(getContext()->getMacros()->expand(rabbitmq_settings->rabbitmq_queue_base))
, queue_settings_list(parseSettings(getContext()->getMacros()->expand(rabbitmq_settings->rabbitmq_queue_settings_list)))
, persistent(rabbitmq_settings->rabbitmq_persistent.value)
, use_user_setup(rabbitmq_settings->rabbitmq_queue_consume.value)
, hash_exchange(num_consumers > 1 || num_queues > 1)
, log(&Poco::Logger::get("StorageRabbitMQ (" + table_id_.table_name + ")"))
, address(rabbitmq_settings->rabbitmq_host_port.value)
, address(getContext()->getMacros()->expand(rabbitmq_settings->rabbitmq_host_port))
, parsed_address(parseAddress(address, 5672))
, login_password(std::make_pair(
getContext()->getConfigRef().getString("rabbitmq.username"),
getContext()->getConfigRef().getString("rabbitmq.password")))
, vhost(getContext()->getConfigRef().getString("rabbitmq.vhost", rabbitmq_settings->rabbitmq_vhost.value))
, connection_string(rabbitmq_settings->rabbitmq_address)
, vhost(getContext()->getConfigRef().getString("rabbitmq.vhost", getContext()->getMacros()->expand(rabbitmq_settings->rabbitmq_vhost)))
, connection_string(getContext()->getMacros()->expand(rabbitmq_settings->rabbitmq_address))
, secure(rabbitmq_settings->rabbitmq_secure.value)
, semaphore(0, num_consumers)
, unique_strbase(getRandomName())