41239a1952fixed to make returning message functional, and added test code
Emiel Bruijntjes
2018-03-01 22:54:50 +0100
1ccd93cc5efinal step (although untested) for handling returned messages
Emiel Bruijntjes
2018-03-01 22:27:27 +0100
1f3500cee8breaking 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
Emiel Bruijntjes
2018-03-01 21:12:53 +0100
f39df772d3breaking 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
Emiel Bruijntjes
2018-03-01 21:12:50 +0100
ef76876d67refactored code to make room for a deferredpublisher class (which will also use the deferredreceiver base class)
Emiel Bruijntjes
2018-03-01 18:07:18 +0100
520fe40201refactored 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)
Emiel Bruijntjes
2018-03-01 17:34:27 +0100
e0feb17eccrenamed 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
Emiel Bruijntjes
2018-02-27 05:08:21 +0100
3080950cffMerge branch 'master' into hunter
Steven Geddis
2018-02-22 09:36:52 +0100
ec327de396less conservative caching of outgoing data. This fixes#184
Emiel Bruijntjes
2018-02-07 10:08:32 +0100
f5540e9af2fixed autodelete flag for declaring an exchange and added support for internal exchange. this fixes#183
Emiel Bruijntjes
2018-02-06 21:54:56 +0100
accc1810a0remove timer interval from ctor init list
Steven Geddis
2018-02-01 15:31:19 +0100
5a853134aaremove second ctor with heartbeat interval (extend class instead). Change private to protected to allow LibBoostAsioHandler to be extended.
Steven Geddis
2018-02-01 15:27:59 +0100
33c8e76a7ecorrect comment
Steven Geddis
2018-02-01 13:11:23 +0100
ae3b94fe92use custom heartbeat interval outright, if set.
Steven Geddis
2018-02-01 13:05:41 +0100
b713d48bb9add second constructor with heartbeat interval; apply modern cpp typedefs; Add comments;
Steven Geddis
2018-02-01 12:44:48 +0100
4b2c423896Build examples now with travis-ci to ensure new changes don't break existing code. Fixed warnings as a result of lambda captures.
zerodefect
2018-01-30 10:07:27 +0000
c287382770fix includes because existing code was no longer compiling after the latest changes
Aljar Meesters
2018-01-30 10:45:16 +0100
3d823adb51add include for boost/function.hpp
Emiel Bruijntjes
2018-01-30 09:27:43 +0100
f7e8cf5414Updated README.md to reflect changes.
Aart Stuurman
2018-01-26 23:50:41 +0100
dd6bbada96Fix build error for Make where include files could not be found. Make now installs headers correctly.
Aart Stuurman
2018-01-26 23:04:01 +0100
001bf38715Set output directory to bin/
Aart Stuurman
2018-01-23 18:58:51 +0100
4652a9cbdflibboostasio.h does not compile with clang-3.9 due to following error when compile if cpp17 preprocessor check: embedding a directive within macro arguments has undefined behavior [-Werror,-Wembedded-directive]. Fix this by moving the bind away from preprocessor macro. Replace the STRAND_SOCKET_HANDLER, STRAND_TIMER_HANDLER macros with template functions.
Steven Geddis
2018-01-23 18:55:46 +0100
5701d28b2badded BUILD_TCP option to build the linux sockets implementation.
Aart Stuurman
2018-01-23 18:49:59 +0100
9935f8414bupdate copyright year when connection is established to rabbitmq
Emiel Bruijntjes
2018-01-23 17:17:21 +0100
50761bd40dCMakefile cleanup. No functional changes.
Aart Stuurman
2018-01-23 17:12:38 +0100
Emiel Bruijntjes
Steven Geddis
Steven Geddis
Aart Stuurman
zerodefect
Aljar Meesters
DAQ-AART\AartStuurman