Skip to content

Commit f676338

Browse files
committed
Add x-super-stream argument to super stream exchange
When created from performance tool.
1 parent ca471ed commit f676338

File tree

1 file changed

+6
-1
lines changed
  • src/performance-tool/java/com/rabbitmq/stream/perf

1 file changed

+6
-1
lines changed

src/performance-tool/java/com/rabbitmq/stream/perf/Utils.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -609,7 +609,12 @@ public String apply(String stream, Integer index) {
609609

610610
static void declareSuperStreamExchangeAndBindings(
611611
Channel channel, String superStream, List<String> streams) throws Exception {
612-
channel.exchangeDeclare(superStream, BuiltinExchangeType.DIRECT, true);
612+
channel.exchangeDeclare(
613+
superStream,
614+
BuiltinExchangeType.DIRECT,
615+
true,
616+
false,
617+
Collections.singletonMap("x-super-stream", true));
613618

614619
for (int i = 0; i < streams.size(); i++) {
615620
channel.queueBind(

0 commit comments

Comments
 (0)