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

Merge pull request #182 from lion10243/issue181-set-heartbeat 

add second constructor with heartbeat interval param
This commit is contained in:
Emiel Bruijntjes 2018-02-01 15:51:25 +01:00 committed by GitHub
parent f9f054d315 accc1810a0
commit ba587aca13
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
include/amqpcpp/libboostasio.h
View File

@ -47,7 +47,7 @@ namespace AMQP {
*/ */
class LibBoostAsioHandler : public virtual TcpHandler class LibBoostAsioHandler : public virtual TcpHandler
{ {
private: protected:
/** /**
* Helper class that wraps a boost io_service socket monitor. * Helper class that wraps a boost io_service socket monitor.
@ -62,7 +62,7 @@ private:
*/ */
boost::asio::io_service & _ioservice; boost::asio::io_service & _ioservice;
typedef std::weak_ptr<boost::asio::io_service::strand> strand_weak_ptr; using strand_weak_ptr = std::weak_ptr<boost::asio::io_service::strand>;
/** /**
* The boost asio io_service::strand managed pointer. * The boost asio io_service::strand managed pointer.
@ -77,7 +77,6 @@ private:
*/ */
boost::asio::posix::stream_descriptor _socket; boost::asio::posix::stream_descriptor _socket;
/** /**
* A boolean that indicates if the watcher is monitoring for read events. * A boolean that indicates if the watcher is monitoring for read events.
* @var _read True if reads are being monitored else false. * @var _read True if reads are being monitored else false.
@ -315,7 +314,7 @@ private:
*/ */
boost::asio::io_service & _ioservice; boost::asio::io_service & _ioservice;
typedef std::weak_ptr<boost::asio::io_service::strand> strand_weak_ptr; using strand_weak_ptr = std::weak_ptr<boost::asio::io_service::strand>;
/** /**
* The boost asio io_service::strand managed pointer. * The boost asio io_service::strand managed pointer.
@ -330,6 +329,7 @@ private:
boost::asio::deadline_timer _timer; boost::asio::deadline_timer _timer;
using handler_fn = boost::function<void(boost::system::error_code)>; using handler_fn = boost::function<void(boost::system::error_code)>;
/** /**
* Binds and returns a lamba function handler for the io operation. * Binds and returns a lamba function handler for the io operation.
* @param connection The connection being watched. * @param connection The connection being watched.
@ -457,7 +457,7 @@ private:
*/ */
boost::asio::io_service & _ioservice; boost::asio::io_service & _ioservice;
typedef std::shared_ptr<boost::asio::io_service::strand> strand_shared_ptr; using strand_shared_ptr = std::shared_ptr<boost::asio::io_service::strand>;
/** /**
* The boost asio io_service::strand managed pointer. * The boost asio io_service::strand managed pointer.
@ -465,17 +465,18 @@ private:
*/ */
strand_shared_ptr _strand; strand_shared_ptr _strand;
/** /**
* All I/O watchers that are active, indexed by their filedescriptor * All I/O watchers that are active, indexed by their filedescriptor
* @var std::map<int,Watcher> * @var std::map<int,Watcher>
*/ */
std::map<int, std::shared_ptr<Watcher> > _watchers; std::map<int, std::shared_ptr<Watcher> > _watchers;
/**
* The boost asio io_service::deadline_timer managed pointer.
* @var class std::shared_ptr<Timer>
*/
std::shared_ptr<Timer> _timer; std::shared_ptr<Timer> _timer;
/** /**
* Method that is called by AMQP-CPP to register a filedescriptor for readability or writability * Method that is called by AMQP-CPP to register a filedescriptor for readability or writability
* @param connection The TCP connection object that is reporting * @param connection The TCP connection object that is reporting
@ -584,4 +585,3 @@ public:
* End of namespace * End of namespace
*/ */
} }