Skip to content

Commit 33a7749

Browse files
committed
Add sample code for website documentation
1 parent f1bbd2e commit 33a7749

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

src/test/java/com/rabbitmq/client/amqp/docs/WebsiteDocumentation.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package com.rabbitmq.client.amqp.docs;
22

3+
import static com.rabbitmq.client.amqp.ConnectionSettings.Affinity.Operation.PUBLISH;
34
import static java.nio.charset.StandardCharsets.UTF_8;
45

56
import java.time.Duration;
@@ -375,4 +376,15 @@ void combinedFilterExpressions() {
375376
})
376377
.build();
377378
}
379+
380+
void affinity() {
381+
Environment environment = null;
382+
Connection connection = environment.connectionBuilder()
383+
.affinity()
384+
.queue("my-queue")
385+
.operation(PUBLISH)
386+
.reuse(true)
387+
.connection()
388+
.build();
389+
}
378390
}

0 commit comments

Comments
 (0)