Files
natsdotnet/tests/NATS.Server.Tests/JetStreamClusterControlExtendedApiTests.cs

13 lines
502 B
C#

namespace NATS.Server.Tests;
public class JetStreamClusterControlExtendedApiTests
{
[Fact]
public async Task Peer_remove_and_consumer_stepdown_subjects_return_success_shape()
{
await using var fx = await JetStreamClusterFixture.StartAsync(nodes: 3);
(await fx.RequestAsync("$JS.API.STREAM.PEER.REMOVE.ORDERS", "{\"peer\":\"n2\"}")).Success.ShouldBeTrue();
(await fx.RequestAsync("$JS.API.CONSUMER.LEADER.STEPDOWN.ORDERS.DUR", "{}")).Success.ShouldBeTrue();
}
}