bindings/servicemix-http/src/main/java/org/apache/servicemix/http/endpoints/HttpConsumerEndpoint.java [466:480]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private Object getOrCreateMutex(Continuation continuation) {
        Object result = null;

        // let's try to find the object that corresponds to the exchange first
        if (continuation != null) {
            result = continuation.getAttribute(MUTEX);
        }

        // no luck finding an existing object, let's create a new one
        if (result == null) {
            result = new Object();
        }

        return result;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



bindings/servicemix-http/src/main/java/org/apache/servicemix/http/processors/ConsumerProcessor.java [245:259]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private Object getOrCreateMutex(Continuation continuation) {
        Object result = null;

        // let's try to find the object that corresponds to the exchange first
        if (continuation != null) {
            result = continuation.getAttribute(MUTEX);
        }

        // no luck finding an existing object, let's create a new one
        if (result == null) {
            result = new Object();
        }

        return result;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -