3 Commits

Author	SHA1	Message	Date
Emiel Bruijntjes	31f2d78778	Breaking change: the channel.publish() method no longer returns a DeferredPublisher-object, because it was not logical that you had to reinstall the callbacks for bounce-methods after each individual publish() call, not was it logical that the callbacks were not always logically linked to the publish() operation that failed (they were always sent to the handler of the most recent publish() instead of to the handler of the failed publish()). At the same time we added a channel.recall() method that can be used to notify the library that user-space is prepared to recall/take-back/accept bounced messages	2020-10-19 08:52:50 +02:00
Emiel Bruijntjes	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
Emiel Bruijntjes	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