camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject camel git commit: Component docs
Date Sun, 17 Jan 2016 09:24:05 GMT
Repository: camel
Updated Branches:
  refs/heads/camel-2.16.x f1bd0be5e -> 54e8e6150


Component docs


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/54e8e615
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/54e8e615
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/54e8e615

Branch: refs/heads/camel-2.16.x
Commit: 54e8e6150a42e4f4a27a494d5b7a5e2ab616a3f2
Parents: f1bd0be
Author: Claus Ibsen <davsclaus@apache.org>
Authored: Sun Jan 17 10:12:14 2016 +0100
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Sun Jan 17 10:23:52 2016 +0100

----------------------------------------------------------------------
 .../camel/component/jms/JmsConfiguration.java   | 13 +++++++
 .../apache/camel/component/jms/JmsEndpoint.java | 37 +++++++++-----------
 2 files changed, 30 insertions(+), 20 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/54e8e615/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
----------------------------------------------------------------------
diff --git a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
index c3e2877..3d2738a 100644
--- a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
+++ b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
@@ -195,6 +195,8 @@ public class JmsConfiguration implements Cloneable {
     @UriParam(defaultValue = "true", label = "consumer",
             description = "Specifies whether to use persistent delivery by default for replies.")
     private boolean replyToDeliveryPersistent = true;
+    @UriParam(label = "consumer", description = "Sets the JMS selector to use")
+    private String selector;
     @UriParam(defaultValue = "-1", label = "producer",
             description = "When sending messages, specifies the time-to-live of the message
(in milliseconds).")
     private long timeToLive = -1;
@@ -1922,4 +1924,15 @@ public class JmsConfiguration implements Cloneable {
     public void setMessageCreatedStrategy(MessageCreatedStrategy messageCreatedStrategy)
{
         this.messageCreatedStrategy = messageCreatedStrategy;
     }
+
+    public String getSelector() {
+        return selector;
+    }
+
+    /**
+     * Sets the JMS selector to use
+     */
+    public void setSelector(String selector) {
+        this.selector = selector;
+    }
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/54e8e615/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
index ea68d14..7727322 100644
--- a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
+++ b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
@@ -74,15 +74,14 @@ public class JmsEndpoint extends DefaultEndpoint implements HeaderFilterStrategy
     private final AtomicInteger runningMessageListeners = new AtomicInteger();
     private boolean pubSubDomain;
     private JmsBinding binding;
-    @UriPath(defaultValue = "queue", enums = "queue,topic,temp:queue,temp:topic")
+    @UriPath(defaultValue = "queue", enums = "queue,topic,temp:queue,temp:topic", description
= "The kind of destination to use")
     private String destinationType;
-    @UriPath @Metadata(required = "true")
+    @UriPath(description = "Name of the queue or topic to use as destination")
+    @Metadata(required = "true")
     private String destinationName;
     private Destination destination;
-    @UriParam(label = "advanced")
+    @UriParam(label = "advanced", description = "To use a custom HeaderFilterStrategy to
filter header to and from Camel message.")
     private HeaderFilterStrategy headerFilterStrategy;
-    @UriParam(label = "consumer")
-    private String selector;
     @UriParam
     private JmsConfiguration configuration;
 
@@ -228,7 +227,7 @@ public class JmsEndpoint extends DefaultEndpoint implements HeaderFilterStrategy
         } else {
             // do nothing, as we're working with a DefaultJmsMessageListenerContainer with
an explicit DefaultTaskExecutorType,
             // so DefaultJmsMessageListenerContainer#createDefaultTaskExecutor will handle
the creation
-            log.debug("Deferring creation of TaskExecutor for listener container: {} as per
policy: {}", 
+            log.debug("Deferring creation of TaskExecutor for listener container: {} as per
policy: {}",
                     listenerContainer, configuration.getDefaultTaskExecutorType());
         }
 
@@ -319,7 +318,7 @@ public class JmsEndpoint extends DefaultEndpoint implements HeaderFilterStrategy
     public String getThreadName() {
         return "JmsConsumer[" + getEndpointConfiguredDestinationName() + "]";
     }
-    
+
     // Properties
     // -------------------------------------------------------------------------
 
@@ -405,17 +404,6 @@ public class JmsEndpoint extends DefaultEndpoint implements HeaderFilterStrategy
         this.configuration = configuration;
     }
 
-    public String getSelector() {
-        return selector;
-    }
-
-    /**
-     * Sets the JMS selector to use
-     */
-    public void setSelector(String selector) {
-        this.selector = selector;
-    }
-
     public boolean isSingleton() {
         return true;
     }
@@ -572,11 +560,11 @@ public class JmsEndpoint extends DefaultEndpoint implements HeaderFilterStrategy
     public ErrorHandler getErrorHandler() {
         return getConfiguration().getErrorHandler();
     }
-    
+
     public LoggingLevel getErrorHandlerLoggingLevel() {
         return getConfiguration().getErrorHandlerLoggingLevel();
     }
-   
+
     @ManagedAttribute
     public boolean isErrorHandlerLogStackTrace() {
         return getConfiguration().isErrorHandlerLogStackTrace();
@@ -1239,6 +1227,15 @@ public class JmsEndpoint extends DefaultEndpoint implements HeaderFilterStrategy
         return runningMessageListeners.get();
     }
 
+    @ManagedAttribute
+    public String getSelector() {
+        return configuration.getSelector();
+    }
+
+    public void setSelector(String selector) {
+        configuration.setSelector(selector);
+    }
+
     // Implementation methods
     //-------------------------------------------------------------------------
 


Mime
View raw message