86b0356492
Update rabbitmq-components.mk
2019-08-01 17:13:04 +03:00
edc3b65324
Update rabbitmq-components.mk
2019-07-09 16:05:45 +02:00
b7517061b9
Update rabbitmq-components.mk
2019-06-28 16:05:22 +02:00
beec0470e6
Update erlang.mk
2019-06-28 16:01:26 +02:00
0c5c26388a
Update rabbitmq-components.mk
2019-06-03 02:23:28 +01:00
3bacb06ba6
Update rabbitmq-components.mk
2019-05-17 15:17:11 +02:00
aed7b20a68
Update rabbitmq-components.mk
2019-05-17 08:36:13 +03:00
4f5d21ccf3
Update rabbitmq-components.mk
2019-05-16 23:22:39 +03:00
9d8a91ce81
Update rabbitmq-components.mk
2019-05-14 11:50:35 +03:00
6bd74ea30a
Update rabbitmq-components.mk
2019-05-13 16:43:35 +03:00
5ba7597300
URI parser: allow the container_id to be set
2019-05-08 10:50:05 +01:00
5ed06bbb68
Uri parser: return error when path segments are used
2019-05-08 09:48:40 +01:00
ed054e2e2f
Merge pull request #25 from rabbitmq/echo-flow-state
...
Add function to request flow state from sender
2019-05-07 19:41:36 +03:00
a21725d0d0
Update rabbitmq-components.mk
2019-05-01 13:18:04 +01:00
d8a5e0eedc
Update rabbitmq-components.mk
2019-04-30 16:20:51 -07:00
26a933028e
Update rabbitmq-components.mk
2019-04-30 14:47:23 +02:00
67299b6f04
Update rabbitmq-components.mk
2019-04-22 21:54:55 +01:00
0a9fdd60fb
Merge pull request #28 from hommeabeil/play-with-filter
...
Fix filter encoding
2019-04-17 18:23:37 +04:00
2a07fe1812
activemq_ct_helpers: Skip test if waiting for ActiveMQ fails
...
Also, wait longer (one minute instead of 10 seconds).
Before this patch, if the service didn't start in 10 seconds, it would
still proceed with the testcases. This led to uninformative test
failures.
There are log messages to help debug the situation if ActiveMQ doesn't
start.
2019-04-04 11:07:36 +02:00
9fc74a411b
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).
# Fixed URLs
## 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://www.apache.org/licenses/LICENSE-2.0 with 2 occurrences migrated to:
https://www.apache.org/licenses/LICENSE-2.0 ([https](https://www.apache.org/licenses/LICENSE-2.0 ) result 200).
2019-03-21 02:52:01 -05:00
2003561b02
update all the filters
2019-03-20 11:06:45 -04:00
bc1eb6193e
update
2019-03-20 08:42:15 -04:00
28c0b7e1b4
dirty hack the filter
2019-03-20 08:38:57 -04:00
f80a29d4fc
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).
# Fixed URLs
## 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://activemq.apache.org/configuring-transports.html with 2 occurrences migrated to:
https://activemq.apache.org/configuring-transports.html ([https](https://activemq.apache.org/configuring-transports.html ) result 200).
* http://activemq.apache.org/jmx.html with 2 occurrences migrated to:
https://activemq.apache.org/jmx.html ([https](https://activemq.apache.org/jmx.html ) result 200).
* http://activemq.apache.org/persistence.html with 2 occurrences migrated to:
https://activemq.apache.org/persistence.html ([https](https://activemq.apache.org/persistence.html ) result 200).
* http://activemq.apache.org/producer-flow-control.html with 2 occurrences migrated to:
https://activemq.apache.org/producer-flow-control.html ([https](https://activemq.apache.org/producer-flow-control.html ) result 200).
* http://activemq.apache.org/schema/core/activemq-core.xsd with 2 occurrences migrated to:
https://activemq.apache.org/schema/core/activemq-core.xsd ([https](https://activemq.apache.org/schema/core/activemq-core.xsd ) result 200).
* http://activemq.apache.org/slow-consumer-handling.html with 2 occurrences migrated to:
https://activemq.apache.org/slow-consumer-handling.html ([https](https://activemq.apache.org/slow-consumer-handling.html ) result 200).
* http://www.springframework.org/schema/beans/spring-beans.xsd with 2 occurrences migrated to:
https://www.springframework.org/schema/beans/spring-beans.xsd ([https](https://www.springframework.org/schema/beans/spring-beans.xsd ) result 200).
# Ignored
These URLs were intentionally ignored.
* http://activemq.apache.org/schema/core with 4 occurrences
* http://www.springframework.org/schema/beans with 6 occurrences
* http://www.w3.org/2001/XMLSchema-instance with 2 occurrences
2019-03-19 20:07:56 -05:00
ba105196f1
Update rabbitmq-components.mk
2019-03-15 05:32:41 +03:00
91b2eff7b6
Update rabbitmq-components.mk
2019-03-15 05:05:32 +03:00
bd38baa3be
Add function to request flow state from sender
...
It is part of the spec although RabbitMQ doesn't implement it.
2019-03-06 13:47:30 +00:00
7bda227517
Provide scheme defualts when parsing URIs
...
Else uri parsing will fail when explicit ports aren't provided.
2019-02-20 10:31:06 +00:00
2aeb7a8148
Update rabbitmq-components.mk
2019-02-12 23:23:42 +03:00
187c5c25b1
Update rabbitmq-components.mk
2019-01-09 12:54:49 -08:00
d720f0dbf6
Update rabbitmq-components.mk
2019-01-08 11:58:21 -08:00
82f7711495
Update rabbitmq-components.mk
2018-12-06 18:28:34 +03:00
204a3b624b
Update rabbitmq-components.mk
2018-12-06 03:15:01 +03:00
2e6988489f
Update rabbitmq-components.mk
2018-11-30 14:56:42 +01:00
3be8d0377f
Update rabbitmq-components.mk
2018-11-22 09:19:27 +01:00
5c0817875f
Update rabbitmq-components.mk
2018-10-29 12:43:10 +00:00
c7a4333e9e
Remove commented out code
...
[#161256187 ]
2018-10-26 09:36:57 +01:00
2c98f67aa0
Add API for client to pass the drain flag
...
[#161256187 ]
2018-10-24 17:55:14 +01:00
a70a105ead
Update rabbitmq-components.mk
2018-09-19 10:38:08 +02:00
d3d261852c
Update rabbitmq-components.mk
2018-09-11 14:22:20 +02:00
5138be18e6
Add amqp10_msg:body_bin/1 function
...
To allow users to get a binary representation of the body (which may be
amqp 1.0 encoded). Currently it re-encodes the decoded value, in the
future we can optimise this by delaying the actual body decoding until
it is needed. (if it ever is).
[#159434026 ]
2018-08-13 15:23:40 +01:00
d416fe145d
OTP 19.3 compatibility
2018-08-13 00:13:37 +03:00
8e50160c68
Merge pull request #21 from rabbitmq/uri-improvements
...
URI decode user and password when parsing
2018-08-10 18:13:23 +02:00
3afc76630a
URI decode user and password when parsing
...
Usernames and passwords in the amqp URI may be URI encoded. Ensure we
decode them during URI parse.
[#159650732 ]
2018-08-10 11:22:48 +01:00
e871f9b83e
Update rabbitmq-components.mk
2018-08-09 17:45:43 +02:00
330e294d78
Merge branch 'master' into uri-improvements
2018-08-09 14:16:04 +02:00
cd672ed251
Update rabbitmq-components.mk
2018-08-09 12:16:53 +02:00
d44ac69679
improve URI support
...
This change includes three improvements:
1. Support configuring tls versions through the uri. Previusly this
could only be done in code or by configururing the application
environment.
2. Default the hostname connection property to the URI host if no
hostname query parameter was found.
3. Make sasl=plain implicit if the URI contains a username and password.
[#159650732 ]
2018-08-09 10:50:54 +01:00
12c1b028cc
Update rabbitmq-components.mk
2018-06-07 11:31:28 +02:00
df86bf4237
Merge pull request #18 from rabbitmq/qpid-jms-client-support
...
Make compatible with amqp10_common changes
2018-04-24 00:59:36 +09:00
9a3c409e71
Make compatible with amqp10_common changes
...
The array representation was changed and needed updating.
[#156613309 ]
2018-04-23 12:13:34 +01:00
cf3e7db9c6
Update erlang.mk
2018-04-11 10:52:16 +02:00
e6b430f8b2
Update rabbitmq-components.mk
2018-04-11 10:51:14 +02:00
3a9f24d3aa
Update rabbitmq-components.mk
2018-04-11 10:09:56 +02:00
b8e5b4e0a0
translate_filters tests
2018-04-07 18:24:24 +02:00
12a78bad4f
fix dialyzer errors
2018-04-07 15:55:28 +02:00
55860b5e5e
export attach_receiver_link/6
2018-04-07 15:29:39 +02:00
e8e599380c
export filter type and add comment
2018-03-24 15:40:16 +01:00
d34fc6b372
test azure filtering
2018-03-23 18:47:37 +01:00
982c78e89c
more readable formatting
2018-03-23 13:50:10 +01:00
20c8ea6c93
Allow passing of filters in attach receiver
2018-03-23 13:38:40 +01:00
8e6f1657e4
Update erlang.mk
2018-03-02 19:02:43 +01:00
66c01ca344
Update rabbitmq-components.mk
2018-01-30 15:23:24 +01:00
1fcaefee99
Update rabbitmq-components.mk
2018-01-29 16:22:06 -08:00
6181279581
Update rabbitmq-components.mk
2018-01-23 17:21:16 +01:00
0223ed33ee
Update rabbitmq-components.mk
2018-01-23 15:31:06 +01:00
13bdfcf6c4
Update rabbitmq-components.mk
2018-01-23 12:50:19 +01:00
14ffd0d165
Update rabbitmq-components.mk
2018-01-22 22:13:15 +00:00
85b2430b29
Update rabbitmq-components.mk
2018-01-22 21:53:59 +00:00
c66617343b
Add test for large message sizes.
...
Set a more sensible default for max_frame_size that works better with
large messages.
Clean up partial transfers on completion.
2017-12-21 16:21:22 +00:00
c68aa1a202
Handle transfer frames without deliver_id
...
Fixes bug where continuation frames without a delivery_id were not
handled.
Also re-enables tests using the mock server.
[#153702031 ]
2017-12-19 15:51:26 +00:00
c746c78223
Add integration test that parses an amqp uri
...
[#153597350 ]
2017-12-12 16:46:02 +00:00
fdc0719c7c
typespec fixes
2017-12-12 15:32:39 +00:00
37a971637d
Ensure user and pass are binaries
2017-12-11 17:41:05 -08:00
a809b14f36
Add support for server_name_indication in AMQP URI
...
See PT story [153560059]
See rabbitmq/rabbitmq-erlang-client#95
2017-12-11 11:37:38 -08:00
de4a4e5ef2
Update rabbitmq-components.mk
2017-12-01 15:16:10 +01:00
61b5529ee3
Update rabbitmq-components.mk
2017-11-28 14:00:29 +01:00
6a18c01dc0
Update rabbitmq-components.mk
2017-11-28 13:24:43 +01:00
8e79c9b9fc
Makefile: Update Apache ActiveMQ download URL
2017-10-24 14:41:39 +02:00
0b665d6244
With Erlang 20, turn off warning about deprecated gen_fsm
...
Specifying '+{nowarn_deprecated_functions, [...]}' on the command line
didn't appear to work, so I put those directives in source files and
used a define to enable it.
2017-10-16 17:40:57 +02:00
09c3b0e8f4
Update rabbitmq-components.mk
2017-10-13 15:02:18 +02:00
6f5099283f
Update rabbitmq-components.mk
2017-10-13 14:33:02 +02:00
517e0512bd
Update README.md
...
Fix sample code.
2017-09-25 09:38:34 +01:00
23fb789371
Remove a file with an absolute system-specific path hardcoded
...
We may want to restore it later in a way that works for everyone.
Note that currently test suite runs delete it anyway.
2017-09-12 11:39:00 -04:00
948ccbd0d1
Update erlang.mk
2017-08-30 19:36:37 +01:00
954d1c24cb
Update README.md
2017-08-11 15:44:28 +03:00
8e8b0a6e82
Update README.md
2017-08-11 15:44:07 +03:00
2c2c1ed9e8
Merge pull request #2 from rabbitmq/rabbitmq-shovel-26
...
Only auto flow based on settled transfers.
2017-06-08 23:07:29 +03:00
52186e736a
Update README with transfer_limit_margin
...
connection config
2017-06-07 17:13:53 +01:00
42ec995f69
Refine and comment connection config
2017-06-07 17:10:12 +01:00
3b5ce0b96c
Only auto flow based on settled transfers.
...
Previously we'd auto flow more credit to sender after a certain number
of received transfer whether they have been settled or not. This changes
the approach to keep a separate counter of transfers that have been
settled and only grant more credit once this falls below the requested
limit. It isn't a perfect approach but it is much better than what was
there before which would effectively have the effect of providing no
flow control.
2017-06-07 16:46:15 +01:00
42ec958cdd
Update README.md
2017-06-06 23:39:49 +03:00
3e2ff91c96
Disable debug logging
2017-05-26 16:51:04 +01:00
d92661a8c6
Update README.md
2017-05-12 18:36:33 +03:00
1edeb64ce7
add attach_sender_link_sync/5
2017-05-09 11:37:40 +01:00
4304640f38
Add api overload to configure durability during attach
...
It is a fairly commonly used configuration option.
2017-05-08 13:25:31 +01:00
45fb64fda7
dialyzer fixes
2017-05-08 11:29:01 +01:00
631d094ba5
Monitor reader in case socket is closed
...
The connection process won't know if the socket is closed
as it is the reader that owns the socket. By monitoring the
reader the connection can at least close and notify closure.
2017-05-08 11:16:57 +01:00
7c237ae0e4
merge
2017-05-04 17:54:12 +01:00
10fc840c04
Replace LinkRef with Sender or Receiver
...
Signed-off-by: Gerhard Lazu <gerhard@rabbitmq.com>
2017-05-02 12:40:53 +01:00
2cb3cf33ce
add crypto to LOCAL_DEPS
2017-05-02 12:13:56 +01:00
095897e04f
Treat unexpected socket closures as errors.
...
AMQP 1.0 requires connection closure to follow protocol.
Hence we treat unexpected socket closures as errors and
avoid trying to terminate the supervisor as this can
cause a race condition when the connection tries to do
the same.
2017-05-02 12:05:13 +01:00
a86a249844
Terminius durabuility
...
Expose attach_link/2 that takes and AttachArgs map so that we can
specify the terminus durability during attach.
2017-05-02 12:02:22 +01:00
967511c5c4
Handle undefined delivery state.
...
IBM MQ returns an undefined delivery state when the link is detached
before the disposition is sent.
2017-05-02 12:00:32 +01:00
f4addfc122
correctly tag timestamps
2017-04-18 13:06:54 +01:00
588709aa55
message and delivery annotation setters
2017-04-18 12:10:32 +01:00
2b40d727eb
fix issues encoding/decoding application_properties
2017-04-13 17:05:30 +01:00
4b5c31b36a
Turn certain debug messages into full error logs
2017-04-13 10:58:01 +01:00
c53a5098bd
Add application_properties
2017-04-13 10:51:27 +01:00
ad195319d2
disable debug logging
2017-04-12 10:59:58 +01:00
e5eb41aabd
Add license headers
2017-04-12 10:53:27 +01:00
121b31473a
add tls options to uri parser
2017-04-06 12:03:05 +01:00
21d8a885ac
fix type spec
2017-04-05 19:36:39 +01:00
874b2023a0
basic amqp uri parser
2017-04-05 17:37:34 +01:00
090f4a064f
Docs and refactor to use link_refs in amqp10_link events
2017-04-04 17:07:14 +01:00
9e01f3f8e5
move hrl file as not meant to be shared
2017-04-03 15:46:53 +01:00
7790bc14fd
README updates
2017-04-03 15:46:06 +01:00
45276a5a0a
Add README.md
2017-04-03 15:25:02 +01:00
ae79d197b3
document api modules
2017-04-03 13:10:45 +01:00
2e4e39215b
handle tcp errors
2017-04-03 11:58:06 +01:00
4bf5effbfd
implement flow auto-renewal
2017-04-03 11:44:40 +01:00
22e48d0d0b
report reason in detached event
2017-04-03 09:28:57 +01:00
bc98d8d0f5
add service bus test to test suite
...
without adding it to the all() groups
2017-03-31 16:59:12 +01:00
1419d83b6c
set default message_format
...
Azure ServiceBus goes really weird without it.
2017-03-31 14:15:12 +01:00
65064d8ea1
Tweaks for Servicebus
2017-03-31 12:20:21 +01:00
78cb78ed0c
Use tls for roundtrip test
2017-03-30 11:08:22 +01:00
245427cc96
Add basic ssl/tcl support
2017-03-30 10:48:15 +01:00
e702bc08b3
Implement PLAIN SASL auth
2017-03-29 16:57:59 +01:00
204c0b8b90
make link attach/detach async
2017-03-28 11:21:03 +01:00
390e9d05ca
rabbitmq amqp10 plugin returns undefined for the link
...
detach close parameter
2017-03-24 17:56:52 +00:00
95a2ab9833
client initiated link detach
2017-03-24 17:39:43 +00:00
a8ec136090
Do not expose delivery ids in api
...
The user should only have to keep track of the
user-provided deliery tag.
2017-03-24 16:19:43 +00:00
bb7682ce4b
Add elvis
...
Fix dialyzer issues in tests
2017-03-24 10:51:52 +00:00
401d2dae4c
API refactor
2017-02-17 17:39:01 +00:00
0b70bcd129
incoming heartbeats
2017-02-16 10:57:22 +00:00
95f98625c1
switchable debugging
2017-02-07 11:57:53 +00:00
4b6dfa0613
disposition frames _must_ specify role
2017-02-07 11:41:23 +00:00
1b43387aaf
make dispositions of unsettled messages
...
async
2017-02-07 11:22:34 +00:00
678ef4362b
Make explose flow_credit api to be able to subscribe
2017-01-24 11:38:41 +00:00
41865b3605
Create sync version of connection:open
2017-01-24 10:49:56 +00:00
bc89987362
Allow the container_id to be configured.
2017-01-24 10:09:06 +00:00
953da8b540
Rename connection states more in line with the spec.
2017-01-24 09:23:42 +00:00
34289d4f30
mock1 -> insufficient_credit test
2017-01-23 16:35:03 +00:00
3de1e1a95e
Add basic mock_server for testing.
...
Allow connections without sasl.
Add sync version of session:begin
2017-01-23 16:12:59 +00:00
8f9b4092af
More bookkeeping
2017-01-20 17:38:54 +00:00
3ea277e0c5
link and session bookkeeping
2017-01-20 12:11:07 +00:00
b7bd7bfe80
Disposition handling for receiver links.
2017-01-18 17:03:02 +00:00
c4afa8c43d
Disposition handling for senders
2017-01-18 10:44:19 +00:00
454459eab6
Tidy up comments
2017-01-17 12:58:04 +00:00
1aa2ee8533
Split outgoing transfer frames
2017-01-17 12:29:06 +00:00
33fb4883f5
Handle multiple incoming transfer frames
2017-01-12 12:38:14 +00:00
ee42b4dd8a
Use amqp10_msg in links api
2017-01-11 15:27:33 +00:00
5fc5abcc07
Use shared code from rabbitmq-amqp1.0-common
2017-01-11 16:08:08 +01:00
b5ea0fbcf2
amqp10_msg: handle non binary body types
2017-01-11 13:20:14 +00:00
cbf004c8a8
amqp10_msg: basic setters
2017-01-10 18:08:42 +00:00
d77d76a1fa
Add application_properties, footer and additional amqp
...
body options.
2017-01-10 15:57:01 +00:00
d5dfb85230
Add amqp_msg module with functions for parsing message data
2017-01-10 15:06:44 +00:00
c12dce976e
test: Automatically download and extract ActiveMQ
2017-01-09 15:17:19 +01:00
f544124580
system_SUITE: Test against both RabbitMQ and ActiveMQ
2017-01-09 13:17:52 +01:00
b98a2e8ce1
route tranfer frames
2017-01-09 09:25:58 +00:00
0436c39c92
complete rountrip transfer and sync get
2017-01-06 14:50:53 +00:00
f046345531
satisfy dialyzer
2017-01-06 12:20:39 +00:00
d82c5f6270
some dialyzer fixes
2017-01-06 09:38:34 +00:00
809ebe58dc
make reader state names more generic
2017-01-06 09:22:58 +00:00
3fe84f77ce
add tests for sasl frame routing
2017-01-06 09:17:16 +00:00
426af68d1b
We got transfer
2017-01-05 17:27:07 +00:00
50260ad721
Rename session states according to spec.
2017-01-04 17:21:07 +00:00
0db2a01b1c
refactoring and first cut transfer
2017-01-04 17:00:52 +00:00
0309690964
Revisit supervision tree and implement sessions
2017-01-02 17:31:59 +01:00
2bd711aba3
First attempt at connection supervision tree
2016-12-23 15:51:28 +00:00
eb97d949a7
codegen, Makefile, specs and binary parsers
2016-12-20 17:56:04 +00:00
342127c402
Initial commit
2016-12-20 16:22:53 +00:00
Michael Klishin
Arnaud Cogoluègnes
Jean-Sébastien Pédron
Gerhard Lazu
Michael Klishin
kjnilsson
Luke Bakken
Michael Klishin
Spring Operator
Jean Bouchard
Jean-Sébastien Pédron
Patrick Detlefsen
Diana Corbacho
Karl Nilsson
Daniil Fedotov
Karl Nilsson