From e6c25c183d4581a5897eae8ebd4f8ac20cf0b886 Mon Sep 17 00:00:00 2001 From: William Welling Date: Wed, 1 May 2019 07:34:17 -0500 Subject: [PATCH] opt-in weaver messaging --- .../tamu/iiif/service/MessageListenerService.java | 4 ++-- src/main/resources/application.yaml | 14 +++++++++----- src/test/resources/application.yaml | 6 ------ 3 files changed, 11 insertions(+), 13 deletions(-) diff --git a/src/main/java/edu/tamu/iiif/service/MessageListenerService.java b/src/main/java/edu/tamu/iiif/service/MessageListenerService.java index 82d77e5..0c27215 100644 --- a/src/main/java/edu/tamu/iiif/service/MessageListenerService.java +++ b/src/main/java/edu/tamu/iiif/service/MessageListenerService.java @@ -22,7 +22,7 @@ import edu.tamu.weaver.messaging.model.MessageAction; @Service -@Profile("!test") +@Profile("weaver-messaging") @Import(MessagingConfig.class) public class MessageListenerService { @@ -34,7 +34,7 @@ public class MessageListenerService { @Autowired private List manifestServices; - @WeaverMessageListener(destination = "${iiif.messaging.channel:cap}", containerFactory = "topicContainerFactory") + @WeaverMessageListener(destination = "${messaging.channels.cap:cap}", containerFactory = "topicContainerFactory") private void update(Map message) { MessageAction action = MessageAction.valueOf(message.get("action")); switch (action) { diff --git a/src/main/resources/application.yaml b/src/main/resources/application.yaml index 31d5eea..00026a6 100644 --- a/src/main/resources/application.yaml +++ b/src/main/resources/application.yaml @@ -9,11 +9,13 @@ logging: org.springframework: INFO path: /var/logs/iiif +# to enable messaging, include profile weaver-messaging and update activemq broker-url, username and password + spring: activemq: - broker-url: tcp://srv-message-broker-dev.library.tamu.edu:61616 - user: admin - password: admin + broker-url: tcp://localhost:61616 + user: username + password: password redis: host: localhost port: 6379 @@ -21,13 +23,15 @@ spring: active: production include: dspace, fedora +messaging: + channels: + cap: cap + iiif: admins: - username: admin password: abc123 - messaging: - channel: cap service: url: http://localhost:${server.port}${server.contextPath} connection: diff --git a/src/test/resources/application.yaml b/src/test/resources/application.yaml index 5e028bb..91f8797 100644 --- a/src/test/resources/application.yaml +++ b/src/test/resources/application.yaml @@ -10,10 +10,6 @@ logging: path: /var/logs/iiif spring: - activemq: - broker-url: tcp://srv-message-broker-dev.library.tamu.edu:61616 - user: admin - password: admin redis: host: localhost port: 6380 @@ -26,8 +22,6 @@ iiif: - username: admin password: abc123 - messaging: - channel: cap service: url: http://localhost:${server.port}${server.contextPath} connection: