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

added consistent-hash exchange (same as pull request #68)

This commit is contained in:
Emiel Bruijntjes 2016-06-15 11:20:31 -04:00
parent ec9630ced7
commit 6320e2ae0e
2 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
include/exchangetype.h
View File

@ -24,7 +24,8 @@ enum ExchangeType
fanout, fanout,
direct, direct,
topic, topic,
headers headers,
consistent_hash
}; };
/** /**

11
src/channelimpl.cpp
View File

@ -219,10 +219,13 @@ Deferred &ChannelImpl::declareExchange(const std::string &name, ExchangeType typ
{ {
// convert exchange type // convert exchange type
std::string exchangeType; std::string exchangeType;
if (type == ExchangeType::fanout) exchangeType = "fanout";
if (type == ExchangeType::direct) exchangeType = "direct"; // convert the exchange type into a string
if (type == ExchangeType::topic) exchangeType = "topic"; if (type == ExchangeType::fanout) exchangeType = "fanout";
if (type == ExchangeType::headers)exchangeType = "headers"; else if (type == ExchangeType::direct) exchangeType = "direct";
else if (type == ExchangeType::topic) exchangeType = "topic";
else if (type == ExchangeType::headers) exchangeType = "headers";
else if (type == ExchangeType::consistent_hash) exchangeType = "x-consistent-hash";
// send declare exchange frame // send declare exchange frame
return push(ExchangeDeclareFrame(_id, name, exchangeType, (flags & passive) != 0, (flags & durable) != 0, false, arguments)); return push(ExchangeDeclareFrame(_id, name, exchangeType, (flags & passive) != 0, (flags & durable) != 0, false, arguments));