Skip to content

Commit f1fbda2

Browse files
committed
Add x-super-stream arguments to super stream exchange
In tests.
1 parent aed7332 commit f1fbda2

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

src/test/java/com/rabbitmq/stream/impl/TestUtils.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -267,7 +267,12 @@ static void declareSuperStreamTopology(Connection connection, String superStream
267267
static void declareSuperStreamTopology(Connection connection, String superStream, String... rks)
268268
throws Exception {
269269
try (Channel ch = connection.createChannel()) {
270-
ch.exchangeDeclare(superStream, BuiltinExchangeType.DIRECT, true);
270+
ch.exchangeDeclare(
271+
superStream,
272+
BuiltinExchangeType.DIRECT,
273+
true,
274+
false,
275+
Collections.singletonMap("x-super-stream", true));
271276

272277
List<Tuple2<String, Integer>> bindings = new ArrayList<>(rks.length);
273278
for (int i = 0; i < rks.length; i++) {

0 commit comments

Comments
 (0)