| 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.
|
| | |
|
| | |
|
| | |
|
| | |
|
| |
| |
| |
| |
| |
| |
| |
| |
| | |
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
|
| | |
|
| | |
|
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
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.
|
| |
| |
| |
| |
| |
| |
| |
| | |
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
|
| |
| |
| |
| | |
WINVER 0x0502 is WinXP SP2
|
| | |
|
| |
| |
| |
| | |
Most of this code comes from version Curl 7.35.
|
| |
| |
| |
| | |
Fixes #170
|
| | |
|
| | |
|
| |
| |
| |
| |
| |
| | |
The socket is closed when amqp_connection_close() is called.
Signed-off-by: Luka Perkov <luka.perkov@sartura.hr>
|
| |
| |
| |
| |
| |
| |
| |
| | |
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
|
| |
| |
| |
| |
| | |
Add encode/decode support for connection.blocked, connection.unblocked
RabbitMQ AMQP extension
|
| |
| |
| |
| |
| |
| | |
On one of my PC (Intel Core2 Duo Processor E7500 2.93 GHz),
QueryPerformanceFrequency return 2933330000.
This value is greater than AMQP_NS_PER_S (1000000000).
|
| | |
|
| | |
|
| | |
|
| |
| |
| |
| |
| |
| |
| | |
RabbitMQ defines two delivery modes, persistent and non-persistent, see
http://www.rabbitmq.com/amqp-0-9-1-reference.html#class.basic for more
information. This commit adds enumeration constants for these delivery
modes.
|
| |
| |
| |
| |
| |
| |
| | |
* amqp.h: Fix link to amqp_destroy_envelope()
* amqp_ssl_socket.h: Fix typo in parameter name
* amqp_tcp_socket.h: Use correct parameter name
* amqp.h: Typo in amqp_basic_ack() documentation
|
| | |
|
| | |
|
| | |
|
| | |
|
| |
| |
| |
| |
| |
| |
| | |
Fix a bug that manifested itself by the broker disconnecting the client
with an invalid_frame_end_marker error. The cause was when send()
returned less than the size of the buffer to be sent we weren't using
the correct parameters when restarting the send call.
|
| | |
|
| |
| |
| |
| |
| | |
Add function to return the properties table advertised by the broker on
connection to the broker.
|
| | |
|
| | |
|
| | |
|
| | |
|
| |
| |
| |
| |
| |
| |
| | |
Provide default values for:
- channel-max as AMQP_DEFAULT_CHANNEL_MAX 0 = unlimited
- frame-size as AMQP_DEFAULT_FRAME_SIZE 131072 = 128KB
- heartbeat as AMQP_DEFAULT_HEARTBEAT 0 = disabled
|