|
@@ -1,5 +1,6 @@
|
|
|
package com.persagy.dmp.rwd.digital.config;
|
|
|
|
|
|
+import com.persagy.dmp.basic.constant.DigitalMessageConstant;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.amqp.core.Binding;
|
|
|
import org.springframework.amqp.core.BindingBuilder;
|
|
@@ -38,4 +39,9 @@ public class DigitalRabbitConfig {
|
|
|
public Binding projectBinding() {
|
|
|
return BindingBuilder.bind(projectQueue()).to(projectExchange()).with(PROJECT_ROUTING_KEY);
|
|
|
}
|
|
|
+
|
|
|
+ @Bean
|
|
|
+ public TopicExchange bdtpDigitalExchange() {
|
|
|
+ return new TopicExchange(DigitalMessageConstant.MESSAGE_EXCHANGE);
|
|
|
+ }
|
|
|
}
|