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