Post-processor for WebServiceMessageDrivenBean

Added MessagePostProcessor support for WebServiceMessageDrivenBean.

Issue: SWS-813
This commit is contained in:
Arjen Poutsma
2013-04-04 13:30:03 +02:00
parent f0fc4c8919
commit ddd3eaaa4b

View File

@@ -27,6 +27,7 @@ import javax.naming.NamingException;
import org.springframework.ejb.support.AbstractJmsMessageDrivenBean;
import org.springframework.jms.connection.ConnectionFactoryUtils;
import org.springframework.jms.core.MessagePostProcessor;
import org.springframework.jms.support.JmsUtils;
import org.springframework.jndi.JndiLookupFailureException;
import org.springframework.ws.WebServiceMessageFactory;
@@ -97,6 +98,7 @@ public class WebServiceMessageDrivenBean extends AbstractJmsMessageDrivenBean {
delegate = new JmsMessageReceiver();
delegate.setMessageFactory(createMessageFactory());
delegate.setMessageReceiver(createMessageReceiver());
delegate.setPostProcessor(createPostProcessor());
}
catch (NamingException ex) {
throw new JndiLookupFailureException("Could not create connection", ex);
@@ -155,4 +157,14 @@ public class WebServiceMessageDrivenBean extends AbstractJmsMessageDrivenBean {
return connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
}
/**
* Creates a JMS {@link MessagePostProcessor} to process JMS messages. Default
* implementation returns {@code null}, meaning that no post processor is used.
*
* @return a message post processor
*/
protected MessagePostProcessor createPostProcessor() {
return null;
}
}