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

Set option via address.

This commit is contained in:
aljar 2020-11-13 18:05:07 +01:00
parent 11f1eaf2c3
commit fe1538e8ae
2 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
include/amqpcpp/linux_tcp/tcpconnection.h
View File

@ -192,9 +192,8 @@ public:
* Constructor * Constructor
* @param handler User implemented handler object * @param handler User implemented handler object
* @param hostname The address to connect to * @param hostname The address to connect to
* @param random Randomly select one of the IP addresses that belong to the hostname
*/ */
TcpConnection(TcpHandler *handler, const Address &address, bool random = false); TcpConnection(TcpHandler *handler, const Address &address);
/** /**
* No copying * No copying

5
src/linux_tcp/tcpconnection.cpp
View File

@ -23,11 +23,10 @@ namespace AMQP {
* Constructor * Constructor
* @param handler User implemented handler object * @param handler User implemented handler object
* @param hostname The address to connect to * @param hostname The address to connect to
* @param random Randomly select one of the IP addresses that belong to the hostname
*/ */
TcpConnection::TcpConnection(TcpHandler *handler, const Address &address, bool random) : TcpConnection::TcpConnection(TcpHandler *handler, const Address &address) :
_handler(handler), _handler(handler),
_state(new TcpResolver(this, address.hostname(), address.port(), address.secure(), address.option("connectTimeout", 5), random)), _state(new TcpResolver(this, address.hostname(), address.port(), address.secure(), address.option("connectTimeout", 5), address.option("randomConnect", false))),
_connection(this, address.login(), address.vhost()) _connection(this, address.login(), address.vhost())
{ {
// tell the handler // tell the handler