public void subscribe()

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

• 20 lines of code
• 3 McCabe index (conditional complexity)

    public void subscribe(EventingClientBean bean, String subscriptionID) throws Exception {

        Options options = serviceClient.getOptions();
        if (options == null) {
            options = new Options();
            serviceClient.setOptions(options);
        }

        String SOAPVersion = options.getSoapVersionURI();
        if (SOAPVersion == null)
            SOAPVersion = SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI;

        SOAPEnvelope envelope = createSubscriptionEnvelope(bean, SOAPVersion);

        String oldAction = options.getAction();
        String action = EventingConstants.Actions.Subscribe;
        options.setAction(action);
        OMElement subscriptionResponse =
                serviceClient.sendReceive(envelope.getBody().getFirstElement());
        SubscriptionResponseData subscriptionResponseData =
                getSubscriptionResponseData(subscriptionResponse);

        subscriptionDataMap.put(subscriptionID, subscriptionResponseData);

        options.setAction(oldAction);
    }