fix: queue name
This commit is contained in:
parent
c6605cb322
commit
90dab24ae8
@ -13,7 +13,7 @@ import org.springframework.stereotype.Service;
|
||||
public class UpdateMangaFollowChapterListConsumer {
|
||||
private final UserMangaFollowService userMangaFollowService;
|
||||
|
||||
@RabbitListener(queues = "${rabbit-mq.queues.manga-follow-update-chapter}")
|
||||
@RabbitListener(queues = "${queues.manga-follow-update-chapter}")
|
||||
public void receiveMangaFollowUpdateChapterCommand(UpdateMangaFollowChapterListCommand command) {
|
||||
log.info("Received update followed manga chapter list command: {}", command);
|
||||
userMangaFollowService.checkForMangaUpdates(command.mangaProviderId());
|
||||
|
||||
@ -13,7 +13,7 @@ import org.springframework.stereotype.Service;
|
||||
public class UpdateMangaFollowChapterListProducer {
|
||||
private final RabbitTemplate rabbitTemplate;
|
||||
|
||||
@Value("${rabbit-mq.queues.manga-follow-update-chapter}")
|
||||
@Value("${queues.manga-follow-update-chapter}")
|
||||
private String mangaFollowUpdateChapterQueue;
|
||||
|
||||
public void sendUpdateMangaFollowChapterListCommand(UpdateMangaFollowChapterListCommand command) {
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user