Java 类org.apache.camel.impl.SynchronousDelegateProducer 实例源码

@Override
public Producer createProducer() throws Exception {
    JettyHttpProducer answer = new JettyHttpProducer(this);
    if (client != null) {
        // use shared client, and ensure its started so we can use it
        client.start();
        answer.setSharedClient(client);
        answer.setBinding(getJettyBinding(client));
    } else {
        HttpClient httpClient = createJettyHttpClient();
        answer.setClient(httpClient);
        answer.setBinding(getJettyBinding(httpClient));
    }

    if (isSynchronous()) {
        return new SynchronousDelegateProducer(answer);
    } else {
        return answer;
    }
}

@Override
public Producer createProducer() throws Exception {
    KafkaProducer producer = createProducer(this);
    if (isSynchronous()) {
        return new SynchronousDelegateProducer(producer);
    } else {
        return producer;
    }
}

public Producer createProducer() throws Exception {
    Producer answer = new MyAsyncProducer(this);
    if (isSynchronous()) {
        // force it to be synchronously
        return new SynchronousDelegateProducer(answer);
    } else {
        return answer;
    }
}

@Override
public Producer createProducer() throws Exception {
    Producer answer = new NettyHttpProducer(this, getConfiguration());
    if (isSynchronous()) {
        return new SynchronousDelegateProducer(answer);
    } else {
        return answer;
    }
}

public Producer createProducer() throws Exception {
    Producer answer = new CxfProducer(this);
    if (isSynchronous()) {
        return new SynchronousDelegateProducer(answer);
    } else {
        return answer;
    }
}

public Producer createProducer() throws Exception {
    Producer answer = new JmsProducer(this);
    if (isSynchronous()) {
        return new SynchronousDelegateProducer(answer);
    } else {
        return answer;
    }
}

public Producer createProducer() throws Exception {
    Producer answer = new MyAsyncProducer(this);
    if (isSynchronous()) {
        // force it to be synchronously
        return new SynchronousDelegateProducer(answer);
    } else {
        return answer;
    }
}

public Producer createProducer() throws Exception {
    Producer answer = new NettyProducer(this, configuration);
    if (isSynchronous()) {
        return new SynchronousDelegateProducer(answer);
    } else {
        return answer;
    }
}

@Override
public Producer createProducer() throws Exception {
    KafkaProducer producer = createProducer(this);
    if (isSynchronous()) {
        return new SynchronousDelegateProducer(producer);
    } else {
        return producer;
    }
}

@Override
public Producer createProducer() throws Exception {
    Producer answer = new NettyHttpProducer(this, getConfiguration());
    if (isSynchronous()) {
        return new SynchronousDelegateProducer(answer);
    } else {
        return answer;
    }
}

public Producer createProducer() throws Exception {
    Producer answer = new XmlRpcProducer(this);
    if (isSynchronous()) {
        return new SynchronousDelegateProducer(answer);
    } else {
        return answer;
    }
}

public Producer createProducer() throws Exception {
    Producer answer = new MyAsyncProducer(this);
    if (isSynchronous()) {
        // force it to be synchronously
        return new SynchronousDelegateProducer(answer);
    } else {
        return answer;
    }
}

public Producer createProducer() throws Exception {
    // producer requires an operation, topicName must be the invalid operation name
    if (operationName == null) {
        throw new IllegalArgumentException(String.format("Invalid Operation %s", topicName));
    }

    SalesforceProducer producer = new SalesforceProducer(this);
    if (isSynchronous()) {
        return new SynchronousDelegateProducer(producer);
    } else {
        return producer;
    }
}

public Producer createProducer() throws Exception {
    Producer answer = new NettyProducer(this, configuration);
    if (isSynchronous()) {
        return new SynchronousDelegateProducer(answer);
    } else {
        return answer;
    }
}