Author: dkulp
Date: Wed Aug 5 20:06:58 2009
New Revision: 801394
URL: http://svn.apache.org/viewvc?rev=801394&view=rev
Log:
Fix compile failure with older spring
Modified:
cxf/branches/2.1.x-fixes/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JCATransactionalMessageListenerContainer.java
Modified:
cxf/branches/2.1.x-fixes/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JCATransactionalMessageListenerContainer.java
URL:
http://svn.apache.org/viewvc/cxf/branches/2.1.x-fixes/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JCATransactionalMessageListenerContainer.java?rev=801394&r1=801393&r2=801394&view=diff
==============================================================================
---
cxf/branches/2.1.x-fixes/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JCATransactionalMessageListenerContainer.java
(original)
+++
cxf/branches/2.1.x-fixes/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JCATransactionalMessageListenerContainer.java
Wed Aug 5 20:06:58 2009
@@ -47,7 +47,8 @@
this.setCacheLevel(CACHE_CONNECTION);
}
- protected boolean receiveAndExecute(Object invoker, Session session,
MessageConsumer consumer)
+ @Override
+ protected boolean receiveAndExecute(Session session, MessageConsumer
consumer)
throws JMSException {
boolean messageReceived = false;
MessageEndpoint ep = null;
@@ -62,8 +63,8 @@
mc = s.createConsumer(getDestination());
ep = factory.createEndpoint(xar);
ENDPOINT_LOCAL.set(ep);
- ep.beforeDelivery(method);
- messageReceived = doReceiveAndExecute(invoker, s, mc, null);
+ ep.beforeDelivery(method);
+ messageReceived = doReceiveAndExecute(s, mc, null);
ep.afterDelivery();
} catch (Exception ex) {
throw new JMSException(ex.getMessage());