1 17 package org.apache.servicemix.components.util; 18 19 import org.apache.servicemix.MessageExchangeListener; 20 21 import javax.jbi.component.ComponentLifeCycle; 22 import javax.jbi.messaging.MessageExchange; 23 import javax.jbi.messaging.MessagingException; 24 import javax.xml.namespace.QName ; 25 26 32 public class ComponentAdaptorMEListener extends ComponentAdaptor implements MessageExchangeListener { 33 34 private MessageExchangeListener listener; 35 36 public ComponentAdaptorMEListener(ComponentLifeCycle lifeCycle, MessageExchangeListener listener) { 37 super(lifeCycle); 38 this.listener = listener; 39 } 40 41 public ComponentAdaptorMEListener(ComponentLifeCycle lifeCycle, QName service, String endpoint, MessageExchangeListener listener) { 42 super(lifeCycle, service, endpoint); 43 this.listener = listener; 44 } 45 46 public void onMessageExchange(MessageExchange exchange) throws MessagingException { 47 listener.onMessageExchange(exchange); 48 } 49 } 50 | Popular Tags |