1 package org.jumpmind.symmetric.ext;
2
3 import org.apache.commons.logging.Log;
4 import org.apache.commons.logging.LogFactory;
5 import org.jumpmind.symmetric.load.IDataLoaderContext;
6 import org.springframework.jms.core.JmsTemplate;
7
8 public class SimpleJmsPublisher implements IPublisher {
9
10 static final Log logger = LogFactory.getLog(SimpleJmsPublisher.class);
11
12 JmsTemplate jmsTemplate;
13
14 public boolean enabled = true;
15
16 public void publish(IDataLoaderContext ctx, String text) {
17 if (logger.isDebugEnabled()) {
18 logger.debug(text);
19 }
20
21 if (enabled) {
22 jmsTemplate.convertAndSend(text);
23 } else {
24 logger.warn("Message was not published because the publisher is not enabled.");
25 }
26 }
27
28 public void setJmsTemplate(JmsTemplate jmsTemplate) {
29 this.jmsTemplate = jmsTemplate;
30 }
31
32 public boolean isEnabled() {
33 return enabled;
34 }
35
36 public void setEnabled(boolean enable) {
37 this.enabled = enable;
38 }
39
40 }