c82fce8ec9
fix for incorrect handling of synchronous flag
2019-06-19 09:38:56 +02:00
19d82ed1f2
fixed issue where timer could set negative value in repeat if heavily delayed
2019-05-02 12:08:14 +02:00
b4a67ac618
fixed dealing with timers in libev handler
2019-03-06 12:53:35 +01:00
a18e518ac8
when heartbeats were disabled, the event loop refcount would not be restored correctly after the timer expired. This has been fixed ( #281 )
2019-01-17 16:16:38 +01:00
a3c68009e7
Give the server more time to send a heartbeat to make sure one missed heartbeat does not close the connection
2019-01-15 13:12:57 +01:00
0857022bc4
ev_timer_again should be called after next has been reset
2019-01-10 15:59:57 +01:00
901298cd1c
fixed libev handler: the heartbeat interval proposed by the server was not accepted
2018-12-17 16:19:40 +01:00
5d1d2c2852
fix timer that expired too early ( fix #272 )
2018-12-17 16:11:53 +01:00
1256c82d60
use std::list instead of std::vector
2018-12-14 00:07:19 +01:00
20d4104d18
Merge pull request #271 from CopernicaMarketingSoftware/heartbeats
...
Implemented custom heartbeats in Livev
2018-12-13 23:41:20 +01:00
a92dc27653
Implemented custom heartbeats in Livev
2018-12-13 13:01:38 +01:00
3d1605009b
This simple change allows the library to be compiled under FreeBSD.
2018-12-03 13:00:00 +01:00
d2e3792abc
fixed issue when end-of-file was encountered, this fixes #266
2018-11-30 06:42:54 +01:00
53f994d61d
when user calls connection.heartbeat() we now always send out the heartbeat (AMQP-CPP no longer tries to be smart about skipping heartbeats, because that could lead to timeouts if the user is a little late with its call, or when there is network congestion)
2018-11-28 13:52:00 +01:00
91a23d5737
Merge branch 'master' of github.com:CopernicaMarketingSoftware/AMQP-CPP
2018-11-23 11:16:03 +01:00
ee60aeb025
The Channel constructor now throws an exception if the max number of channels has been reached
2018-11-23 11:15:51 +01:00
799583ea39
Merge branch 'master' of github.com:CopernicaMarketingSoftware/AMQP-CPP
2018-11-21 13:56:53 +01:00
8eed709988
Connection::fail() will now also call the channel::onError method
2018-11-21 13:56:44 +01:00
45ca61cc43
added TcpConnection::closed()
2018-11-14 14:15:52 +01:00
549fec5cb1
libevhandler only checks for heartbeats if not overridden by user
2018-11-12 22:07:48 +01:00
888dc8c40b
added channel::usable() to replace channel::connected()
2018-11-12 15:24:25 +01:00
6432ce2ec1
added connection::usable()
2018-11-12 15:19:31 +01:00
a80847dc5e
fixed a couple of todos, make sure that onError() is always called
2018-11-12 12:12:04 +01:00
6f81b0a097
when tcp connection is lost, the pending operations are now reported with an error
2018-11-11 23:46:58 +01:00
8d08916b8c
fixed libev compiler errors
2018-11-11 22:58:13 +01:00
d83e88b95d
fixed the libev handler to be compatible with amqp-cpp 4.0, and we now also close the connection if the server stops sending heartbeats
2018-11-11 22:54:42 +01:00
fc21b62852
disable timer in libboostasio because it cannot handle multiple connections, fixes #251
2018-11-11 22:51:41 +01:00
e83a07f871
renamed onClosed to onLost to prevent confusion between TcpHandler::onClosed() and ConnectionHandler::onClosed()
2018-11-08 09:58:36 +01:00
da6744bf4d
renamed ConnectionHandler::onConnectedO() to ConnectionHandler::onReady()
2018-11-08 08:34:58 +01:00
06dc23190d
added ConnectionHandler::onProperties and TcpConnectionHandler::onProperties
2018-11-07 23:22:25 +01:00
f0ad90dd65
fixed compiler warning
2018-11-07 17:34:35 +01:00
428219ad83
simplified and improved the close procedure
2018-11-07 15:04:08 +01:00
64c876e65a
removed support for TcpConnection::flush() and removed internal TcpShutdown state
2018-11-06 18:11:27 +01:00
9330231a69
fixed assigning the new state
2018-11-05 17:11:21 +01:00
54049f9e8e
improved the tcp handler, added more methods to monitor whether a connection is connected, logged on and in an error state
2018-11-05 16:49:55 +01:00
bb417e89c2
add support for ConnectionHandler::onAttached() and ConnectionHandler::onDetached()
2018-11-05 16:19:48 +01:00
359eec189f
work in progress, simplified the tcp and ssl states
2018-11-05 16:18:20 +01:00
b81bc340b5
work in progress on refactored tcp handling, to solve various issues, like the one that lost connections do not trigger operations to fail
2018-11-04 23:34:31 +01:00
62a4262a58
the TcpConnection::close() method now supports an "immediate" parameter to skip the official amqp handshake for closing down
2018-10-28 18:13:13 +01:00
8546f52cd0
added onAttached() and onDetached() to the TcpHandler interface
2018-10-28 10:22:01 +01:00
c52e8ff0b2
added ConnectionHandler::onAttached() and ConnectionHandler::onDetached() methods
2018-10-28 10:04:34 +01:00
c0241cac67
Merge pull request #195 from Aleksandrius/master
...
Fixed MinGW compilation on Windows
2018-10-27 12:52:52 +02:00
11af8a7f6b
Merge pull request #218 from RZRCDR/fix_msvc_compiler_warnings
...
Fix msvc compiler warnings
2018-10-27 12:52:07 +02:00
ba532e0434
onError should be overloaded by subclass, otherwise callback installers are no longer available for that class.
2018-09-21 12:26:23 +02:00
757feb10c6
tcpchannel should also be movable
2018-08-31 15:01:10 +02:00
31f6a18f37
channel should be movable
2018-08-31 14:44:19 +02:00
94bff62986
Monitor: avoid null pointer dereference when copying instances
...
When the copy constructor was added to allow passing a monitor by value
into a lambda the implementation did not account for the possibility of
the watchable having already been destroyed.
Also provide the companion copy assignment to complete the triad.
2018-06-24 10:31:21 -05:00
025fdb5530
Merge pull request #134 from mgibula/master
...
Add Publisher Confirms support
2018-05-14 22:42:56 +02:00
ddee073278
Add onAck and onNack methods
2018-05-14 21:40:30 +02:00
1a955b39af
Add deferredconfirm.h to amqpcpp.h
2018-05-14 21:35:08 +02:00
76cf06d0ba
Comment fix
2018-05-14 21:34:43 +02:00
2aa55b83c7
Replace old API with DeferredConfirm class
2018-05-14 21:12:34 +02:00
bf1caa1eae
Add DeferredConfirm class
2018-05-14 21:05:49 +02:00
a90c620709
Add BasicAckFrame and BasicNackFrame to class list
2018-05-14 21:05:07 +02:00
eeee1c3c5f
Rename setConfirmMode() to confirmSelect()
2018-05-14 12:59:20 +02:00
e0b04ad7e0
Remove messageCounter()
2018-05-14 12:55:15 +02:00
976e948cb0
added comments
2018-05-11 11:58:55 +02:00
9bb20437d0
Fixed unused parameter warnings in header files
2018-05-11 08:52:43 +08:00
5ec49d5b8a
Added CountCallback to support 32bit unsigned int passed in defferedget.
2018-04-23 08:30:37 +01:00
4d34c582d0
numericfield: cleanup for floating point types
...
Rework so floating point values are supported to the same degree as
integer values.
Closes #214
2018-04-22 16:30:37 -05:00
1479922901
Fix MSVC compile warning C4800 for bitwise operation resulting in int to boolean assignment.
...
Fix MSVC compile warning C4244 possible loss of data. Possible data loss from uint64_t to uint32_t.
2018-04-22 15:53:52 +01:00
d0b5189d1e
Envelope: ensure const objects cannot be changed through _body
...
In commit 00b81949d3
2018-04-20 18:27:53 -05:00
d857fbafde
better comment for the channel::consume() call, the comment about the consumer tag was wrong ( fixes #211 )
2018-04-19 09:56:35 +02:00
a624bc872c
Added virtual dtor to OutBuffer
2018-04-18 15:46:46 +03:00
539128e559
Replaced C-casts with const_cast for Envelope::body_
2018-04-18 14:59:35 +03:00
1db6ed13a6
libev implementation was incorrect when one single handler was used to manage multiple connections
2018-04-12 12:05:22 +02:00
bfd91b6ab5
Merge with upstream
2018-04-10 10:30:01 +02:00
69a201e741
optimizid dealing with ssl connections by not going back to the event loop that often, and prevented that object was staying in send state if it was endlessly sending data and not receiving anything, found this out when working on issue #207
2018-04-05 11:10:55 +02:00
b26058f3e2
renamed bytesQueued() to queued()
2018-04-01 22:34:15 +02:00
8800d2917e
Add method to return the amount of queued outgoing data
2018-04-01 10:54:05 +01:00
cf7d2e49ff
allow for a clean shutdown of asio connections
...
remove heartbeat timer on close
make sure only weak references are stored in bindings even below C++17
2018-03-12 12:07:09 +01:00
f1c32242f7
Merge branch 'master' of github.com:CopernicaMarketingSoftware/AMQP-CPP
2018-03-10 14:56:18 +01:00
d2b2d5af14
shared-ptr has been turned into a unique-ptr for the tcp-state
2018-03-10 14:55:57 +01:00
11786ff10b
update docblock in boostasio class to warn users about the possible low quality of the code
2018-03-10 14:55:23 +01:00
23cae9de84
fixed Address constructor
2018-03-10 10:32:48 +01:00
d81565fe6a
fixed that stream operator of address wrote the port number when the default amqps port was used
2018-03-10 10:31:40 +01:00
1ee18911ce
fixed writing address to std::stream
2018-03-10 10:20:52 +01:00
367de51d77
added method to intercept tls handshakes, and to verify certificates
2018-03-10 00:59:14 +01:00
4c2b8ff68e
added ability to set the handle to the openssl library (so that programs that load openssl via dlopen() can still use amqp-cpp)
2018-03-09 15:08:52 +01:00
f23bcf19f1
improved docblocks in tcpstate.h header file, when an error or closed is reported to user space, the _handler variable is now reset to prevent that it will be used to report more than once (we still need to check if this does not trigger other errors), and the state object is no longer destructed after a reportClosed() call, so that it can clean up nicely (which we need to the tls shutdown anyway)
2018-03-08 10:02:42 +01:00
b0adbb1878
Fixed MinGW compilation on Windows
2018-03-06 18:58:02 +02:00
a025e6c1c9
breaking change: the linux-tcp module is no longer included by default, applications that rely on this now have to explicitly include amcpcpp/linux_tcp
2018-03-06 08:46:17 +01:00
5b8841c937
removed more tabs
2018-03-06 08:45:12 +01:00
69c615d0a4
removed tcp prefix from all ssl related classes
2018-03-06 08:39:42 +01:00
463eed89c0
work in progress on closing ssl connections
2018-03-05 22:24:19 +01:00
e46dfcf3b8
work in progress on ssl support for the AMQP-CPP library
2018-03-05 17:29:37 +01:00
342268e50a
support for amqps:// addresses in the AMQP::Address class (although it does not yet make a real secure connection)
2018-03-02 13:53:00 +01:00
ab817384b1
fixed auth method prefix extra / char
2018-03-02 12:54:09 +01:00
b9047f5ea7
added ampqs:// parsing to address
2018-03-02 12:14:43 +01:00
41239a1952
fixed to make returning message functional, and added test code
2018-03-01 22:54:50 +01:00
1ccd93cc5e
final step (although untested) for handling returned messages
2018-03-01 22:27:27 +01:00
1f3500cee8
breaking changes:
...
channel.publish() now returns a DeferredConsumer object on which callbacks can be installed for handling returned messages,
channel.get().onSize() has a different behavior: it now reports the message size (and no longer the queue size),
channel.get().onCount() has been added: it reports the queue size (this used to be the onSize() method),
channel.consume().onSize() method has been added to find out the size of the upcoming message
2018-03-01 21:12:53 +01:00
f39df772d3
breaking changes:
...
channel.publish() now returns a DeferredConsumer object on which callbacks can be installed for handling returned messages,
channel.get().onSize() has a different behavior: it now reports the message size (and no longer the queue size),
channel.get().onCount() has been added: it reports the queue size (this used to be the onSize() method),
channel.consume().onSize() method has been added to find out the size of the upcoming message
2018-03-01 21:12:50 +01:00
ef76876d67
refactored code to make room for a deferredpublisher class (which will also use the deferredreceiver base class)
2018-03-01 18:07:18 +01:00
520fe40201
refactored handling of incoming messages from consume and get operations, to prepare for future handling of returned messages and publisher confirms. this also implies a small change to the api: the begin-callback when a message is received now also gets the original exchange and routing key (which could be useful)
2018-03-01 17:34:27 +01:00
3ccc6af475
added deferredreceiver files (forgotter in prev commit)
2018-02-27 05:09:03 +01:00
e0feb17ecc
renamed deferredconsumerbase into deferredreceiver, because it is not only a base class for the consumer, but also for other receiving operations: get requests and in the future also for returned messages
2018-02-27 05:08:21 +01:00
ec327de396
less conservative caching of outgoing data. This fixes #184
2018-02-07 10:08:32 +01:00
f5540e9af2
fixed autodelete flag for declaring an exchange and added support for internal exchange. this fixes #183
2018-02-06 21:54:56 +01:00
accc1810a0
remove timer interval from ctor init list
2018-02-01 15:31:19 +01:00
Michael van der Werve
Emiel Bruijntjes
thijs-blom
Thijs Blom
Youri Moll
Moreno Carullo
Peter A. Bigot
Marcin Gibula
Mathias Devos
Dirkco du Plessis
theirix
Aljar Meesters
Mike Playle
tilsche
Aleksandr Serbin
Tamas Elekes
Steven Geddis