org.apache.camel.groovy.extend
Class CamelGroovyMethods

java.lang.Object
  org.apache.camel.groovy.extend.CamelGroovyMethods

public final class CamelGroovyMethods
extends Object

Extension class containing static methods that mainly allow to use Closures instead of Predicates, Expressions, Processors, or AggregationStrategies

Method Summary

static org.apache.camel.model.AggregateDefinition	aggregate(org.apache.camel.model.ProcessorDefinition<?> self, groovy.lang.Closure<?> correlationExpression)
static org.apache.camel.model.AggregateDefinition	aggregationStrategy(org.apache.camel.model.AggregateDefinition self, groovy.lang.Closure<org.apache.camel.Exchange> aggregationLogic)
static org.apache.camel.model.MulticastDefinition	aggregationStrategy(org.apache.camel.model.MulticastDefinition self, groovy.lang.Closure<org.apache.camel.Exchange> aggregationLogic)
static org.apache.camel.model.RecipientListDefinition<?>	aggregationStrategy(org.apache.camel.model.RecipientListDefinition<?> self, groovy.lang.Closure<org.apache.camel.Exchange> aggregationLogic)
static org.apache.camel.model.SplitDefinition	aggregationStrategy(org.apache.camel.model.SplitDefinition self, groovy.lang.Closure<org.apache.camel.Exchange> aggregationLogic)
static org.apache.camel.processor.aggregate.AggregationStrategy	aggregator(org.apache.camel.builder.RouteBuilder self, groovy.lang.Closure<org.apache.camel.Exchange> aggregationLogic)
static org.apache.camel.model.AggregateDefinition	completionPredicate(org.apache.camel.model.AggregateDefinition self, groovy.lang.Closure<?> predicate)
static org.apache.camel.model.AggregateDefinition	completionSize(org.apache.camel.model.AggregateDefinition self, groovy.lang.Closure<?> expression)
static org.apache.camel.model.AggregateDefinition	completionTimeout(org.apache.camel.model.AggregateDefinition self, groovy.lang.Closure<?> expression)
static org.apache.camel.model.OnExceptionDefinition	continued(org.apache.camel.model.OnExceptionDefinition self, groovy.lang.Closure<?> predicate)
static org.apache.camel.model.DelayDefinition	delay(org.apache.camel.model.ProcessorDefinition<?> self, groovy.lang.Closure<?> expression)
static org.apache.camel.model.DynamicRouterDefinition<?>	dynamicRouter(org.apache.camel.model.ProcessorDefinition<?> self, groovy.lang.Closure<?> expression)
static org.apache.camel.model.ProcessorDefinition<?>	enrich(org.apache.camel.model.ProcessorDefinition<?> self, String resourceUri, groovy.lang.Closure<org.apache.camel.Exchange> aggregationLogic)
static <T> T	expression(org.apache.camel.builder.ExpressionClause<T> self, groovy.lang.Closure<?> expression)
static org.apache.camel.Expression	expression(org.apache.camel.builder.RouteBuilder self, groovy.lang.Closure<?> expression)
static org.apache.camel.model.FilterDefinition	filter(org.apache.camel.model.ProcessorDefinition<?> self, groovy.lang.Closure<?> predicate)
static org.apache.camel.model.ProcessorDefinition<?>	gnode(org.apache.camel.builder.DataFormatClause<?> self)
static org.apache.camel.model.ProcessorDefinition<?>	gnode(org.apache.camel.builder.DataFormatClause<?> self, boolean namespaceAware)
static org.apache.camel.model.ProcessorDefinition<?>	gpath(org.apache.camel.builder.DataFormatClause<?> self)
static org.apache.camel.model.ProcessorDefinition<?>	gpath(org.apache.camel.builder.DataFormatClause<?> self, boolean namespaceAware)
static org.apache.camel.model.OnExceptionDefinition	handled(org.apache.camel.model.OnExceptionDefinition self, groovy.lang.Closure<?> predicate)
static org.apache.camel.model.IdempotentConsumerDefinition	idempotentConsumer(org.apache.camel.model.ProcessorDefinition<?> self, groovy.lang.Closure<?> expression)
static org.apache.camel.model.IdempotentConsumerDefinition	idempotentConsumer(org.apache.camel.model.ProcessorDefinition<?> self, org.apache.camel.spi.IdempotentRepository<?> rep, groovy.lang.Closure<?> expression)
static org.apache.camel.model.LoopDefinition	loop(org.apache.camel.model.ProcessorDefinition<?> self, groovy.lang.Closure<?> expression)
org.apache.camel.model.WireTapDefinition<?>	newExchange(org.apache.camel.model.WireTapDefinition<?> self, groovy.lang.Closure<?> processorLogic)
static org.apache.camel.model.WireTapDefinition<?>	newExchangeBody(org.apache.camel.model.WireTapDefinition<?> self, groovy.lang.Closure<?> expression)
static org.apache.camel.model.WireTapDefinition<?>	newExchangeHeader(org.apache.camel.model.WireTapDefinition<?> self, String header, groovy.lang.Closure<?> expression)
static org.apache.camel.model.MulticastDefinition	onPrepare(org.apache.camel.model.MulticastDefinition self, groovy.lang.Closure<org.apache.camel.Exchange> processorLogic)
static org.apache.camel.model.RecipientListDefinition<?>	onPrepare(org.apache.camel.model.RecipientListDefinition<?> self, groovy.lang.Closure<org.apache.camel.Exchange> processorLogic)
static org.apache.camel.model.SplitDefinition	onPrepare(org.apache.camel.model.SplitDefinition self, groovy.lang.Closure<org.apache.camel.Exchange> processorLogic)
static org.apache.camel.model.WireTapDefinition<?>	onPrepare(org.apache.camel.model.WireTapDefinition<?> self, groovy.lang.Closure<org.apache.camel.Exchange> processorLogic)
static org.apache.camel.model.OnExceptionDefinition	onRedelivery(org.apache.camel.model.OnExceptionDefinition self, groovy.lang.Closure<org.apache.camel.Exchange> processorLogic)
static org.apache.camel.model.CatchDefinition	onWhen(org.apache.camel.model.CatchDefinition self, groovy.lang.Closure<?> predicate)
static org.apache.camel.model.OnCompletionDefinition	onWhen(org.apache.camel.model.OnCompletionDefinition self, groovy.lang.Closure<?> predicate)
static org.apache.camel.model.OnExceptionDefinition	onWhen(org.apache.camel.model.OnExceptionDefinition self, groovy.lang.Closure<?> predicate)
static org.apache.camel.model.TryDefinition	onWhen(org.apache.camel.model.TryDefinition self, groovy.lang.Closure<?> predicate)
static org.apache.camel.model.ProcessorDefinition<?>	pollEnrich(org.apache.camel.model.ProcessorDefinition<?> self, String resourceUri, groovy.lang.Closure<org.apache.camel.Exchange> aggregationLogic)
static org.apache.camel.model.ProcessorDefinition<?>	pollEnrich(org.apache.camel.model.ProcessorDefinition<?> self, String resourceUri, long timeout, groovy.lang.Closure<org.apache.camel.Exchange> aggregationLogic)
static org.apache.camel.Predicate	predicate(org.apache.camel.builder.RouteBuilder self, groovy.lang.Closure<?> predicate)
static org.apache.camel.model.ProcessorDefinition<?>	process(org.apache.camel.model.ProcessorDefinition<?> self, groovy.lang.Closure<?> processorLogic)
static org.apache.camel.Processor	processor(org.apache.camel.builder.RouteBuilder self, groovy.lang.Closure<org.apache.camel.Exchange> processor)
static org.apache.camel.model.RecipientListDefinition<?>	recipientList(org.apache.camel.model.ProcessorDefinition<?> self, groovy.lang.Closure<?> recipients)
static org.apache.camel.model.RecipientListDefinition<?>	recipientList(org.apache.camel.model.ProcessorDefinition<?> self, String delimiter, groovy.lang.Closure<?> recipients)
static org.apache.camel.model.ResequenceDefinition	resequence(org.apache.camel.model.ProcessorDefinition<?> self, groovy.lang.Closure<?> expression)
static org.apache.camel.model.OnExceptionDefinition	retryWhile(org.apache.camel.model.OnExceptionDefinition self, groovy.lang.Closure<?> predicate)
static org.apache.camel.model.RoutingSlipDefinition<?>	routingSlip(org.apache.camel.model.ProcessorDefinition<?> self, groovy.lang.Closure<?> recipients)
static org.apache.camel.model.RoutingSlipDefinition<?>	routingSlip(org.apache.camel.model.ProcessorDefinition<?> self, String delimiter, groovy.lang.Closure<?> recipients)
static org.apache.camel.model.ProcessorDefinition<?>	setBody(org.apache.camel.model.ProcessorDefinition<?> self, groovy.lang.Closure<?> expression)
static org.apache.camel.model.ProcessorDefinition<?>	setFaultBody(org.apache.camel.model.ProcessorDefinition<?> self, groovy.lang.Closure<?> expression)
static org.apache.camel.model.ProcessorDefinition<?>	setHeader(org.apache.camel.model.ProcessorDefinition<?> self, String name, groovy.lang.Closure<?> expression)
static org.apache.camel.model.ProcessorDefinition<?>	setProperty(org.apache.camel.model.ProcessorDefinition<?> self, String name, groovy.lang.Closure<?> expression)
static org.apache.camel.model.ProcessorDefinition<?>	sort(org.apache.camel.model.ProcessorDefinition<?> self, groovy.lang.Closure<?> expression)
static org.apache.camel.model.SplitDefinition	split(org.apache.camel.model.ProcessorDefinition<?> self, groovy.lang.Closure<?> expression)
static org.apache.camel.model.ThrottleDefinition	throttle(org.apache.camel.model.ProcessorDefinition<?> self, groovy.lang.Closure<?> expression)
static org.apache.camel.model.ProcessorDefinition<?>	transform(org.apache.camel.model.ProcessorDefinition<?> self, groovy.lang.Closure<?> expression)
static org.apache.camel.model.ProcessorDefinition<?>	validate(org.apache.camel.model.ProcessorDefinition<?> self, groovy.lang.Closure<?> predicate)
static org.apache.camel.model.ChoiceDefinition	when(org.apache.camel.model.ChoiceDefinition self, groovy.lang.Closure<?> predicate)
static org.apache.camel.model.InterceptDefinition	when(org.apache.camel.model.InterceptDefinition self, groovy.lang.Closure<?> predicate)
static org.apache.camel.model.InterceptSendToEndpointDefinition	when(org.apache.camel.model.InterceptSendToEndpointDefinition self, groovy.lang.Closure<?> predicate)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

process

public static org.apache.camel.model.ProcessorDefinition<?> process(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                    groovy.lang.Closure<?> processorLogic)

newExchange

public org.apache.camel.model.WireTapDefinition<?> newExchange(org.apache.camel.model.WireTapDefinition<?> self,
                                                               groovy.lang.Closure<?> processorLogic)

onRedelivery

public static org.apache.camel.model.OnExceptionDefinition onRedelivery(org.apache.camel.model.OnExceptionDefinition self,
                                                                        groovy.lang.Closure<org.apache.camel.Exchange> processorLogic)

enrich

public static org.apache.camel.model.ProcessorDefinition<?> enrich(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                   String resourceUri,
                                                                   groovy.lang.Closure<org.apache.camel.Exchange> aggregationLogic)

pollEnrich

public static org.apache.camel.model.ProcessorDefinition<?> pollEnrich(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                       String resourceUri,
                                                                       groovy.lang.Closure<org.apache.camel.Exchange> aggregationLogic)

pollEnrich

public static org.apache.camel.model.ProcessorDefinition<?> pollEnrich(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                       String resourceUri,
                                                                       long timeout,
                                                                       groovy.lang.Closure<org.apache.camel.Exchange> aggregationLogic)

aggregationStrategy

public static org.apache.camel.model.MulticastDefinition aggregationStrategy(org.apache.camel.model.MulticastDefinition self,
                                                                             groovy.lang.Closure<org.apache.camel.Exchange> aggregationLogic)

aggregationStrategy

public static org.apache.camel.model.RecipientListDefinition<?> aggregationStrategy(org.apache.camel.model.RecipientListDefinition<?> self,
                                                                                    groovy.lang.Closure<org.apache.camel.Exchange> aggregationLogic)

aggregationStrategy

public static org.apache.camel.model.SplitDefinition aggregationStrategy(org.apache.camel.model.SplitDefinition self,
                                                                         groovy.lang.Closure<org.apache.camel.Exchange> aggregationLogic)

aggregationStrategy

public static org.apache.camel.model.AggregateDefinition aggregationStrategy(org.apache.camel.model.AggregateDefinition self,
                                                                             groovy.lang.Closure<org.apache.camel.Exchange> aggregationLogic)

onPrepare

public static org.apache.camel.model.MulticastDefinition onPrepare(org.apache.camel.model.MulticastDefinition self,
                                                                   groovy.lang.Closure<org.apache.camel.Exchange> processorLogic)

onPrepare

public static org.apache.camel.model.RecipientListDefinition<?> onPrepare(org.apache.camel.model.RecipientListDefinition<?> self,
                                                                          groovy.lang.Closure<org.apache.camel.Exchange> processorLogic)

onPrepare

public static org.apache.camel.model.SplitDefinition onPrepare(org.apache.camel.model.SplitDefinition self,
                                                               groovy.lang.Closure<org.apache.camel.Exchange> processorLogic)

onPrepare

public static org.apache.camel.model.WireTapDefinition<?> onPrepare(org.apache.camel.model.WireTapDefinition<?> self,
                                                                    groovy.lang.Closure<org.apache.camel.Exchange> processorLogic)

transform

public static org.apache.camel.model.ProcessorDefinition<?> transform(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                      groovy.lang.Closure<?> expression)

setProperty

public static org.apache.camel.model.ProcessorDefinition<?> setProperty(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                        String name,
                                                                        groovy.lang.Closure<?> expression)

setHeader

public static org.apache.camel.model.ProcessorDefinition<?> setHeader(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                      String name,
                                                                      groovy.lang.Closure<?> expression)

setBody

public static org.apache.camel.model.ProcessorDefinition<?> setBody(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                    groovy.lang.Closure<?> expression)

setFaultBody

public static org.apache.camel.model.ProcessorDefinition<?> setFaultBody(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                         groovy.lang.Closure<?> expression)

sort

public static org.apache.camel.model.ProcessorDefinition<?> sort(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                 groovy.lang.Closure<?> expression)

idempotentConsumer

public static org.apache.camel.model.IdempotentConsumerDefinition idempotentConsumer(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                                     groovy.lang.Closure<?> expression)

idempotentConsumer

public static org.apache.camel.model.IdempotentConsumerDefinition idempotentConsumer(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                                     org.apache.camel.spi.IdempotentRepository<?> rep,
                                                                                     groovy.lang.Closure<?> expression)

recipientList

public static org.apache.camel.model.RecipientListDefinition<?> recipientList(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                              groovy.lang.Closure<?> recipients)

recipientList

public static org.apache.camel.model.RecipientListDefinition<?> recipientList(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                              String delimiter,
                                                                              groovy.lang.Closure<?> recipients)

routingSlip

public static org.apache.camel.model.RoutingSlipDefinition<?> routingSlip(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                          groovy.lang.Closure<?> recipients)

routingSlip

public static org.apache.camel.model.RoutingSlipDefinition<?> routingSlip(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                          String delimiter,
                                                                          groovy.lang.Closure<?> recipients)

dynamicRouter

public static org.apache.camel.model.DynamicRouterDefinition<?> dynamicRouter(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                              groovy.lang.Closure<?> expression)

split

public static org.apache.camel.model.SplitDefinition split(org.apache.camel.model.ProcessorDefinition<?> self,
                                                           groovy.lang.Closure<?> expression)

resequence

public static org.apache.camel.model.ResequenceDefinition resequence(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                     groovy.lang.Closure<?> expression)

aggregate

public static org.apache.camel.model.AggregateDefinition aggregate(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                   groovy.lang.Closure<?> correlationExpression)

completionSize

public static org.apache.camel.model.AggregateDefinition completionSize(org.apache.camel.model.AggregateDefinition self,
                                                                        groovy.lang.Closure<?> expression)

completionTimeout

public static org.apache.camel.model.AggregateDefinition completionTimeout(org.apache.camel.model.AggregateDefinition self,
                                                                           groovy.lang.Closure<?> expression)

delay

public static org.apache.camel.model.DelayDefinition delay(org.apache.camel.model.ProcessorDefinition<?> self,
                                                           groovy.lang.Closure<?> expression)

throttle

public static org.apache.camel.model.ThrottleDefinition throttle(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                 groovy.lang.Closure<?> expression)

loop

public static org.apache.camel.model.LoopDefinition loop(org.apache.camel.model.ProcessorDefinition<?> self,
                                                         groovy.lang.Closure<?> expression)

newExchangeBody

public static org.apache.camel.model.WireTapDefinition<?> newExchangeBody(org.apache.camel.model.WireTapDefinition<?> self,
                                                                          groovy.lang.Closure<?> expression)

newExchangeHeader

public static org.apache.camel.model.WireTapDefinition<?> newExchangeHeader(org.apache.camel.model.WireTapDefinition<?> self,
                                                                            String header,
                                                                            groovy.lang.Closure<?> expression)

filter

public static org.apache.camel.model.FilterDefinition filter(org.apache.camel.model.ProcessorDefinition<?> self,
                                                             groovy.lang.Closure<?> predicate)

validate

public static org.apache.camel.model.ProcessorDefinition<?> validate(org.apache.camel.model.ProcessorDefinition<?> self,
                                                                     groovy.lang.Closure<?> predicate)

when

public static org.apache.camel.model.ChoiceDefinition when(org.apache.camel.model.ChoiceDefinition self,
                                                           groovy.lang.Closure<?> predicate)

onWhen

public static org.apache.camel.model.TryDefinition onWhen(org.apache.camel.model.TryDefinition self,
                                                          groovy.lang.Closure<?> predicate)

onWhen

public static org.apache.camel.model.OnExceptionDefinition onWhen(org.apache.camel.model.OnExceptionDefinition self,
                                                                  groovy.lang.Closure<?> predicate)

handled

public static org.apache.camel.model.OnExceptionDefinition handled(org.apache.camel.model.OnExceptionDefinition self,
                                                                   groovy.lang.Closure<?> predicate)

continued

public static org.apache.camel.model.OnExceptionDefinition continued(org.apache.camel.model.OnExceptionDefinition self,
                                                                     groovy.lang.Closure<?> predicate)

retryWhile

public static org.apache.camel.model.OnExceptionDefinition retryWhile(org.apache.camel.model.OnExceptionDefinition self,
                                                                      groovy.lang.Closure<?> predicate)

onWhen

public static org.apache.camel.model.OnCompletionDefinition onWhen(org.apache.camel.model.OnCompletionDefinition self,
                                                                   groovy.lang.Closure<?> predicate)

onWhen

public static org.apache.camel.model.CatchDefinition onWhen(org.apache.camel.model.CatchDefinition self,
                                                            groovy.lang.Closure<?> predicate)

completionPredicate

public static org.apache.camel.model.AggregateDefinition completionPredicate(org.apache.camel.model.AggregateDefinition self,
                                                                             groovy.lang.Closure<?> predicate)

when

public static org.apache.camel.model.InterceptDefinition when(org.apache.camel.model.InterceptDefinition self,
                                                              groovy.lang.Closure<?> predicate)

when

public static org.apache.camel.model.InterceptSendToEndpointDefinition when(org.apache.camel.model.InterceptSendToEndpointDefinition self,
                                                                            groovy.lang.Closure<?> predicate)

aggregator

public static org.apache.camel.processor.aggregate.AggregationStrategy aggregator(org.apache.camel.builder.RouteBuilder self,
                                                                                  groovy.lang.Closure<org.apache.camel.Exchange> aggregationLogic)

expression

public static org.apache.camel.Expression expression(org.apache.camel.builder.RouteBuilder self,
                                                     groovy.lang.Closure<?> expression)

predicate

public static org.apache.camel.Predicate predicate(org.apache.camel.builder.RouteBuilder self,
                                                   groovy.lang.Closure<?> predicate)

processor

public static org.apache.camel.Processor processor(org.apache.camel.builder.RouteBuilder self,
                                                   groovy.lang.Closure<org.apache.camel.Exchange> processor)

expression

public static <T> T expression(org.apache.camel.builder.ExpressionClause<T> self,
                               groovy.lang.Closure<?> expression)

gnode

public static org.apache.camel.model.ProcessorDefinition<?> gnode(org.apache.camel.builder.DataFormatClause<?> self,
                                                                  boolean namespaceAware)

gnode

public static org.apache.camel.model.ProcessorDefinition<?> gnode(org.apache.camel.builder.DataFormatClause<?> self)

gpath

public static org.apache.camel.model.ProcessorDefinition<?> gpath(org.apache.camel.builder.DataFormatClause<?> self,
                                                                  boolean namespaceAware)

gpath

public static org.apache.camel.model.ProcessorDefinition<?> gpath(org.apache.camel.builder.DataFormatClause<?> self)