X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;ds=sidebyside;f=legacy%2Fruntime%2Forg.argeo.slc.support.activemq%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fjms%2FJmsExecutionHandler.java;fp=legacy%2Fruntime%2Forg.argeo.slc.support.activemq%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fjms%2FJmsExecutionHandler.java;h=0000000000000000000000000000000000000000;hb=0e75bed97c103d94640dd4c8e36cdce24b11390a;hp=9239c7a33fbe578d6f2c41ab1b31504874af4b12;hpb=57aa5d64fb38af2d98076eeaaa11573b3147cc26;p=gpl%2Fargeo-slc.git diff --git a/legacy/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsExecutionHandler.java b/legacy/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsExecutionHandler.java deleted file mode 100644 index 9239c7a33..000000000 --- a/legacy/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsExecutionHandler.java +++ /dev/null @@ -1,47 +0,0 @@ -/* - * Copyright (C) 2007-2012 Mathieu Baudier - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.argeo.slc.jms; - -import javax.jms.JMSException; -import javax.jms.Message; -import javax.jms.MessageListener; - -import org.argeo.slc.SlcException; -import org.argeo.slc.msg.MsgHandler; -import org.springframework.jms.support.converter.MessageConverter; - -public class JmsExecutionHandler implements MessageListener { - - private MessageConverter messageConverter; - private MsgHandler serviceMsgHandler; - - public void onMessage(Message message) { - try { - serviceMsgHandler.handleMsg(messageConverter.fromMessage(message)); - } catch (JMSException e) { - throw new SlcException("Could not interpret message " + message, e); - } - } - - public void setMessageConverter(MessageConverter messageConverter) { - this.messageConverter = messageConverter; - } - - public void setServiceMsgHandler(MsgHandler serviceMsgHandler) { - this.serviceMsgHandler = serviceMsgHandler; - } - -}