thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-23 08:02:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update StorageRabbitMQ.cpp

Browse Source
This commit is contained in:
Kseniia Sumarokova 2021-09-01 13:28:34 +03:00 committed by GitHub
parent 335b6f12fd
commit 09c9dd489b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1066,11 +1066,11 @@ void registerStorageRabbitMQ(StorageFactory & factory)
if (!rabbitmq_settings->rabbitmq_host_port.changed
&& !rabbitmq_settings->rabbitmq_address.changed)
throw Exception("You must speicify either `rabbitmq_host_port` or `rabbitmq_address` settings",
throw Exception("You must specify either `rabbitmq_host_port` or `rabbitmq_address` settings",
ErrorCodes::NUMBER_OF_ARGUMENTS_DOESNT_MATCH);
if (!rabbitmq_settings->rabbitmq_format.changed)
throw Exception("You must speicify `rabbitmq_format` setting", ErrorCodes::NUMBER_OF_ARGUMENTS_DOESNT_MATCH);
throw Exception("You must specify `rabbitmq_format` setting", ErrorCodes::NUMBER_OF_ARGUMENTS_DOESNT_MATCH);
return StorageRabbitMQ::create(args.table_id, args.getContext(), args.columns, std::move(rabbitmq_settings));
};