1 10 11 package org.mule.providers.oracle.jms; 12 13 import org.mule.providers.jms.JmsConnector; 14 import org.mule.providers.jms.JmsMessageDispatcher; 15 import org.mule.umo.UMOMessage; 16 import org.mule.umo.endpoint.UMOImmutableEndpoint; 17 18 21 public class OracleJmsMessageDispatcher extends JmsMessageDispatcher 22 { 23 24 public OracleJmsMessageDispatcher(UMOImmutableEndpoint endpoint) 25 { 26 super(endpoint); 27 } 28 29 43 protected UMOMessage doReceive(UMOImmutableEndpoint endpoint, long timeout) throws Exception 44 { 45 ((OracleJmsSupport)((JmsConnector)getConnector()).getJmsSupport()).setEndpointProperties(endpoint.getEndpointURI() 46 .getParams()); 47 return super.doReceive(endpoint, timeout); 48 } 49 } 50 | Popular Tags |