Skip to content

Commit 468cafe

Browse files
villainscodevillainscode
committed
step8 RetryTemplate 을 이용한 재처리 기본 구조
1 parent c5a6f20 commit 468cafe

10 files changed

Lines changed: 42 additions & 175 deletions

‎src/main/java/net/harunote/hellomessagequeue/step7/DeadLetterConsumer.java‎

Lines changed: 0 additions & 46 deletions
This file was deleted.

‎src/main/java/net/harunote/hellomessagequeue/step7/MessageConsumer.java‎

Lines changed: 0 additions & 48 deletions
This file was deleted.

‎src/main/java/net/harunote/hellomessagequeue/step7/OrderController.java‎

Lines changed: 0 additions & 30 deletions
This file was deleted.

‎src/main/java/net/harunote/hellomessagequeue/step7/OrderProducer.java‎

Lines changed: 0 additions & 23 deletions
This file was deleted.

‎src/main/java/net/harunote/hellomessagequeue/step7/RabbitMQManualConfig.java‎

Lines changed: 0 additions & 26 deletions
This file was deleted.

‎src/main/java/net/harunote/hellomessagequeue/step8/OrderConsumer.java‎

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
package net.harunote.hellomessagequeue.step8;
2+
3+
import com.rabbitmq.client.Channel;
4+
import org.springframework.amqp.rabbit.annotation.RabbitListener;
5+
import org.springframework.messaging.handler.annotation.Header;
6+
import org.springframework.stereotype.Component;
7+
8+
import java.io.IOException;
9+
10+
@Component
11+
public class OrderConsumer {
12+
13+
}

‎src/main/java/net/harunote/hellomessagequeue/step8/OrderController.java‎

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
package net.harunote.hellomessagequeue.step8;
2+
3+
import org.springframework.http.ResponseEntity;
4+
import org.springframework.web.bind.annotation.*;
5+
6+
@RestController
7+
@RequestMapping("/api/order")
8+
public class OrderController {
9+
10+
}

‎src/main/java/net/harunote/hellomessagequeue/step8/OrderDLQConsumer.java‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
package net.harunote.hellomessagequeue.step8;
2+
3+
import org.springframework.stereotype.Component;
4+
5+
@Component
6+
public class OrderDLQConsumer {
7+
8+
}

‎src/main/java/net/harunote/hellomessagequeue/step8/OrderProducer.java‎

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
package net.harunote.hellomessagequeue.step8;
2+
3+
import org.springframework.amqp.rabbit.core.RabbitTemplate;
4+
import org.springframework.stereotype.Component;
5+
6+
@Component
7+
public class OrderProducer {
8+
9+
}

src/main/java/net/harunote/hellomessagequeue/step7/RabbitMQConfig.java renamed to src/main/java/net/harunote/hellomessagequeue/step8/RabbitMQConfig.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package net.harunote.hellomessagequeue.step7;
1+
package net.harunote.hellomessagequeue.step8;
22

33
import org.springframework.amqp.core.*;
44
import org.springframework.context.annotation.Bean;
@@ -9,7 +9,7 @@ public class RabbitMQConfig {
99
public static final String ORDER_COMPLETED_QUEUE = "orderCompletedQueue";
1010

1111
public static final String DLQ = "deadLetterQueue";
12-
public static final String ORDER_EXCHANGE = "topicExchange";
12+
public static final String ORDER_EXCHANGE = "orderExchange";
1313
public static final String DLX = "deadLetterExchange";
1414

1515
@Bean

0 commit comments

Comments
 (0)