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