File tree Expand file tree Collapse file tree 1 file changed +12
-0
lines changed
support/src/main/java/org/springframework/ws/transport/jms Expand file tree Collapse file tree 1 file changed +12
-0
lines changed Original file line number Diff line number Diff line change 27
27
28
28
import org .springframework .ejb .support .AbstractJmsMessageDrivenBean ;
29
29
import org .springframework .jms .connection .ConnectionFactoryUtils ;
30
+ import org .springframework .jms .core .MessagePostProcessor ;
30
31
import org .springframework .jms .support .JmsUtils ;
31
32
import org .springframework .jndi .JndiLookupFailureException ;
32
33
import org .springframework .ws .WebServiceMessageFactory ;
@@ -97,6 +98,7 @@ protected void onEjbCreate() {
97
98
delegate = new JmsMessageReceiver ();
98
99
delegate .setMessageFactory (createMessageFactory ());
99
100
delegate .setMessageReceiver (createMessageReceiver ());
101
+ delegate .setPostProcessor (createPostProcessor ());
100
102
}
101
103
catch (NamingException ex ) {
102
104
throw new JndiLookupFailureException ("Could not create connection" , ex );
@@ -155,4 +157,14 @@ protected Session createSession(Connection connection) throws JMSException {
155
157
return connection .createSession (false , Session .AUTO_ACKNOWLEDGE );
156
158
}
157
159
160
+ /**
161
+ * Creates a JMS {@link MessagePostProcessor} to process JMS messages. Default
162
+ * implementation returns {@code null}, meaning that no post processor is used.
163
+ *
164
+ * @return a message post processor
165
+ */
166
+ protected MessagePostProcessor createPostProcessor () {
167
+ return null ;
168
+ }
169
+
158
170
}
You can’t perform that action at this time.
0 commit comments