Skip to content

Commit cd6409a

Browse files
Spring: use standard queue names in more places
1 parent 3ed15cd commit cd6409a

2 files changed

Lines changed: 5 additions & 5 deletions

File tree

spring-amqp/src/main/java/org/springframework/amqp/tutorials/tut6/Tut6Config.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ private static class ClientConfig {
3838

3939
@Bean
4040
public DirectExchange exchange() {
41-
return new DirectExchange("tut.rpc");
41+
return new DirectExchange("rpc");
4242
}
4343

4444
@Bean
@@ -53,12 +53,12 @@ private static class ServerConfig {
5353

5454
@Bean
5555
public Queue queue() {
56-
return QueueBuilder.durable("tut.rpc.requests").quorum().build();
56+
return QueueBuilder.durable("rpc_queue").quorum().build();
5757
}
5858

5959
@Bean
6060
public DirectExchange exchange() {
61-
return new DirectExchange("tut.rpc");
61+
return new DirectExchange("rpc");
6262
}
6363

6464
@Bean

spring-amqp/src/main/java/org/springframework/amqp/tutorials/tut6/Tut6Server.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,8 @@
2323
*/
2424
public class Tut6Server {
2525

26-
@RabbitListener(queues = "tut.rpc.requests")
27-
// @SendTo("tut.rpc.replies") used when the client doesn't set replyTo.
26+
@RabbitListener(queues = "rpc_queue")
27+
// @SendTo("rpc_replies") used when the client doesn't set replyTo.
2828
public int fibonacci(int n) {
2929
System.out.println(" [x] Received request for " + n);
3030
int result = fib(n);

0 commit comments

Comments
 (0)