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

Merge pull request #218 from RZRCDR/fix_msvc_compiler_warnings 

Fix msvc compiler warnings
This commit is contained in:
Emiel Bruijntjes 2018-10-27 12:52:07 +02:00 committed by GitHub
parent 5836ab88d9 5ec49d5b8a
commit 11af8a7f6b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
include/amqpcpp/callbacks.h
View File

@ -45,7 +45,8 @@ using DeleteCallback = std::function<void(uint32_t deletedmessages)>;
* When retrieving the size of a queue in some way
*/
using EmptyCallback = std::function<void()>;
using SizeCallback = std::function<void(uint32_t messagecount)>;
using CountCallback = std::function<void(uint32_t messagecount)>;
using SizeCallback = std::function<void(uint64_t messagesize)>;
/**
* Starting and stopping a consumer

6
include/amqpcpp/deferredget.h
View File

@ -38,9 +38,9 @@ private:
/**
* Callback with the number of messages still in the queue
* @var SizeCallback
* @var CountCallback
*/
SizeCallback _countCallback;
CountCallback _countCallback;
/**
* Report success for a get operation
@ -162,7 +162,7 @@ public:
* Register a function to be called when queue size information is known
* @param callback the callback to execute
*/
DeferredGet &onCount(const SizeCallback &callback)
DeferredGet &onCount(const CountCallback &callback)
{
// store callback
_countCallback = callback;

10
src/channelimpl.cpp
View File

@ -283,11 +283,11 @@ Deferred &ChannelImpl::declareExchange(const std::string &name, ExchangeType typ
else if (type == ExchangeType::consistent_hash) exchangeType = "x-consistent-hash";
// the boolean options
bool passive = flags & AMQP::passive;
bool durable = flags & AMQP::durable;
bool autodelete = flags & AMQP::autodelete;
bool internal = flags & AMQP::internal;
bool nowait = flags & AMQP::nowait;
bool passive = (flags & AMQP::passive) != 0;
bool durable = (flags & AMQP::durable) != 0;
bool autodelete = (flags & AMQP::autodelete) != 0;
bool internal = (flags & AMQP::internal) != 0;
bool nowait = (flags & AMQP::nowait) != 0;
// send declare exchange frame
return push(ExchangeDeclareFrame(_id, name, exchangeType, passive, durable, autodelete, internal, nowait, arguments));