in modules/core/src/main/java/org/apache/savan/atom/AtomMessageReceiverDelegator.java [271:287]
public void doProtocolSpecificProcessing(SavanMessageContext inSavanMessage,
MessageContext outMessage) throws SavanException {
int msgtype = ((Integer)inSavanMessage.getProperty(SavanConstants.MESSAGE_TYPE)).intValue();
switch (msgtype) {
case SavanConstants.MessageTypes.SUBSCRIPTION_MESSAGE:
handleSubscriptionRequest(inSavanMessage, outMessage);
break;
case SavanConstants.MessageTypes.RENEW_MESSAGE:
handleRenewRequest(inSavanMessage, outMessage);
break;
case SavanConstants.MessageTypes.UNSUBSCRIPTION_MESSAGE:
handleEndSubscriptionRequest(inSavanMessage, outMessage);
break;
default:
throw new SavanException("Unknow Message type [" + msgtype + "]");
}
}