@Bean
public MessageConsumer<MemberSignUpEvent> inviteCodeConsumer(@Qualifier("redisMemberQueue") RedisMessageQueue redisMemberQueue, @Qualifier("inviteCode") MessageListener<MemberSignUpEvent> inviteCode){
MessageConsumer<MemberSignUpEvent> messageConsumer = new com.github.davidmarquis.redisq.consumer.MessageConsumer<>();
messageConsumer.setQueue(redisMemberQueue);
messageConsumer.setConsumerId("SignUpEvent.InviteCode");
messageConsumer.setMessageListener(inviteCode);
return messageConsumer;
}
@Bean("inviteCode")
public MessageListener<MemberSignUpEvent> inviteCodeListener(){
return new MemberSignUpInviteCodeListener();
}
@Bean
public MessageConsumer<MemberSignUpEvent> registerNoticeConsumer(@Qualifier("redisMemberQueue") RedisMessageQueue redisMemberQueue, @Qualifier("registerNotice") MessageListener<MemberSignUpEvent> registerNotice){
MessageConsumer<MemberSignUpEvent> messageConsumer = new com.github.davidmarquis.redisq.consumer.MessageConsumer<>();
messageConsumer.setQueue(redisMemberQueue);
messageConsumer.setConsumerId("SignUpEvent.Notice");
messageConsumer.setMessageListener(registerNotice);
return messageConsumer;
}
@Bean("registerNotice")
public MessageListener<MemberSignUpEvent> registerNoticeListener(){
return new MemberSignUpNoticeListener();
}
@Bean
public MessageConsumer<MemberSignInEvent> loginNoticeConsumer(@Qualifier("redisMemberQueue") RedisMessageQueue redisMemberQueue, @Qualifier("loginNotice") MessageListener<MemberSignInEvent> loginNotice){
MessageConsumer<MemberSignInEvent> messageConsumer = new com.github.davidmarquis.redisq.consumer.MessageConsumer<>();
messageConsumer.setQueue(redisMemberQueue);
messageConsumer.setConsumerId("SignInEvent.Notice");
messageConsumer.setMessageListener(loginNotice);
return messageConsumer;
}
@Bean("loginNotice")
public MessageListener<MemberSignInEvent> loginNoticeListener(){
return new MemberSignInNoticeListener();
}