Java 类org.apache.camel.util.AsyncProcessorHelper 实例源码

项目:Camel    文件:RedeliveryErrorHandler.java   
public void process(Exchange exchange) throws Exception {
    if (output == null) {
        // no output then just return
        return;
    }
    AsyncProcessorHelper.process(this, exchange);
}
项目:vertx-camel-bridge    文件:CamelToVertxProcessor.java   
@Override
public void process(Exchange exchange) throws Exception {
  AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:SetHeaderProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:RemovePropertiesProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:BatchProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:ValidatingProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:ScriptProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:AggregateProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:ExchangePatternProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:ConvertBodyProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:TryProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:EvaluateExpressionProcessor.java   
@Override
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:RecipientList.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:ChoiceProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:StopProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:SetBodyProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:ThreadsProcessor.java   
public void process(final Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:RemoveHeadersProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:TransformProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:IdempotentConsumer.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:DelegateAsyncProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:RestBindingProcessor.java   
@Override
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:PollEnricher.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:LoadBalancerSupport.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:MarshalProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:ThroughputLogger.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:CamelLogger.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:RollbackProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:WireTapProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:UnmarshalProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:RemoveHeaderProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:RoutingSlip.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:StreamResequencer.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:Enricher.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:SendProcessor.java   
public void process(final Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:SetPropertyProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:OnCompletionProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:RemovePropertyProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:SendDynamicProcessor.java   
public void process(final Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}
项目:Camel    文件:MulticastProcessor.java   
public void process(Exchange exchange) throws Exception {
    AsyncProcessorHelper.process(this, exchange);
}