968eefa1bb
Bump (c) line year
...
There are no functional changes to this massive diff.
2025-01-01 17:54:10 -05:00
d83ae8c9c7
More missed (c) header updates
2024-01-23 11:26:29 -05:00
7b151a7651
More missed (c) header updates
2024-01-22 23:44:47 -05:00
ec4f1dba7d
(c) year bump: 2022 => 2023
2023-01-01 23:17:36 -05:00
c38a3d697d
Bump (c) year
2022-03-21 01:21:56 +04:00
b11a79cccf
Bump (c) year in header files
2021-02-04 07:04:58 +03:00
5c469ed519
Ensure safe amqp client call timeouts on connection
...
establishment. This guarantees that the effective
call timeouts are always safe, i.e. granting enough
time to the underlying network operations, which must
always timeout first in case of any unexpected
lingering operations leading to timeouts. This eliminates
the chance of leaking connection processes when call
timeouts elapse, while underlying remote cconnection
establishment call was still taking place.
2020-11-26 17:02:49 +00:00
482907e1fa
No longer use amqp_util:call_timeout/0 for wait_for_confirms. Allow specifying integer dimension via a tuple
2020-11-03 09:25:29 -08:00
78b1f67e75
Document the Timeout parameter to wait_for_confirms
...
This parameter is in seconds. Also remove superfluous `CALL_TIMEOUT` macro.
cc @dumbbell
Also see rabbitmq/rabbitmq-server#2490
2020-11-03 09:25:29 -08:00
f2f2e0358b
Switch to Mozilla Public License 2.0 (MPL 2.0)
2020-07-10 15:13:17 +01:00
d56461c038
Update copyright (year 2020)
2020-03-10 15:39:18 +01:00
a2589a512c
(c) bump
2019-12-29 05:50:22 +03:00
27888c7189
URL Cleanup
...
This commit updates URLs to prefer the https protocol. Redirects are not followed to avoid accidentally expanding intentionally shortened URLs (i.e. if using a URL shortener).
# HTTP URLs that Could Not Be Fixed
These URLs were unable to be fixed. Please review them to see if they can be manually resolved.
* http://blog.listincomprehension.com/search/label/procket (200) with 1 occurrences could not be migrated:
([https](https://blog.listincomprehension.com/search/label/procket ) result ClosedChannelException).
* http://dozzie.jarowit.net/trac/wiki/TOML (200) with 1 occurrences could not be migrated:
([https](https://dozzie.jarowit.net/trac/wiki/TOML ) result SSLHandshakeException).
* http://dozzie.jarowit.net/trac/wiki/subproc (200) with 1 occurrences could not be migrated:
([https](https://dozzie.jarowit.net/trac/wiki/subproc ) result SSLHandshakeException).
* http://e2project.org (200) with 1 occurrences could not be migrated:
([https](https://e2project.org ) result AnnotatedConnectException).
* http://erlang.org/pipermail/erlang-bugs/2012-June/002933.html (200) with 1 occurrences could not be migrated:
([https](https://erlang.org/pipermail/erlang-bugs/2012-June/002933.html ) result ConnectTimeoutException).
* http://nitrogenproject.com/ (200) with 2 occurrences could not be migrated:
([https](https://nitrogenproject.com/ ) result ConnectTimeoutException).
* http://proper.softlab.ntua.gr (200) with 1 occurrences could not be migrated:
([https](https://proper.softlab.ntua.gr ) result SSLHandshakeException).
* http://yaws.hyber.org (200) with 1 occurrences could not be migrated:
([https](https://yaws.hyber.org ) result AnnotatedConnectException).
* http://choven.ca (503) with 1 occurrences could not be migrated:
([https](https://choven.ca ) result ConnectTimeoutException).
# Fixed URLs
## Fixed But Review Recommended
These URLs were fixed, but the https status was not OK. However, the https status was the same as the http request or http redirected to an https URL, so they were migrated. Your review is recommended.
* http://fixprotocol.org/ (301) with 1 occurrences migrated to:
https://fixtrading.org ([https](https://fixprotocol.org/ ) result SSLHandshakeException).
* http://erldb.org (UnknownHostException) with 1 occurrences migrated to:
https://erldb.org ([https](https://erldb.org ) result UnknownHostException).
## Fixed Success
These URLs were switched to an https URL with a 2xx status. While the status was successful, your review is still recommended.
* http://cloudi.org/ with 27 occurrences migrated to:
https://cloudi.org/ ([https](https://cloudi.org/ ) result 200).
* http://erlware.org/ with 1 occurrences migrated to:
https://erlware.org/ ([https](https://erlware.org/ ) result 200).
* http://inaka.github.io/cowboy-trails/ with 1 occurrences migrated to:
https://inaka.github.io/cowboy-trails/ ([https](https://inaka.github.io/cowboy-trails/ ) result 200).
* http://ninenines.eu with 6 occurrences migrated to:
https://ninenines.eu ([https](https://ninenines.eu ) result 200).
* http://tbaggery.com/2008/04/19/a-note-about-git-commit-messages.html with 1 occurrences migrated to:
https://tbaggery.com/2008/04/19/a-note-about-git-commit-messages.html ([https](https://tbaggery.com/2008/04/19/a-note-about-git-commit-messages.html ) result 200).
* http://tools.ietf.org/html/rfc3986 with 1 occurrences migrated to:
https://tools.ietf.org/html/rfc3986 ([https](https://tools.ietf.org/html/rfc3986 ) result 200).
* http://www.actordb.com/ with 2 occurrences migrated to:
https://www.actordb.com/ ([https](https://www.actordb.com/ ) result 200).
* http://www.cs.kent.ac.uk/projects/wrangler/Home.html with 1 occurrences migrated to:
https://www.cs.kent.ac.uk/projects/wrangler/Home.html ([https](https://www.cs.kent.ac.uk/projects/wrangler/Home.html ) result 200).
* http://www.erlang.org/ with 1 occurrences migrated to:
https://www.erlang.org/ ([https](https://www.erlang.org/ ) result 200).
* http://www.rabbitmq.com with 1 occurrences migrated to:
https://www.rabbitmq.com ([https](https://www.rabbitmq.com ) result 200).
* http://www.rabbitmq.com/ with 2 occurrences migrated to:
https://www.rabbitmq.com/ ([https](https://www.rabbitmq.com/ ) result 200).
* http://www.rabbitmq.com/build-erlang-client.html with 1 occurrences migrated to:
https://www.rabbitmq.com/build-erlang-client.html ([https](https://www.rabbitmq.com/build-erlang-client.html ) result 200).
* http://www.rabbitmq.com/erlang-client-user-guide.html with 2 occurrences migrated to:
https://www.rabbitmq.com/erlang-client-user-guide.html ([https](https://www.rabbitmq.com/erlang-client-user-guide.html ) result 200).
* http://www.rabbitmq.com/protocol.html with 1 occurrences migrated to:
https://www.rabbitmq.com/protocol.html ([https](https://www.rabbitmq.com/protocol.html ) result 200).
* http://www.rebar3.org with 1 occurrences migrated to:
https://www.rebar3.org ([https](https://www.rebar3.org ) result 200).
* http://contributor-covenant.org with 1 occurrences migrated to:
https://contributor-covenant.org ([https](https://contributor-covenant.org ) result 301).
* http://contributor-covenant.org/version/1/3/0/ with 1 occurrences migrated to:
https://contributor-covenant.org/version/1/3/0/ ([https](https://contributor-covenant.org/version/1/3/0/ ) result 301).
* http://inaka.github.com/apns4erl with 1 occurrences migrated to:
https://inaka.github.com/apns4erl ([https](https://inaka.github.com/apns4erl ) result 301).
* http://inaka.github.com/edis/ with 1 occurrences migrated to:
https://inaka.github.com/edis/ ([https](https://inaka.github.com/edis/ ) result 301).
* http://lasp-lang.org/ with 1 occurrences migrated to:
https://lasp-lang.org/ ([https](https://lasp-lang.org/ ) result 301).
* http://saleyn.github.com/erlexec with 1 occurrences migrated to:
https://saleyn.github.com/erlexec ([https](https://saleyn.github.com/erlexec ) result 301).
* http://www.erlang.org/doc/man/gen_tcp.html with 1 occurrences migrated to:
https://www.erlang.org/doc/man/gen_tcp.html ([https](https://www.erlang.org/doc/man/gen_tcp.html ) result 301).
* http://www.erlang.org/doc/man/inet.html with 1 occurrences migrated to:
https://www.erlang.org/doc/man/inet.html ([https](https://www.erlang.org/doc/man/inet.html ) result 301).
* http://www.mozilla.org/MPL/ with 27 occurrences migrated to:
https://www.mozilla.org/MPL/ ([https](https://www.mozilla.org/MPL/ ) result 301).
* http://zhongwencool.github.io/observer_cli with 1 occurrences migrated to:
https://zhongwencool.github.io/observer_cli ([https](https://zhongwencool.github.io/observer_cli ) result 301).
2019-03-20 03:14:58 -05:00
3e36da8e6a
Use 2047 instead of 2048
...
Since channel 0 exists on every connection for negotiation and
error communication.
2018-05-09 12:40:17 -05:00
d06c845f49
Change channel_max default to 2048
...
Part of rabbitmq/rabbitmq-server#1593 .
2018-05-09 10:05:46 -05:00
1905e30e67
Bump call timeout to 60s
...
To match default server heartbeat timeout.
While at it, increase initial connection timeout to 60s
to match (heartbeat timeout doesn't matter here specifically but
related in general).
2017-06-15 20:13:03 +03:00
c6e5a10035
Replace infinite timeouts with sensible defaults.
...
Change gen_server:call timeouts to use a configurable
default that is cached inside each process' process dictionary.
Also make supervisor shutdown timeouts use
the SUPERVISOR_WAIT value.
[#147178169 ]
2017-06-15 15:46:21 +01:00
ddc19bb666
Use the new -spec format
...
The old format is removed in Erlang 19.0, leading to build errors.
Also, get rid of the `use_specs` macro and thus always define -spec() &
friends.
While here, unnify the style of -type and -spec.
References rabbitmq/rabbitmq-server#860.
[#118562897 ]
[#122335241 ]
2016-06-29 13:14:30 +02:00
9eb22b6980
Fix compile error with Erlang OTP 19
2016-06-26 17:11:37 +03:00
d35000573b
Fix preprocessor ifdef for specs
...
The OTP 19 master branch gives syntax errors for the specs format used
in RabbitMQ:
amqp_gen_consumer_spec.hrl:30: syntax error before: '/'
This patch replaces the "edoc" ifdef with "use_specs" (like in all other
places), so RabbitMQ can be compiles with the OTP 19 master branch.
2015-12-17 11:18:36 +01:00
d196401124
modified heartbeat value to 10
2015-12-03 15:18:53 +01:00
5152a22d2a
(c) year
2015-05-24 04:48:39 +03:00
62f5b3d7ad
Backout 5bbe6d4f364f
2014-08-05 15:27:53 +04:00
cd8d23c517
Backout 5a8c2ebc869d
2014-08-05 15:27:04 +04:00
e1aed55e2a
Introduce amqp_msg.channel_pid
...
The channel will be sending notifications rabbit_amqqueue:send_notify/2.
Consumers need to know the pid to tell it to do so.
2014-08-04 10:44:08 +04:00
6d0f806ba9
Add a ref that identifies amqp_msg
...
To give consumers a chance to rabbit_amqqueue:notify_sent/2
deliveries. Can be useful in other contexts, too.
2014-08-04 09:46:00 +04:00
4edc0aab42
Update copyright for 2014
2014-03-17 17:25:21 +00:00
69b504345c
stable to default
2014-03-04 08:46:04 +00:00
bbd64ccf87
Spec for handle_server_cancel/2.
2014-03-04 08:45:08 +00:00
fbd9a66f92
Support direct connections with no user.
2014-02-05 13:18:41 +00:00
30dcbbaf50
Report authentication failures as returned by the broker
2013-09-24 11:58:25 +01:00
97f9ea8a34
Untabify
2013-08-01 11:03:16 +04:00
1e646caae1
Merge default into bug25191
2013-08-01 10:54:11 +04:00
3b431b82d9
s/VMware/GoPivotal/g
2013-07-01 10:49:12 +01:00
cb13e0f291
Add connection.blocked to client capabilities
2013-06-27 19:57:19 +04:00
147b7897e7
Rename
2013-02-22 12:15:22 +00:00
4cfc2a937c
Added include/routing_prefixes.hrl
2013-02-20 14:44:53 +00:00
4e730491c7
Update copyright 2013
2013-01-23 11:40:49 +00:00
364bd04f92
address -> host.
2012-11-19 16:34:02 +00:00
7b812d1b91
Add password to amqp_params_direct
2012-09-18 10:35:09 +01:00
b47ea65591
move LOG_ERR macro to where it belongs
...
This was missed in bug 25034 since the LOG_ERR was introduced in
parallel in bug 25056.
2012-09-11 13:46:11 +01:00
1f494cf572
merge bug25034
2012-08-14 17:44:34 +01:00
fc98667f55
report direct connection errors as errors
2012-07-16 12:34:15 +01:00
1d3af53355
rename adapter_info in order to avoid name conflicts
2012-07-02 19:09:40 +01:00
b4969bbb08
move adapter_info back into amqp_client.hrl
...
...since it is part of the API. We shall rename it later.
2012-07-02 17:31:38 +01:00
7749390ecf
move internal definitions etc out of amqp_client.hrl
...
...in order to avoid application name space polution
2012-07-02 16:54:31 +01:00
44278dc2b8
Update copyright 2012
2012-02-02 13:04:28 +00:00
bdf829cf3a
hide specs for the two gen_consumer implementations
...
The docs for both of them still reference the behaviour which includes the
specs as part of its documentation.
2012-01-23 12:54:43 +00:00
ef348e9191
merge default into bug23326
2011-10-25 15:19:32 +01:00
7bcf882334
expose socket_options in amqp_params_network
2011-10-24 15:39:06 +01:00
Michael Klishin
Michael Klishin
Michael Klishin
Ayanda-D
Luke Bakken
dcorbacho
Jean-Sébastien Pédron
Spring Operator
kjnilsson
Dinis Rosário
Johannes Weißl
Gabriele Santomaggio
Michael Klishin
Simon MacMullen
Emile Joubert
Matthias Radestock
Francesco Mazzoli
Alexandru Scvortov