Commit Graph

34 Commits

Author SHA1 Message Date
David Ansari 3d7a027503 Send all received WebSocket frames to app
Prior to this commit, if the WebSocket client received multiple
WebSocket frames in a single Erlang message by gen_tcp, the WebSocket
client sent only the first received WebSocket frame to the application.

This commit fixes this bug by having the WebSocket client send all
WebSocket frames to the application.
2025-02-24 20:50:55 +01:00
David Ansari 579c58603e Support AMQP over WebSocket (OSS part) 2025-01-27 17:50:47 +01:00
Michael Klishin 968eefa1bb
Bump (c) line year
There are no functional changes to this massive diff.
2025-01-01 17:54:10 -05:00
Michael Klishin 01092ff31f
(c) year bumps 2024-01-01 22:02:20 -05:00
Michael Klishin 1b642353ca
Update (c) according to [1]
1. https://investors.broadcom.com/news-releases/news-release-details/broadcom-and-vmware-intend-close-transaction-november-22-2023
2023-11-21 23:18:22 -05:00
Jean-Sébastien Pédron 6c83939008
rabbit_ct_client_helpers: Add a timeout to `open_channel/2`
[Why]
Exactly like in commit b165adb958, we
don't need to wait indefinitely for a channel to open. If it lasts,
there is a problem.

There is probably a weakness/bug in that basic channels manager that
would explain those indefinite operations though.
2023-08-04 10:14:58 +02:00
David Ansari b165adb958 Add timeout for test AMQP 0.9.1 connection to open
We see sporadic test failures where a test case hangs in the
receive until the Bazel suite timeout is reached.

There is no point in a test case to wait forever for an AMQP 0.9.1
connection to establish. Let's time out after 1 minute.

This will make the test case fail faster.
2023-02-16 19:25:06 +01:00
Michael Klishin ec4f1dba7d
(c) year bump: 2022 => 2023 2023-01-01 23:17:36 -05:00
Rin Kuryloski bef2756b5f Fixes for various dialyzer warnings 2022-12-02 09:14:08 +01:00
Luke Bakken 7fe159edef
Yolo-replace format strings
Replaces `~s` and `~p` with their unicode-friendly counterparts.

```
git ls-files *.erl | xargs sed -i.ORIG -e s/~s>/~ts/g -e s/~p>/~tp/g
```
2022-10-10 10:32:03 +04:00
Michael Klishin 7c47d0925a
Revert "Correct a double quote introduced in #4603"
This reverts commit 6a44e0e2ef.

That wiped a lot of files unintentionally
2022-04-20 16:05:56 +04:00
Michael Klishin 6a44e0e2ef
Correct a double quote introduced in #4603 2022-04-20 16:01:29 +04:00
Michael Klishin c38a3d697d
Bump (c) year 2022-03-21 01:21:56 +04:00
David Ansari e3ccefbf39 Maintain order when dead-lettering rejected messages in quorum queues
Before this commit, when a client consumes from a quorum queue and
rejects many messages, the order in which the messages got dead-lettered
is not the same as the order in which the messages got rejected.

Classic queues already maintain the order.
2022-02-28 16:27:56 +01:00
Michael Klishin 8687912032 rabbit_ct_client_helpers:consume/3: don't expect the queue was fully drained
in some tests, e.g. eager_sync_SUITE, this may not always be the case.
In general, it is quite reasonable for a test to not consume every single message
available, too.
2021-01-22 10:25:18 +03:00
dcorbacho f6ba7bc184 Switch to Mozilla Public License 2.0 (MPL 2.0) 2020-07-11 19:53:03 +01:00
Jean-Sébastien Pédron 20e2a402c0 Update copyright (year 2020) 2020-03-10 16:08:29 +01:00
Michael Klishin b956dcdf66 (c) bump 2019-12-29 05:50:27 +03:00
Michael Klishin 9ad56efed3 rabbit_ct_client_helpers: introduce consume_without_acknowledging/3 2019-05-09 19:49:06 +03:00
Jean-Sébastien Pédron b8c717b1e9 Merge branch 'stable' 2017-07-31 10:11:20 +02:00
Jean-Sébastien Pédron af8b15217f rabbit_ct_client_helpers: Be sure to wait for connection/channel process exit
I didn't find any evidence the previous code was broken; I suspected
this, but the problem was elsewhere. But this way, we are even safer.

[#149584741]
2017-07-27 17:55:19 +02:00
Jean-Sébastien Pédron 59e8ad89a9 Merge branch 'stable' 2017-07-06 15:52:47 +02:00
Jean-Sébastien Pédron 22c59eac3e rabbit_ct_client_helpers: Wait for 5 seconds in consume()
... before deciding we won't receive more messages from the broker.

Hopefully it should help with timeouts in CI.
2017-07-06 15:51:41 +02:00
Jean-Sébastien Pédron 8a4e18307a rabbit_ct_client_helpers: Set amqp_client gen_server:call timeout to infinity
It was changed from infinity to 30 seconds in the Erlang client in
commit 2e7586145a50fbe4e41952149e113543df6739ef, as part of #147178169.

Unfortunately, this broke several testcases which have to wait for
confirms for more thant 30 seconds.
2017-06-27 14:03:00 +02:00
Jean-Sébastien Pédron 0d614b33a1 Keep only files related to Erlang client helpers
[#134347953]
2016-11-15 16:42:30 +01:00
kjnilsson b7afc85abb Symlink private_log directory for the last test run inside logs 2016-10-07 12:35:50 +01:00
Jean-Sébastien Pédron f308371a12 rabbit_ct_helpers: Use path to `rabbit_common` in rabbit_common_srcdir
... not `rabbit`.

This fixes a failure in the rabbitmq-federation plugin testsuite.
2016-09-29 15:50:18 +02:00
Jean-Sébastien Pédron b95f8740c7 New PropEr helpers from branch rabbitmq-management-236 in rabbitmq-common
[#130086871]
2016-09-27 11:14:19 +02:00
Jean-Sébastien Pédron 9658ef1791 rabit_ct_client_helpers: Use values from `Config`
... instead of hard-coding them.
2016-09-23 14:45:43 +02:00
Jean-Sébastien Pédron 9a176594c6 rabbit_ct_client_helpers: Support direct conn. in open_unmanaged_connection() 2016-09-23 14:41:55 +02:00
Jean-Sébastien Pédron 75e33c0f93 rabbitmq_ct_helpers: Base directory lookups on rabbitmq-ct-helpers
[#130086871]
2016-09-19 11:08:45 +02:00
Jean-Sébastien Pédron b23688e80d inet_tcp_proxy: Use error_logger instead of rabbit_log
rabbit_log is part of rabbitmq-server and we don't want a circular
dependency.

[#130086871]
2016-09-19 11:06:36 +02:00
Jean-Sébastien Pédron 73b45bd68a Initial import of all testsuite helpers (stable branch)
[#130086871]
2016-09-15 12:09:00 +02:00
Jean-Sébastien Pédron 15bb6984da Initial import of all testsuite helpers
[#130086871]
2016-09-15 11:51:31 +02:00