jessequ
/
AMQP-CPP
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix wrong exchange type check in ChannelImpl::declareExchange

This commit is contained in:
Tony Roussel 2021-11-23 16:00:02 +01:00
parent c83708e9bd
commit 6fd0e8f1d5
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/channelimpl.cpp
View File

@ -285,12 +285,12 @@ Deferred &ChannelImpl::declareExchange(const std::string &name, ExchangeType typ
const char *exchangeType = ""; const char *exchangeType = "";
// convert the exchange type into a string // convert the exchange type into a string
if (type == ExchangeType::fanout) exchangeType = "fanout"; if (type == ExchangeType::fanout) exchangeType = "fanout";
else if (type == ExchangeType::direct) exchangeType = "direct"; else if (type == ExchangeType::direct) exchangeType = "direct";
else if (type == ExchangeType::topic) exchangeType = "topic"; else if (type == ExchangeType::topic) exchangeType = "topic";
else if (type == ExchangeType::headers) exchangeType = "headers"; else if (type == ExchangeType::headers) exchangeType = "headers";
else if (type == ExchangeType::consistent_hash) exchangeType = "x-consistent-hash"; else if (type == ExchangeType::consistent_hash) exchangeType = "x-consistent-hash";
else if (type == ExchangeType::consistent_hash) exchangeType = "x-message-deduplication"; else if (type == ExchangeType::message_deduplication) exchangeType = "x-message-deduplication";
// the boolean options // the boolean options
bool passive = (flags & AMQP::passive) != 0; bool passive = (flags & AMQP::passive) != 0;