e87581f14c
Remove unnecessary dependencies
2021-01-19 15:04:59 +01:00
2f903843e0
Add list_stream_publishers CLI command
2021-01-19 14:49:30 +01:00
1e6244990c
Add list_stream_consumers CLI command
2021-01-19 11:31:39 +01:00
0d73b58be0
Re-order stream command constants
...
The order is more usage-oriented.
2021-01-18 11:25:21 +01:00
52aa2963f5
Bump test dependencies in stream plugins
2021-01-14 17:58:38 +01:00
5f0df3bdb0
Format stream and stream management plugins code
2021-01-06 15:47:27 +01:00
07b9e68ff5
Add logs to some stream tests
2021-01-06 14:38:02 +01:00
c0bb7ec4a7
Add offset & consumed metrics to stream consumer
2020-12-15 15:37:26 +01:00
e5ed53c5e2
Merge branch 'master' into rabbitmq-stream-management
2020-12-08 11:41:22 +01:00
87837f857d
Fix failure tests in stream plugin
2020-12-08 11:40:38 +01:00
846b36bec6
Fix metrics table GC test in stream plugin
2020-12-08 09:47:38 +01:00
1faeaad499
Add publisher REST endpoint to stream consumer management
2020-12-04 17:22:14 +01:00
224e9914b2
Merge branch 'master' into rabbitmq-stream-management
2020-12-04 10:26:42 +01:00
c51e060a07
Wait longer for replicas to come up in stream plugin
2020-12-04 09:48:56 +01:00
66867a4062
Add GC to stream consumer monitoring table
2020-12-02 18:12:45 +01:00
08891a734e
Merge branch 'master' into rabbitmq-stream-management
2020-11-30 09:42:54 +01:00
67308be13c
Remove stream field from publish command
...
Only the publisher ID is necessary now the publisher declaration is
mandatory before publishing.
2020-11-27 11:07:10 +01:00
9859714f0e
Declare publisher in stream test
2020-11-24 18:18:14 +01:00
584811582b
Add first tests for stream management
...
They are using Java to have a proper stream client.
2020-11-23 11:23:29 +01:00
a1f6006356
Support leader locator strategies
...
References rabbitmq/rabbitmq-server#2471
2020-10-21 15:25:31 +02:00
cc030ac195
Support initial-cluster-size argument on creation
...
See rabbitmq/rabbitmq-server#2467
2020-10-16 14:07:19 +02:00
27d06e8021
Add CLI command to list stream connections
2020-10-16 09:18:36 +02:00
685164be64
Add INI-type configuration support
2020-10-12 17:29:38 +02:00
b8bdb5ae7b
Bump dependencies in Java test suite
...
And apply Google Java Format with Maven Spotless plugin.
2020-09-29 12:05:29 +02:00
03a11e0771
Adapt failure tests
...
They are a bit more defensive. The subscription is also now more
reliable by returning a stream-not-available code if necessary.
Using also Aten poll interval to 1 second (bumped to 5 seconds in master
now).
2020-09-29 11:29:56 +02:00
c25d89d67a
Adapt test to additional chunk type field in chunk
2020-09-03 13:46:57 +02:00
21d9aea96c
Add publisher ID
2020-09-02 15:13:37 +02:00
db93e14932
Use byte for subscription ID
...
Instead of integer. This is to be consistent with the introduction of a
similar ID for publishers (which will be a byte as well).
2020-09-01 18:07:27 +02:00
58f6ebff2e
Refactor Java tests after Client package change
2020-08-06 14:01:02 +02:00
02d87cab5d
Fix frame reading in test
2020-07-23 11:40:20 +02:00
7740fee13e
Pass in monitor reference, not stream name
2020-07-09 11:33:44 +02:00
4714f682e5
Add consumer failure test
...
The node the consumer is connected to fails, the consumer connects
and starts consuming where it left off.
2020-07-06 17:42:46 +02:00
4f01776a65
Add publishing failure test
...
Stream leader node fails while publisher is publishing, publisher
reconnects on the new leader. A consumer should read all the confirmed
messages afterwards.
2020-07-03 16:10:38 +02:00
1597bdf14a
Disable failure test
2020-06-29 10:51:31 +02:00
30e51ca4cb
Add failure test
2020-06-25 16:25:02 +02:00
1d3978ae40
Change response code label
...
From "stream deleted" to "stream not available". It covers now the
deletion of a stream and the unavailibility due to a failure. This is up
to the client to find out what to do (typically send a metadata request
about the stream and see if it's still there).
2020-06-23 10:51:34 +02:00
5bd352737c
Pass in node information to Java test suite
2020-06-22 16:35:07 +02:00
50581b2255
Fix cluster tests
2020-06-11 18:12:31 +02:00
d3aa774156
Add Java-based tests for clustering
2020-06-11 15:38:07 +02:00
c39852fa72
Introduce PeerProperties command
...
To exchange client/server properties at the beginning of the connection.
2020-06-10 10:42:29 +02:00
d2a29c5aef
Support client properties
2020-06-09 17:48:23 +02:00
6ef10c8573
Use MPL 2.0
2020-06-08 09:54:33 +02:00
a56cf4013c
Support first/last/next/offset/timestamp offset spec
2020-06-02 16:35:00 +02:00
b54026aa32
Add arguments for stream creation
...
To handle retention settings.
2020-05-19 18:18:30 +02:00
2d19e85925
Use stream instead of target
2020-05-06 09:15:16 +02:00
204f61399b
Handle client heartbeat
2020-04-01 10:08:32 +02:00
ece2a4770f
Refactoring before introducing heartbeat
...
Introduce a level of supervisors to have a parent PID for the heartbeat
process.
2020-03-31 10:12:35 +02:00
e899bdfb3e
Refactor tune
...
Use int32 for both max frame size and bump max frame size to 1 MB.
2020-03-27 15:55:57 +01:00
670f5f639b
Add test for close
2020-03-27 09:26:02 +01:00
9667525cd7
Update test for opening sequence
2020-03-26 17:52:54 +01:00
1fd5270d01
Use constants in tests
2020-03-25 10:22:16 +01:00
b84de96d0b
Add test for authentication
2020-03-25 10:08:10 +01:00
4e8a801e8d
Add license information
2020-03-17 10:59:37 +01:00
ab98aecd17
Initial import
2020-03-16 16:40:02 +01:00
Arnaud Cogoluègnes