1 22 package org.objectweb.petals.component.common.listener; 23 24 import java.util.logging.Level ; 25 import java.util.logging.Logger ; 26 27 import javax.jbi.JBIException; 28 29 import org.objectweb.petals.component.common.util.MessageExchangeWrapper; 30 31 37 public class MessageExchangeWorker extends Thread { 38 39 private MessageExchangeWrapper exchange = null; 40 41 private MessageExchangeProcessor processor = null; 42 43 private Logger logger = null; 44 45 public MessageExchangeWorker(MessageExchangeWrapper exchange, 46 MessageExchangeProcessor processor, Logger logger) { 47 super("MessageExchangeWorker"); 48 this.exchange = exchange; 49 this.processor = processor; 50 } 51 52 55 public void run() { 56 if (processor != null) { 57 try { 58 processor.process(exchange); 59 } catch (JBIException e) { 60 logger.log(Level.SEVERE, e.getMessage(), e); 61 } 62 } 63 } 64 65 } 66 | Popular Tags |