Title: [1027] trunk/components/base/src/main/java/org/servicemix/components/jms/JmsServiceComponent.java: removed dependency on ActiveMQ 3.x
- Revision
- 1027
- Author
- rajdavies
- Date
- 2005-12-07 01:34:22 -0500 (Wed, 07 Dec 2005)
Log Message
removed dependency on ActiveMQ 3.x
Modified Paths
Diff
Modified: trunk/components/base/src/main/java/org/servicemix/components/jms/JmsServiceComponent.java (1026 => 1027)
--- trunk/components/base/src/main/java/org/servicemix/components/jms/JmsServiceComponent.java 2005-12-06 20:14:27 UTC (rev 1026)
+++ trunk/components/base/src/main/java/org/servicemix/components/jms/JmsServiceComponent.java 2005-12-07 06:34:22 UTC (rev 1027)
@@ -29,7 +29,6 @@
import javax.jms.MessageListener;
import javax.jms.Session;
import javax.xml.transform.TransformerException;
-import org.activemq.util.JMSExceptionHelper;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.servicemix.components.util.ComponentSupport;
@@ -55,6 +54,10 @@
private String selector;
private MessageConsumer consumer;
+ /**
+ * called by Spring framework after initialization
+ * @throws Exception
+ */
public void afterPropertiesSet() throws Exception {
if (template == null) {
throw new IllegalArgumentException("Must have a template set");
@@ -73,6 +76,10 @@
consumer.setMessageListener(this);
}
+ /**
+ * called by spring framework on disposal
+ * @throws Exception
+ */
public void destroy() throws Exception {
if (consumer != null) {
consumer.close();
@@ -145,6 +152,10 @@
this.selector = selector;
}
+ /**
+ * MessageListener implementation
+ * @param jmsMessage
+ */
public void onMessage(final Message jmsMessage) {
try {
final InOut messageExchange = getDeliveryChannel().createExchangeFactory().createInOutExchange();
@@ -167,7 +178,9 @@
return message;
}
catch (TransformerException e) {
- throw JMSExceptionHelper.newJMSException("Failed to create JMS Message: " + e, e);
+ JMSException jmsEx = new JMSException("Failed to create a JMS Message: " + e);
+ jmsEx.setLinkedException(e);
+ throw jmsEx;
}
}
});
