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

Merge pull request #438 from TonyRoussel/add-message-deduplication-exchange 

fix wrong exchange type check in ChannelImpl::declareExchange
This commit is contained in:
Emiel Bruijntjes 2021-11-23 16:36:40 +01:00 committed by GitHub
parent 04c77b5cff 6fd0e8f1d5
commit d5a7f3cdd1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/channelimpl.cpp
View File

@ -290,7 +290,7 @@ Deferred &ChannelImpl::declareExchange(const std::string &name, ExchangeType typ
else if (type == ExchangeType::topic) exchangeType = "topic";
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-message-deduplication";
else if (type == ExchangeType::message_deduplication) exchangeType = "x-message-deduplication";
// the boolean options
bool passive = (flags & AMQP::passive) != 0;