camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r560774 - /activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/builder/FromBuilder.java
Date Sun, 29 Jul 2007 18:04:22 GMT
Author: jstrachan
Date: Sun Jul 29 11:04:21 2007
New Revision: 560774

URL: http://svn.apache.org/viewvc?view=rev&rev=560774
Log:
tidied up the code

Modified:
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/builder/FromBuilder.java

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/builder/FromBuilder.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/builder/FromBuilder.java?view=diff&rev=560774&r1=560773&r2=560774
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/builder/FromBuilder.java
(original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/builder/FromBuilder.java
Sun Jul 29 11:04:21 2007
@@ -66,7 +66,6 @@
     /**
      * Sends the exchange to the given endpoint URI
      */
-
     public ProcessorFactory to(String uri) {
         return to(endpoint(uri));
     }
@@ -74,7 +73,6 @@
     /**
      * Sends the exchange to the given endpoint
      */
-
     public ProcessorFactory to(Endpoint endpoint) {
         ToBuilder answer = new ToBuilder(this, endpoint);
         addProcessBuilder(answer);
@@ -84,7 +82,6 @@
     /**
      * Sends the exchange to a list of endpoints using the {@link MulticastProcessor} pattern
      */
-
     public ProcessorFactory to(String... uris) {
         return to(endpoints(uris));
     }
@@ -92,24 +89,14 @@
     /**
      * Sends the exchange to a list of endpoints using the {@link MulticastProcessor} pattern
      */
-
-    public ProcessorFactory to(
-            Endpoint... endpoints)
-
-    {
+    public ProcessorFactory to(Endpoint... endpoints) {
         return to(endpoints(endpoints));
     }
 
     /**
      * Sends the exchange to a list of endpoint using the {@link MulticastProcessor} pattern
      */
-
-    public ProcessorFactory to(
-
-            Collection<Endpoint> endpoints
-    )
-
-    {
+    public ProcessorFactory to(Collection<Endpoint> endpoints) {
         return addProcessBuilder(new MulticastBuilder(this, endpoints));
     }
 
@@ -117,7 +104,6 @@
      * Creates a {@link Pipeline} of the list of endpoints so that the message will get processed
by each endpoint in turn
      * and for request/response the output of one endpoint will be the input of the next
endpoint
      */
-
     public ProcessorFactory pipeline(String... uris) {
         return pipeline(endpoints(uris));
     }
@@ -126,7 +112,6 @@
      * Creates a {@link Pipeline} of the list of endpoints so that the message will get processed
by each endpoint in turn
      * and for request/response the output of one endpoint will be the input of the next
endpoint
      */
-
     public ProcessorFactory pipeline(Endpoint... endpoints) {
         return pipeline(endpoints(endpoints));
     }
@@ -135,7 +120,6 @@
      * Creates a {@link Pipeline} of the list of endpoints so that the message will get processed
by each endpoint in turn
      * and for request/response the output of one endpoint will be the input of the next
endpoint
      */
-
     public ProcessorFactory pipeline(Collection<Endpoint> endpoints) {
         return addProcessBuilder(new PipelineBuilder(this, endpoints));
     }
@@ -143,10 +127,7 @@
     /**
      * Creates an {@link IdempotentConsumer} to avoid duplicate messages
      */
-
-    public IdempotentConsumerBuilder idempotentConsumer(
-            Expression messageIdExpression,
-            MessageIdRepository messageIdRepository) {
+    public IdempotentConsumerBuilder idempotentConsumer(Expression messageIdExpression, MessageIdRepository
messageIdRepository) {
         return (IdempotentConsumerBuilder) addProcessBuilder(new IdempotentConsumerBuilder(this,
messageIdExpression, messageIdRepository));
     }
 
@@ -156,12 +137,7 @@
      *
      * @return the builder for a predicate
      */
-
-    public FilterBuilder filter(
-            Predicate predicate
-    )
-
-    {
+    public FilterBuilder filter(Predicate predicate) {
         FilterBuilder answer = new FilterBuilder(this, predicate);
         addProcessBuilder(answer);
         return answer;
@@ -183,12 +159,7 @@
      *
      * @param receipients is the builder of the expression used in the {@link RecipientList}
to decide the destinations
      */
-
-    public RecipientListBuilder recipientList(
-            Expression receipients
-    )
-
-    {
+    public RecipientListBuilder recipientList(Expression receipients) {
         RecipientListBuilder answer = new RecipientListBuilder(this, receipients);
         addProcessBuilder(answer);
         return answer;
@@ -201,13 +172,7 @@
      * @param receipients the expression on which to split
      * @return the builder
      */
-
-    public SplitterBuilder splitter(
-            Expression receipients
-
-    )
-
-    {
+    public SplitterBuilder splitter(Expression receipients) {
         SplitterBuilder answer = new SplitterBuilder(this, receipients);
         addProcessBuilder(answer);
         return answer;
@@ -233,12 +198,7 @@
      * @param expressions the expressions on which to compare messages in order
      * @return the builder
      */
-
-    public ResequencerBuilder resequencer(List
-
-            <Expression<Exchange>> expressions)
-
-    {
+    public ResequencerBuilder resequencer(List<Expression<Exchange>> expressions)
{
         ResequencerBuilder answer = new ResequencerBuilder(this, expressions);
         setRouteBuilder(answer);
         return answer;
@@ -252,7 +212,6 @@
      * @param expressions the expressions on which to compare messages in order
      * @return the builder
      */
-
     public ResequencerBuilder resequencer(Expression<Exchange>... expressions) {
         List<Expression<Exchange>> list = new ArrayList<Expression<Exchange>>();
         for (Expression<Exchange> expression : expressions) {
@@ -276,7 +235,6 @@
      * @param correlationExpression the expression used to calculate the correlation key.
For a JMS message this could
      *                              be the expression <code>header("JMSDestination")</code>
or  <code>header("JMSCorrelationID")</code>
      */
-
     public AggregatorBuilder aggregator(Expression correlationExpression) {
         AggregatorBuilder answer = new AggregatorBuilder(this, correlationExpression);
         setRouteBuilder(answer);
@@ -298,7 +256,6 @@
      * @param correlationExpression the expression used to calculate the correlation key.
For a JMS message this could
      *                              be the expression <code>header("JMSDestination")</code>
or  <code>header("JMSCorrelationID")</code>
      */
-
     public AggregatorBuilder aggregator(Expression correlationExpression, AggregationStrategy
strategy) {
         AggregatorBuilder answer = new AggregatorBuilder(this, correlationExpression);
         answer.aggregationStrategy(strategy);
@@ -313,7 +270,6 @@
      * @param processAtExpression an expression to calculate the time at which the messages
should be processed
      * @return the builder
      */
-
     public DelayerBuilder delayer(Expression<Exchange> processAtExpression) {
         return delayer(processAtExpression, 0L);
     }
@@ -327,7 +283,6 @@
      *                            message should be processed
      * @return the builder
      */
-
     public DelayerBuilder delayer(Expression<Exchange> processAtExpression, long delay)
{
         DelayerBuilder answer = new DelayerBuilder(this, processAtExpression, delay);
         setRouteBuilder(answer);
@@ -341,33 +296,28 @@
      * @param delay the default delay in milliseconds
      * @return the builder
      */
-
     public DelayerBuilder delayer(long delay) {
         return delayer(null, delay);
     }
 
-
     /**
      * A builder for the <a href="http://activemq.apache.org/camel/delayer.html">Delayer</a>
pattern
      * where an expression is used to calculate the time which the message will be dispatched
on
      *
      * @return the builder
      */
-
     public ThrottlerBuilder throttler(long maximumRequestCount) {
         ThrottlerBuilder answer = new ThrottlerBuilder(this, maximumRequestCount);
         setRouteBuilder(answer);
         return answer;
     }
 
-
     /**
      * Installs the given error handler builder
      *
      * @param errorHandlerBuilder the error handler to be used by default for all child routes
      * @return the current builder with the error handler configured
      */
-
     public FromBuilder errorHandler(ErrorHandlerBuilder errorHandlerBuilder) {
         setErrorHandlerBuilder(errorHandlerBuilder);
         return this;
@@ -379,7 +329,6 @@
      * @param condition the falg as to whether error handlers should be inherited or not
      * @return the current builder
      */
-
     public FromBuilder inheritErrorHandler(boolean condition) {
         setInheritErrorHandler(condition);
         return this;
@@ -391,7 +340,6 @@
         return answer;
     }
 
-
     public FromBuilder intercept(DelegateProcessor interceptor) {
         InterceptorBuilder answer = new InterceptorBuilder(this);
         answer.add(interceptor);
@@ -405,7 +353,6 @@
      *
      * @return
      */
-
     public FromBuilder trace() {
         return trace(DEFAULT_TRACE_CATEGORY);
     }
@@ -417,7 +364,6 @@
      * @param category the logging category trace messages will sent to.
      * @return
      */
-
     public FromBuilder trace(String category) {
         final Log log = LogFactory.getLog(category);
         return intercept(new DelegateProcessor() {
@@ -435,7 +381,6 @@
         return answer;
     }
 
-
     public FromBuilder policy(Policy policy) {
         PolicyBuilder answer = new PolicyBuilder(this);
         answer.add(policy);
@@ -449,7 +394,6 @@
     /**
      * Adds the custom processor to this destination which could be a final destination,
or could be a transformation in a pipeline
      */
-
     public FromBuilder process(Processor processor) {
         addProcessorBuilder(processor);
         return this;
@@ -458,7 +402,6 @@
     /**
      * Adds a processor which sets the body on the IN message
      */
-
     public FromBuilder setBody(Expression expression) {
         addProcessorBuilder(ProcessorBuilder.setBody(expression));
         return this;
@@ -467,7 +410,6 @@
     /**
      * Adds a processor which sets the body on the OUT message
      */
-
     public FromBuilder setOutBody(Expression expression) {
         addProcessorBuilder(ProcessorBuilder.setOutBody(expression));
         return this;
@@ -476,7 +418,6 @@
     /**
      * Adds a processor which sets the header on the IN message
      */
-
     public FromBuilder setHeader(String name, Expression expression) {
         addProcessorBuilder(ProcessorBuilder.setHeader(name, expression));
         return this;
@@ -485,7 +426,6 @@
     /**
      * Adds a processor which sets the header on the OUT message
      */
-
     public FromBuilder setOutHeader(String name, Expression expression) {
         addProcessorBuilder(ProcessorBuilder.setOutHeader(name, expression));
         return this;
@@ -494,7 +434,6 @@
     /**
      * Adds a processor which sets the exchange property
      */
-
     public FromBuilder setProperty(String name, Expression expression) {
         addProcessorBuilder(ProcessorBuilder.setProperty(name, expression));
         return this;
@@ -503,7 +442,6 @@
     /**
      * Converts the IN message body to the specified type
      */
-
     public FromBuilder convertBodyTo(Class type) {
         addProcessorBuilder(ProcessorBuilder.setBody(Builder.body().convertTo(type)));
         return this;
@@ -512,7 +450,6 @@
     /**
      * Converts the OUT message body to the specified type
      */
-
     public FromBuilder convertOutBodyTo(Class type) {
         addProcessorBuilder(ProcessorBuilder.setOutBody(Builder.outBody().convertTo(type)));
         return this;
@@ -615,5 +552,4 @@
     protected void setRouteBuilder(FromBuilder routeBuilder) {
         this.routeBuilder = routeBuilder;
     }
-
 }



Mime
View raw message