in modules/core/src/main/java/org/apache/savan/messagereceiver/MessageReceiverDelegator.java [87:110]
private void setSubscriberStore(SavanMessageContext smc) throws SavanException {
MessageContext msgContext = smc.getMessageContext();
AxisService axisService = msgContext.getAxisService();
Parameter parameter = axisService.getParameter(SavanConstants.SUBSCRIBER_STORE_KEY);
String subscriberStoreKey = SavanConstants.DEFAULT_SUBSCRIBER_STORE_KEY;
if (parameter != null)
subscriberStoreKey = (String)parameter.getValue();
ConfigurationManager configurationManager = (ConfigurationManager)smc
.getConfigurationContext().getProperty(SavanConstants.CONFIGURATION_MANAGER);
SubscriberStore store = configurationManager.getSubscriberStoreInstance(subscriberStoreKey);
parameter = new Parameter();
parameter.setName(SavanConstants.SUBSCRIBER_STORE);
parameter.setValue(store);
try {
axisService.addParameter(parameter);
} catch (AxisFault e) {
throw new SavanException(e);
}
}