Commit Graph

399 Commits

Author SHA1 Message Date
DHP86 71abd6d1d1 Add type 'x' in Field::decode.
type 'x' means byte array (array of unsigned chars) so it is strictly not correct to return a LongString (array of signed chars). But with this change the library can continue going after receiving type 'x'. The original code crashes or starts doing undefined things when receiving a nonempty byte array from a client.
2025-06-23 14:58:32 +02:00
Emiel Bruijntjes 32faf9526a small fix to AMQP::Tagger in case it gets destructed before the close-callbacks are called 2024-04-21 08:29:37 +02:00
Emiel Bruijntjes 0d00bbb7f6 code layout 2023-08-24 21:47:31 +02:00
Emiel Bruijntjes 2ba4237d57 add robustness 2023-08-24 21:46:39 +02:00
Przemyslaw Olejniczak b280aef308 #507 connection_name property is not set on windows platform 2023-08-24 21:21:24 +02:00
Przemyslaw Olejniczak a68cd2ed49 #507 connection_name property is not set on windows platform 2023-08-24 14:13:18 +02:00
Timo Sluis 89ba9138c0 implement tcp handler and pass reason to callback 2023-07-03 13:05:09 +02:00
Timo Sluis 4fb968f7a4 implemented connection.blocked handling and callbacks 2023-07-03 11:41:02 +02:00
Emiel Bruijntjes 12f4314d2a fix setting the connection name 2023-06-24 13:26:10 +02:00
Emiel Bruijntjes d87343afbc {auto} implemented connection_name property 2023-06-21 12:47:46 +02:00
Emiel Bruijntjes dcde4caca4 fix compiling on win32 2023-04-24 11:06:42 +02:00
Emiel Bruijntjes 89a245a05b fix compiling on win32 2023-04-24 11:04:09 +02:00
Emiel Bruijntjes d8550894ba include version number of amqp-cpp, longer product name, change order of platform info 2023-04-22 16:33:31 +02:00
Emiel Bruijntjes 5bc547b121 add better connection information 2023-04-22 15:56:41 +02:00
Emiel Bruijntjes e841b3ff69 AMQP::Tagger now takes a std::string_view 2023-03-26 18:40:14 +02:00
Emiel Bruijntjes a37c354bea {auto} when wrapping a tagger around a channel that already has an error-callback installed, we should preserve the old callback 2023-02-23 11:06:15 +01:00
Emiel Bruijntjes 84a87d8f93 many methods in the Channel class now take a std::string_view instead of a std::string parameter, and are thus a bit more efficient 2023-02-13 10:27:51 +01:00
Emiel Bruijntjes d1be1063a5 implemented "consumer cancel notifications" (see https://www.rabbitmq.com/consumer-cancel.html) 2022-11-23 22:09:15 +01:00
Emiel Bruijntjes 7142d45363
Merge pull request #476 from boimart1/bugfix/handle_zero_max_frame
Handle max-frame=0 correctly
2022-09-11 20:19:36 +02:00
Emiel Bruijntjes b893755293 {auto} improve the tagger destructor to also unset the onAck() and onNack() callbacks 2022-09-11 20:17:53 +02:00
Emiel Bruijntjes c93f2d89ac when destructing a Tagger class, we now also unset the error-callback (closes #480), at the same time we changed the version number in the Makefile (closes #481) 2022-09-11 20:09:02 +02:00
Martin Boisvert f8d9b76609 Add check for _maxFrame > 0 2022-08-16 12:37:08 -04:00
Emiel Bruijntjes c273d93625 make sure threads are synchronized (fixes 474) 2022-08-09 23:10:07 +02:00
Ivan Trofimov a8a73e31b7 make sure compilers dont complain about unused parameters 2022-07-24 01:18:07 +03:00
Emiel Bruijntjes 328d9d12de when retrieving data from an inbuffer, no longer restrict ourselves to uint32 2022-04-25 11:16:57 +02:00
Peter Eisenlohr 060e42a6dd don't call moved-from callbacks 2022-03-25 16:08:50 +01:00
Peter Eisenlohr fa1181aa63 Added const-ref wrappers to make changes backward-compatible. 2022-03-18 23:53:44 +01:00
Peter Eisenlohr 9c4cfffab8 std::move callbacks 2022-03-15 14:10:45 +01:00
Tony Roussel 6fd0e8f1d5 fix wrong exchange type check in ChannelImpl::declareExchange 2021-11-23 16:00:02 +01:00
Tony Roussel c83708e9bd add x-message-deduplication exchange type
This exchange type exist on RabbitMQ server with the plugin rabbitmq_message_deduplication
This plugin code is available here: https://github.com/noxdafox/rabbitmq-message-deduplication
2021-11-23 14:13:55 +01:00
Emiel Bruijntjes 0f596d7a6e added KEEPALIVE option to the TCP socket so that at least we are notified if the peer turns out to be non-connected 2021-09-20 12:48:30 +02:00
Raoul Wols 1d25f0acbc
Fixup sync handling for CopiedBuffer 2021-08-10 16:07:21 +02:00
Emiel Bruijntjes a09e33a609 fixed copy and move constructors of the PassthroughBuffer (fixes #418) 2021-08-10 14:24:04 +02:00
Raoul Wols 1dc169810d
Add missing include (#416) 2021-08-05 17:20:43 +02:00
Emiel Bruijntjes 4b62948275
Merge pull request #411 from CopernicaMarketingSoftware/remove-unused-class
Remove unused ConsumedMessage class
2021-08-02 08:38:57 +02:00
Emiel Bruijntjes c7c36ab3c4
Merge pull request #409 from Niederb/master
Three small improvements
2021-08-02 08:38:19 +02:00
Thomas Niederberger 592a8bf691 Fix typo 2021-08-01 11:20:28 +02:00
Raoul Wols 0499863da2
Fix SSL state bugs (#413) 2021-07-30 14:50:15 +02:00
Raoul Wols f0f17cdf18
Remove unused ConsumedMessage class 2021-07-28 12:14:50 +02:00
Raoul Wols 819af12055
Replace shared_ptr by unique_ptr for Fields (#402)
There is no real purpose to using shared pointers it seems.
2021-07-20 10:32:10 +02:00
Raoul Wols 2f26928e3e
docblock 2021-07-13 13:27:19 +02:00
Raoul Wols 477243d3f3
Handle newlines better in sslerrorprinter.cpp
According to 4cedf30e99/crypto/err/err_prn.c (L20)
the ERR_print_errors_cb function already adds newlines to the end
of each line. So we can just append right away. We do remove the
last newline as normally error messages don't end with a newline.
Also we may return 0 instead of 1.
2021-07-13 13:25:39 +02:00
Raoul Wols 40d2af913e
docblock 2021-07-13 13:19:32 +02:00
Raoul Wols 3ca1ef73ad
Lookup function in shared library 2021-07-13 13:12:32 +02:00
Raoul Wols df78574034
docblocks 2021-07-13 12:32:17 +02:00
Raoul Wols faa491ce65
remove BIO stuff completely, replace with callback 2021-07-13 12:31:04 +02:00
Raoul Wols 4d49b44283
separate cpp file 2021-07-13 11:37:31 +02:00
Raoul Wols d5819ef2dc
docblock 2021-07-13 11:24:08 +02:00
Raoul Wols 3bc7b62567
separate class for extracting errors 2021-07-13 11:23:08 +02:00
Raoul Wols 2f6451a9aa
Print a better error message
This is still missing the dlsym wrappers.
2021-07-12 18:44:16 +02:00