mindol1004/Oneul
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

meessage -> message

Browse Source
This commit is contained in:
jinho jeong
2022-07-15 16:50:52 +09:00
parent 4f63d3afff
commit b72da79ab1
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/com/example/oneul/infra/kafka/service/MessageQueueFactory.java
View File

@@ -14,20 +14,20 @@ import com.example.oneul.infra.kafka.Type;
@Component @Component
public class MessageQueueFactory { public class MessageQueueFactory {
private final Map<Type, Function<Post, PostMessage>> meessageQueueServiceMap = new HashMap<>(); private final Map<Type, Function<Post, PostMessage>> messageQueueServiceMap = new HashMap<>();
public MessageQueueFactory(List<MessageQueueService> meessageQueueServices) { public MessageQueueFactory(List<MessageQueueService> messageQueueServices) {
if(CollectionUtils.isEmpty(meessageQueueServices)){ if(CollectionUtils.isEmpty(messageQueueServices)){
throw new IllegalArgumentException("메시지 큐 구현체가 존재하지 않습니다."); throw new IllegalArgumentException("메시지 큐 구현체가 존재하지 않습니다.");
} }
for(MessageQueueService service : meessageQueueServices){ for(MessageQueueService service : messageQueueServices){
Function<Post, PostMessage> transaction = service::transaction; Function<Post, PostMessage> transaction = service::transaction;
this.meessageQueueServiceMap.put(service.getMessageType(), transaction); this.messageQueueServiceMap.put(service.getMessageType(), transaction);
} }
} }
public Function<Post, PostMessage> getTye(Type type){ public Function<Post, PostMessage> getTye(Type type){
return meessageQueueServiceMap.get(type); return messageQueueServiceMap.get(type);
} }
} }