从配置属性动态设置 @JmsListener 目的地
dynamically set @JmsListener destination from configuration properties
我希望能够从 application.properties
设置 @JMSlistener 目的地
我的代码是这样的
@Service
public class ListenerService {
private Logger log = Logger.getLogger(ListenerService.class);
@Autowired
QueueProperties queueProperties;
public ListenerService(QueueProperties queueProperties) {
this.queueProperties = queueProperties;
}
@JmsListener(destination = queueProperties.getQueueName() )
public void listenQueue(String requestJSON) throws JMSException {
log.info("Received " + requestJSON);
}
}
但是在构建时我得到
Error:(25, 60) java: element value must be a constant expression
您不能引用当前 bean 中的字段,但可以使用 SpEL 表达式在应用程序上下文中引用另一个 bean...
@SpringBootApplication
public class So49368515Application {
public static void main(String[] args) {
SpringApplication.run(So49368515Application.class, args);
}
@Bean
public ApplicationRunner runner(JmsTemplate template, Foo foo) {
return args -> template.convertAndSend(foo.getDestination(), "test");
}
@JmsListener(destination = "#{@foo.destination}")
public void listen(Message in) {
System.out.println(in);
}
@Bean
public Foo foo() {
return new Foo();
}
public class Foo {
public String getDestination() {
return "foo";
}
}
}
您还可以使用 属性 占位符 ${...}
.
使用 属性 占位符更容易。
@JmsListener(destination = "${mq.queue}")
public void onMessage(Message data) {
}
我希望能够从 application.properties
设置 @JMSlistener 目的地我的代码是这样的
@Service
public class ListenerService {
private Logger log = Logger.getLogger(ListenerService.class);
@Autowired
QueueProperties queueProperties;
public ListenerService(QueueProperties queueProperties) {
this.queueProperties = queueProperties;
}
@JmsListener(destination = queueProperties.getQueueName() )
public void listenQueue(String requestJSON) throws JMSException {
log.info("Received " + requestJSON);
}
}
但是在构建时我得到
Error:(25, 60) java: element value must be a constant expression
您不能引用当前 bean 中的字段,但可以使用 SpEL 表达式在应用程序上下文中引用另一个 bean...
@SpringBootApplication
public class So49368515Application {
public static void main(String[] args) {
SpringApplication.run(So49368515Application.class, args);
}
@Bean
public ApplicationRunner runner(JmsTemplate template, Foo foo) {
return args -> template.convertAndSend(foo.getDestination(), "test");
}
@JmsListener(destination = "#{@foo.destination}")
public void listen(Message in) {
System.out.println(in);
}
@Bean
public Foo foo() {
return new Foo();
}
public class Foo {
public String getDestination() {
return "foo";
}
}
}
您还可以使用 属性 占位符 ${...}
.
使用 属性 占位符更容易。
@JmsListener(destination = "${mq.queue}")
public void onMessage(Message data) {
}