diff --git a/include/amqpcpp/exchangetype.h b/include/amqpcpp/exchangetype.h index 5ef5c7a..66325db 100644 --- a/include/amqpcpp/exchangetype.h +++ b/include/amqpcpp/exchangetype.h @@ -25,7 +25,8 @@ enum ExchangeType direct, topic, headers, - consistent_hash + consistent_hash, + message_deduplication }; /** diff --git a/src/channelimpl.cpp b/src/channelimpl.cpp index 79efeb4..326b355 100644 --- a/src/channelimpl.cpp +++ b/src/channelimpl.cpp @@ -290,6 +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"; // the boolean options bool passive = (flags & AMQP::passive) != 0;