| Commit message (Collapse) | Author | Age | Files | Lines |
|\ |
|
| |
| |
| |
| |
| |
| |
| |
| | |
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
|
|\ \
| |/
| |
| |
| |
| | |
Conflicts:
Makefile.am
codegen
|
| |
| |
| |
| |
| | |
test_hostcheck includes a file which includes amqp_private.h which needs
config.h.
|
| |
| |
| |
| | |
WINVER 0x0502 is WinXP SP2
|
| | |
|
| | |
|
| | |
|
| |
| |
| |
| | |
Most of this code comes from version Curl 7.35.
|
| |
| |
| |
| | |
Fixes #170
|
| | |
|
| | |
|
| |
| |
| | |
Include more completely instructions on how to build with autotools.
|
| |
| |
| |
| |
| |
| | |
The socket is closed when amqp_connection_close() is called.
Signed-off-by: Luka Perkov <luka.perkov@sartura.hr>
|
| |
| |
| |
| |
| |
| |
| | |
Properly substitute the @requires_private@ and @libs_private@ variables
when configuring under autoconf
This fixes #154
|
| |
| |
| |
| |
| |
| |
| |
| | |
Correctly document the return values that the amqp_ssl_socket_set_keys,
amqp_ssl_socket_set_cert, and amqp_ssl_socket_set_key_buffer functions
can return.
This fixes #155
|
| |
| |
| |
| |
| |
| | |
This change fixes a bug where delivery mode value was hardcoded to
"persistent" even when --persistent flag wasn't specified on the command
line options.
|
| |
| |
| |
| |
| | |
Add encode/decode support for connection.blocked, connection.unblocked
RabbitMQ AMQP extension
|