| Commit message (Collapse) | Author | Age | Files | Lines |
... | |
| |
|
| |
|
| |
|
| |
|
|
|
|
|
| |
Add a tests that ensures that we add error message strings as we add new
amqp_status_enum values.
|
| |
|
|
|
|
|
|
|
|
| |
Alternate Names DNS entries.
Additional check for entries in SSL certificate.
Signed-off-by: Yevhen Kyriukha <kirgene@gmail.com>
|
| |
|
|
|
|
|
| |
Remove extra text from documentation of amqp_basic_publish that was left there
from an earlier edit.
|
|
|
|
|
|
|
| |
For consistency sake, allocate and return a struct when decoding methods that
don't have fields.
Fixes #225
|
|
|
|
| |
C89 compilers can't do mixed definitions and code.
|
|
|
|
|
|
|
| |
Check to state of socket when doing open/read/write/close to prevent double-open
and double-close issues with the socket implementation.
Fixes #228
|
|
|
|
|
|
|
|
| |
Enable auto_delete and internal parameters of amqp_exchange_declare() in
codegen. These were once not generated because RabbitMQ did not support these
parameters. The broker now supports these and so should we.
This fixes #218
|
|
|
|
| |
Doing this because the next change will cause a ton of diffs otherwise.
|
|
|
|
|
| |
In tools/common.c `#ifdef WITH_SSL` is used but never defined if SSL support is
desired.
|
| |
|
| |
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
If you have a single consumer C₁ and 10 messages are published, all 10
will be streamed to that one customer. Assume each message takes a few
minutes to be handled.
If a second consumer C₂ comes up before C₁ is able to process its first
message, it will stay idle until new messages are published, while C₁
will still have to process the other 9 messages after finishing with the
first one.
If both consumers were started with `--messages 1`, C₁ would only fetch
a single message, and start handling it; C₂ would start and already
receive the second message .
|
|
|
|
|
| |
This reverts commit c9f00dfb9f5ce306398f18cafa143988a4f61515. Because it breaks
under CMake versions that don't know what CMP0042 is.
|
| |
|
| |
|
|
|
|
| |
This fixes #199.
|
| |
|
|
|
|
|
|
|
|
|
| |
Add 'platform' 'version', 'copyright' client-properties to start-ok method
during connection handshake.
Adapted from:
https://github.com/synety-jdebp/rabbitmq-c/commit/e3c76e1887ff50378f6146167daa024dbd7d4eeb
by: Jonathan de Boyne Pollard <jonathan.de.boyne.pollard@synety.com>
|
| |
|
| |
|
|
|
|
|
|
|
|
| |
There is an unexpected local variable shadowing in
amqp_ssl_socket_open(). So the following code is meaningless
unexpectedly.
status = AMQP_STATUS_SSL_HOSTNAME_VERIFY_FAILED
|
| |
|
|
|
|
|
|
|
| |
htonll maybe defined as a macro, look for it in the arpa/inet.h. CMake build
system already does the right thing.
Fixes #206
|
| |
|
| |
|
|
|
|
|
|
|
|
|
|
|
| |
Even if a channel_max is specified, channel_ids can be any number, so don't
range-check channel_ids received. At present this gets rabbitmq-c back into
compliance with the way the RabbitMQ broker works.
See issue #187, #195
To correctly enforce channel_max from the client side, rabbitmq-c would need to
track open channels, which is a bit more involved to do correctly.
|
|
|
|
|
| |
sockfd is assigned, then assigned again unconditionally without being read
from. There's no point in this statement, so lets get rid of it.
|
| |
|
|
|
|
|
|
|
|
|
| |
CMake's check_function_exists() only checks for a symbol being defined in a
library, and does not cover the instance where a function may be defined as a
macro a header. Use check_symbol_exists() to check arpa/inet.h header for symbol
existance of htonll.
This fixes #200
|
| |
|
|
|
|
|
|
|
|
| |
Improve detection of invalid AMQP frame header before allocating frame buffer.
This fixes #187.
Thanks to Mike Stitt <mikes@spindance.com> for the inspiration on this.
|
|
|
|
|
| |
AMQP_INITIAL_DECODING_POOL_PAGE_SIZE isn't used anywhere in the code. Getting
rid of it.
|
|
|
|
| |
Signed-off-by: Mike Stitt <mikes@spindance.com>
|
|
|
|
|
|
|
| |
This fixes a bug in amqp_consume where the function would incorrectly return an
OOM condition when a 0-length exchange name was returned.
Fixes #192
|
|
|
|
|
|
|
|
|
| |
sys/uio.h should be included in amqp_private.h and not amqp.h, it also should
not be protected by a test for the GCC compiler.
This should fix the issue with compiling rabbitmq-c on HP-UX using aCC.
This fixes #183.
|
|
|
|
|
|
|
| |
HP-UX does not have clock_gettime(CLOCK_MONOTONIC), instead use
platform-specific gethrtime() function.
Thanks to zhongk for this fix.
|
|
|
| |
milliseconds = seconds * 1000 + microseconds / 1000
|
|
|
|
|
|
|
| |
Use poll(2) instead of select(2) to do timeout operations on sockets. This helps
with the situation where the fd is larger than FD_MAXSIZE.
Fixes #168
|
|
|
|
|
| |
test_hostcheck includes a file which includes amqp_private.h which needs
config.h.
|
|
|
|
| |
WINVER 0x0502 is WinXP SP2
|
| |
|
| |
|
| |
|