1 10 11 package org.mule.providers.oracle.jms; 12 13 import org.apache.commons.logging.Log; 14 import org.apache.commons.logging.LogFactory; 15 import org.mule.providers.jms.JmsConnector; 16 import org.mule.providers.jms.TransactedJmsMessageReceiver; 17 import org.mule.umo.UMOComponent; 18 import org.mule.umo.endpoint.UMOEndpoint; 19 import org.mule.umo.lifecycle.InitialisationException; 20 import org.mule.umo.provider.UMOConnector; 21 22 25 public class OracleJmsMessageReceiver extends TransactedJmsMessageReceiver 26 { 27 28 public OracleJmsMessageReceiver(UMOConnector connector, UMOComponent component, UMOEndpoint endpoint) 29 throws InitialisationException 30 { 31 super(connector, component, endpoint); 32 } 33 34 39 protected void createConsumer() throws Exception 40 { 41 ((OracleJmsSupport)((JmsConnector)getConnector()).getJmsSupport()).setEndpointProperties(endpoint.getProperties()); 42 super.createConsumer(); 43 } 44 45 public void poll() throws Exception 46 { 47 log.trace("Polling..."); 48 super.poll(); 49 } 50 51 private static Log log = LogFactory.getLog(OracleJmsMessageReceiver.class); 52 } 53 | Popular Tags |