private SubscriptionResponseData getSubscriptionResponseData()

in modules/core/src/main/java/org/apache/savan/eventing/client/EventingClient.java [191:221]

26 lines of code
3 McCabe index (conditional complexity)


    private SubscriptionResponseData getSubscriptionResponseData(OMElement responseMessagePayload)
            throws Exception {
        SubscriptionResponseData data = new SubscriptionResponseData();

        OMElement subscriberManagerElement = responseMessagePayload.getFirstChildWithName(new QName(
                EventingConstants.EVENTING_NAMESPACE,
                EventingConstants.ElementNames.SubscriptionManager));
        EndpointReference managerEPR = EndpointReferenceHelper.fromOM(subscriberManagerElement);
        data.setSubscriptionManager(managerEPR);

        OMElement expiresElement = responseMessagePayload.getFirstChildWithName(new QName(
                EventingConstants.EVENTING_NAMESPACE, EventingConstants.ElementNames.Expires));
        if (expiresElement != null) {
            String text = expiresElement.getText().trim();

            ExpirationBean expirationBean = new ExpirationBean();
            if (CommonUtil.isDuration(text)) {
                expirationBean.setDuration(true);
                Duration duration = ConverterUtil.convertToDuration(text);
                expirationBean.setDurationValue(duration);
            } else {
                expirationBean.setDuration(false);
                Date date = ConverterUtil.convertToDateTime(text).getTime();
                expirationBean.setDateValue(date);
            }

            data.setExpiration(expirationBean);
        }

        return data;
    }