1 18 package org.apache.activemq; 19 20 import org.apache.activemq.command.ActiveMQMessage; 21 22 import javax.jms.Message ; 23 import javax.jms.Session ; 24 import javax.jms.MessageProducer ; 25 import javax.jms.JMSException ; 26 import javax.jms.MessageConsumer ; 27 28 34 public interface MessageTransformer { 35 36 39 public Message producerTransform(Session session, MessageProducer producer, Message message) throws JMSException ; 40 41 44 public Message consumerTransform(Session session, MessageConsumer consumer, Message message)throws JMSException ; 45 } 46 | Popular Tags |