in modules/core/src/main/java/org/apache/savan/eventing/EventingUtilFactory.java [31:59]
public SavanMessageContext initializeMessage(SavanMessageContext smc) {
MessageContext messageContext = smc.getMessageContext();
//setting the message type.
String action = messageContext.getOptions().getAction();
if (EventingConstants.Actions.Subscribe.equals(action))
smc.setMessageType(SavanConstants.MessageTypes.SUBSCRIPTION_MESSAGE);
else if (EventingConstants.Actions.Renew.equals(action))
smc.setMessageType(SavanConstants.MessageTypes.RENEW_MESSAGE);
else if (EventingConstants.Actions.Unsubscribe.equals(action))
smc.setMessageType(SavanConstants.MessageTypes.UNSUBSCRIPTION_MESSAGE);
else if (EventingConstants.Actions.GetStatus.equals(action))
smc.setMessageType(SavanConstants.MessageTypes.GET_STATUS_MESSAGE);
else if (EventingConstants.Actions.SubscribeResponse.equals(action))
smc.setMessageType(SavanConstants.MessageTypes.SUBSCRIPTION_RESPONSE_MESSAGE);
else if (EventingConstants.Actions.RenewResponse.equals(action))
smc.setMessageType(SavanConstants.MessageTypes.RENEW_RESPONSE_MESSAGE);
else if (EventingConstants.Actions.UnsubscribeResponse.equals(action))
smc.setMessageType(SavanConstants.MessageTypes.UNSUBSCRIPTION_RESPONSE_MESSAGE);
else if (EventingConstants.Actions.GetStatusResponse.equals(action))
smc.setMessageType(SavanConstants.MessageTypes.GET_STATUS_RESPONSE_MESSAGE);
else if (EventingConstants.Actions.Publish.equals(action))
smc.setMessageType(SavanConstants.MessageTypes.PUBLISH);
else
smc.setMessageType(SavanConstants.MessageTypes.UNKNOWN);
return smc;
}