public SavanMessageContext initializeMessage()

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;
    }