svn commit: r1210806 [1/3] - in /camel/trunk/camel-core/src: main/java/org/apache/camel/api/management/ main/java/org/apache/camel/api/management/mbean/ main/java/org/apache/camel/management/ main/java/org/apache/camel/management/mbean/ test/java/org/a...

[da...@apache.org]

Author: davsclaus
Date: Tue Dec  6 07:29:02 2011
New Revision: 1210806

URL: http://svn.apache.org/viewvc?rev=1210806&view=rev
Log:
CAMEL-4468: Added client API for mbeans. Thanks to Marco for the patch. Fixed CS. Improved MBeanInfoAssembler to detect annotations on sub class or interfaces.

Added:
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedBrowsableEndpointMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedCamelContextMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedComponentMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedConsumerCacheMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedConsumerMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedCounterMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedDelayerMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedEndpointMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedEndpointRegistryMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedErrorHandlerMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedPerformanceCounterMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProcessorMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProducerCacheMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProducerMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedRouteMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSchedulePollConsumerMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSendProcessorMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedServiceMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSuspendableRouteMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThreadPoolMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThrottlerMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThrottlingInflightRoutePolicyMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedTracerMBean.java   (with props)
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/package.html
      - copied, changed from r1210771, camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/package.html
    camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopUsingMBeanAPITest.java
      - copied, changed from r1210790, camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopTest.java
Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedAttribute.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedNotification.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedNotifications.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedOperation.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedResource.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/MBeanInfoAssembler.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/JMXNotificationTraceEventHandler.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedBrowsableEndpoint.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedCamelContext.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedComponent.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedConsumer.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedConsumerCache.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedCounter.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedDelayer.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedEndpoint.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedEndpointRegistry.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedErrorHandler.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedPerformanceCounter.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedProcessor.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedProducer.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedProducerCache.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoute.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedScheduledPollConsumer.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedSendProcessor.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedService.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedSuspendableRoute.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedThreadPool.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedThrottler.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedThrottlingInflightRoutePolicy.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedTracer.java

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedAttribute.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedAttribute.java?rev=1210806&r1=1210805&r2=1210806&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedAttribute.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedAttribute.java Tue Dec  6 07:29:02 2011
@@ -16,7 +16,9 @@
  */
 package org.apache.camel.api.management;
 
+import java.lang.annotation.Documented;
 import java.lang.annotation.ElementType;
+import java.lang.annotation.Inherited;
 import java.lang.annotation.Retention;
 import java.lang.annotation.RetentionPolicy;
 import java.lang.annotation.Target;
@@ -26,6 +28,8 @@ import java.lang.annotation.Target;
  */
 @Target(ElementType.METHOD)
 @Retention(RetentionPolicy.RUNTIME)
+@Inherited
+@Documented
 public @interface ManagedAttribute {
 
     String description() default "";

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedNotification.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedNotification.java?rev=1210806&r1=1210805&r2=1210806&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedNotification.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedNotification.java Tue Dec  6 07:29:02 2011
@@ -29,10 +29,10 @@ import java.lang.annotation.Target;
 @Documented
 public @interface ManagedNotification {
 
-        String name();
+    String name();
 
-        String description() default "";
+    String description() default "";
 
-        String[] notificationTypes();
+    String[] notificationTypes();
 
 }

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedNotifications.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedNotifications.java?rev=1210806&r1=1210805&r2=1210806&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedNotifications.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedNotifications.java Tue Dec  6 07:29:02 2011
@@ -29,6 +29,6 @@ import java.lang.annotation.Target;
 @Documented
 public @interface ManagedNotifications {
 
-        ManagedNotification[] value();
+    ManagedNotification[] value();
 
 }
\ No newline at end of file

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedOperation.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedOperation.java?rev=1210806&r1=1210805&r2=1210806&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedOperation.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedOperation.java Tue Dec  6 07:29:02 2011
@@ -17,6 +17,7 @@
 package org.apache.camel.api.management;
 
 import java.lang.annotation.ElementType;
+import java.lang.annotation.Inherited;
 import java.lang.annotation.Retention;
 import java.lang.annotation.RetentionPolicy;
 import java.lang.annotation.Target;
@@ -26,6 +27,7 @@ import java.lang.annotation.Target;
  */
 @Target(ElementType.METHOD)
 @Retention(RetentionPolicy.RUNTIME)
+@Inherited
 public @interface ManagedOperation {
 
     String description() default "";

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedResource.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedResource.java?rev=1210806&r1=1210805&r2=1210806&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedResource.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/ManagedResource.java Tue Dec  6 07:29:02 2011
@@ -16,7 +16,9 @@
  */
 package org.apache.camel.api.management;
 
+import java.lang.annotation.Documented;
 import java.lang.annotation.ElementType;
+import java.lang.annotation.Inherited;
 import java.lang.annotation.Retention;
 import java.lang.annotation.RetentionPolicy;
 import java.lang.annotation.Target;
@@ -26,6 +28,8 @@ import java.lang.annotation.Target;
  */
 @Target(ElementType.TYPE)
 @Retention(RetentionPolicy.RUNTIME)
+@Inherited
+@Documented
 public @interface ManagedResource {
 
     String description() default "";

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedBrowsableEndpointMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedBrowsableEndpointMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedBrowsableEndpointMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedBrowsableEndpointMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,48 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedOperation;
+
+public interface ManagedBrowsableEndpointMBean {
+
+    @ManagedOperation(description = "Current number of Exchanges in Queue")
+    long queueSize();
+
+    @ManagedOperation(description = "Get Exchange from queue by index")
+    String browseExchange(Integer index);
+
+    @ManagedOperation(description = "Get message body from queue by index")
+    String browseMessageBody(Integer index);
+
+    /**
+     * @deprecated use {@link #browseAllMessagesAsXml(Boolean)} instead
+     */
+    @ManagedOperation(description = "Get message as XML from queue by index")
+    @Deprecated
+    String browseMessageAsXml(Integer index);
+
+    @ManagedOperation(description = "Get message as XML from queue by index")
+    String browseMessageAsXml(Integer index, Boolean includeBody);
+
+    @ManagedOperation(description = "Gets all the messages as XML from the queue")
+    String browseAllMessagesAsXml(Boolean includeBody);
+
+    @ManagedOperation(description = "Gets the range of messages as XML from the queue")
+    String browseRangeMessagesAsXml(Integer fromIndex, Integer toIndex, Boolean includeBody);
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedBrowsableEndpointMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedBrowsableEndpointMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedCamelContextMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedCamelContextMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedCamelContextMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedCamelContextMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,135 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
+import org.apache.camel.api.management.ManagedAttribute;
+import org.apache.camel.api.management.ManagedOperation;
+
+public interface ManagedCamelContextMBean {
+
+    @ManagedAttribute(description = "Camel id")
+    String getCamelId();
+
+    @ManagedAttribute(description = "Camel Version")
+    String getCamelVersion();
+
+    @ManagedAttribute(description = "Camel State")
+    String getState();
+
+    @ManagedAttribute(description = "Uptime")
+    String getUptime();
+
+    @ManagedAttribute(description = "Camel Properties")
+    Map<String, String> getProperties();
+
+    @ManagedAttribute(description = "Tracing")
+    Boolean getTracing();
+
+    @ManagedAttribute(description = "Tracing")
+    void setTracing(Boolean tracing);
+
+    @ManagedAttribute(description = "Current number of inflight Exchanges")
+    Integer getInflightExchanges();
+
+    @ManagedAttribute(description = "Shutdown timeout")
+    void setTimeout(long timeout);
+
+    @ManagedAttribute(description = "Shutdown timeout")
+    long getTimeout();
+
+    @ManagedAttribute(description = "Shutdown timeout time unit")
+    void setTimeUnit(TimeUnit timeUnit);
+
+    @ManagedAttribute(description = "Shutdown timeout time unit")
+    TimeUnit getTimeUnit();
+
+    @ManagedAttribute(description = "Whether to force shutdown now when a timeout occurred")
+    void setShutdownNowOnTimeout(boolean shutdownNowOnTimeout);
+
+    @ManagedAttribute(description = "Whether to force shutdown now when a timeout occurred")
+    boolean isShutdownNowOnTimeout();
+
+    @ManagedAttribute(description = "Average load over the last minute")
+    String getLoad01();
+
+    @ManagedAttribute(description = "Average load over the last five minutes")
+    String getLoad05();
+
+    @ManagedAttribute(description = "Average load over the last fifteen minutes")
+    String getLoad15();
+
+    @ManagedOperation(description = "Start Camel")
+    void start() throws Exception;
+
+    @ManagedOperation(description = "Stop Camel (shutdown)")
+    void stop() throws Exception;
+
+    @ManagedOperation(description = "Suspend Camel")
+    void suspend() throws Exception;
+
+    @ManagedOperation(description = "Resume Camel")
+    void resume() throws Exception;
+
+    @ManagedOperation(description = "Send body (in only)")
+    void sendBody(String endpointUri, Object body) throws Exception;
+
+    @ManagedOperation(description = "Send body (String type) (in only)")
+    void sendStringBody(String endpointUri, String body) throws Exception;
+
+    @ManagedOperation(description = "Send body and headers (in only)")
+    void sendBodyAndHeaders(String endpointUri, Object body, Map<String, Object> headers) throws Exception;
+
+    @ManagedOperation(description = "Request body (in out)")
+    Object requestBody(String endpointUri, Object body) throws Exception;
+
+    @ManagedOperation(description = "Request body (String type) (in out)")
+    Object requestStringBody(String endpointUri, String body) throws Exception;
+
+    @ManagedOperation(description = "Request body and headers (in out)")
+    Object requestBodyAndHeaders(String endpointUri, Object body, Map<String, Object> headers) throws Exception;
+
+    @ManagedOperation(description = "Dumps the routes as XML")
+    String dumpRoutesAsXml() throws Exception;
+
+    @ManagedOperation(description = "Adds or updates existing routes from XML")
+    void addOrUpdateRoutesFromXml(String xml) throws Exception;
+
+    /**
+     * Creates the endpoint by the given uri
+     *
+     * @param uri uri of endpoint to create
+     * @return <tt>true</tt> if a new endpoint was created, <tt>false</tt> if the endpoint already existed
+     * @throws Exception is thrown if error occurred
+     */
+    @ManagedOperation(description = "Creates the endpoint by the given uri")
+    boolean createEndpoint(String uri) throws Exception;
+
+    /**
+     * Removes the endpoint by the given pattern
+     *
+     * @param pattern the pattern
+     * @return number of endpoints removed
+     * @throws Exception is thrown if error occurred
+     * @see org.apache.camel.CamelContext#removeEndpoints(String)
+     */
+    @ManagedOperation(description = "Removes endpoints by the given pattern")
+    int removeEndpoints(String pattern) throws Exception;
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedCamelContextMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedCamelContextMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedComponentMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedComponentMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedComponentMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedComponentMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,32 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+
+public interface ManagedComponentMBean {
+
+    @ManagedAttribute(description = "Component Name")
+    String getComponentName();
+
+    @ManagedAttribute(description = "Component State")
+    String getState();
+
+    @ManagedAttribute(description = "Camel id")
+    String getCamelId();
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedComponentMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedComponentMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedConsumerCacheMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedConsumerCacheMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedConsumerCacheMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedConsumerCacheMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,45 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+import org.apache.camel.api.management.ManagedOperation;
+
+public interface ManagedConsumerCacheMBean {
+
+    @ManagedAttribute(description = "Source")
+    String getSource();
+
+    @ManagedAttribute(description = "Number of elements cached")
+    Integer getSize();
+
+    @ManagedAttribute(description = "Maximum cache size (capacity)")
+    Integer getMaximumCacheSize();
+
+    @ManagedAttribute(description = "Cache hits")
+    Long getHits();
+
+    @ManagedAttribute(description = "Cache misses")
+    Long getMisses();
+
+    @ManagedOperation(description = "Reset cache statistics")
+    void resetStatistics();
+
+    @ManagedOperation(description = "Purges the cache")
+    void purge();
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedConsumerCacheMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedConsumerCacheMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedConsumerMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedConsumerMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedConsumerMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedConsumerMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,29 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+
+public interface ManagedConsumerMBean {
+
+    @ManagedAttribute(description = "Endpoint Uri")
+    String getEndpointUri();
+
+    @ManagedAttribute(description = "Current number of inflight Exchanges")
+    Integer getInflightExchanges();
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedConsumerMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedConsumerMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedCounterMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedCounterMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedCounterMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedCounterMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,30 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+import org.apache.camel.api.management.ManagedOperation;
+
+public interface ManagedCounterMBean {
+
+    @ManagedOperation(description = "Reset counters")
+    void reset();
+
+    @ManagedAttribute(description = "Total number of exchanges")
+    long getExchangesTotal() throws Exception;
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedCounterMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedCounterMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedDelayerMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedDelayerMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedDelayerMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedDelayerMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,30 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+import org.apache.camel.api.management.ManagedOperation;
+
+public interface ManagedDelayerMBean {
+
+    @ManagedAttribute(description = "Delay")
+    Long getDelay();
+
+    @ManagedOperation(description = "Set a constant delay in millis")
+    void constantDelay(Integer millis);
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedDelayerMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedDelayerMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedEndpointMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedEndpointMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedEndpointMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedEndpointMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,35 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+
+public interface ManagedEndpointMBean {
+
+    @ManagedAttribute(description = "Camel id")
+    String getCamelId();
+
+    @ManagedAttribute(description = "Endpoint Uri")
+    String getEndpointUri();
+
+    @ManagedAttribute(description = "Singleton")
+    boolean isSingleton();
+
+    @ManagedAttribute(description = "Service State")
+    String getState();
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedEndpointMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedEndpointMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedEndpointRegistryMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedEndpointRegistryMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedEndpointRegistryMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedEndpointRegistryMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,36 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+import org.apache.camel.api.management.ManagedOperation;
+
+public interface ManagedEndpointRegistryMBean {
+
+    @ManagedAttribute(description = "Source")
+    String getSource();
+
+    @ManagedAttribute(description = "Number of endpoints cached")
+    Integer getSize();
+
+    @ManagedAttribute(description = "Maximum cache size (capacity)")
+    Integer getMaximumCacheSize();
+
+    @ManagedOperation(description = "Purges the cache")
+    void purge();
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedEndpointRegistryMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedEndpointRegistryMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedErrorHandlerMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedErrorHandlerMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedErrorHandlerMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedErrorHandlerMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,137 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+
+public interface ManagedErrorHandlerMBean {
+
+    @ManagedAttribute(description = "Camel id")
+    String getCamelId();
+
+    @ManagedAttribute(description = "Does the error handler support redelivery")
+    boolean isSupportRedelivery();
+
+    @ManagedAttribute(description = "Is this error handler a dead letter channel")
+    boolean isDeadLetterChannel();
+
+    @ManagedAttribute(description = "When a message is moved to dead letter channel is it the original message or recent message")
+    boolean isDeadLetterUseOriginalMessage();
+
+    @ManagedAttribute(description = "Does this error handler support transactions")
+    boolean isSupportTransactions();
+
+    @ManagedAttribute(description = "Endpoint Uri for the dead letter channel where dead message is move to")
+    String getDeadLetterChannelEndpointUri();
+
+    @ManagedAttribute(description = "RedeliveryPolicy for maximum redeliveries")
+    Integer getMaximumRedeliveries();
+
+    @ManagedAttribute(description = "RedeliveryPolicy for maximum redeliveries")
+    void setMaximumRedeliveries(Integer maximum);
+
+    @ManagedAttribute(description = "RedeliveryPolicy for maximum redelivery delay")
+    Long getMaximumRedeliveryDelay();
+
+    @ManagedAttribute(description = "RedeliveryPolicy for maximum redelivery delay")
+    void setMaximumRedeliveryDelay(Long delay);
+
+    @ManagedAttribute(description = "RedeliveryPolicy for redelivery delay")
+    Long getRedeliveryDelay();
+
+    @ManagedAttribute(description = "RedeliveryPolicy for redelivery delay")
+    void setRedeliveryDelay(Long delay);
+
+    @ManagedAttribute(description = "RedeliveryPolicy for backoff multiplier")
+    Double getBackOffMultiplier();
+
+    @ManagedAttribute(description = "RedeliveryPolicy for backoff multiplier")
+    void setBackOffMultiplier(Double multiplier);
+
+    @ManagedAttribute(description = "RedeliveryPolicy for collision avoidance factor")
+    Double getCollisionAvoidanceFactor();
+
+    @ManagedAttribute(description = "RedeliveryPolicy for collision avoidance factor")
+    void setCollisionAvoidanceFactor(Double factor);
+
+    @ManagedAttribute(description = "RedeliveryPolicy for collision avoidance percent")
+    Double getCollisionAvoidancePercent();
+
+    @ManagedAttribute(description = "RedeliveryPolicy for collision avoidance percent")
+    void setCollisionAvoidancePercent(Double percent);
+
+    @ManagedAttribute(description = "RedeliveryPolicy for delay pattern")
+    String getDelayPattern();
+
+    @ManagedAttribute(description = "RedeliveryPolicy for delay pattern")
+    void setDelayPattern(String pattern);
+
+    @ManagedAttribute(description = "RedeliveryPolicy for logging level when retries exhausted")
+    String getRetriesExhaustedLogLevel();
+
+    @ManagedAttribute(description = "RedeliveryPolicy for logging level when retries exhausted")
+    void setRetriesExhaustedLogLevel(String level);
+
+    @ManagedAttribute(description = "RedeliveryPolicy for logging level when attempting retry")
+    String getRetryAttemptedLogLevel();
+
+    @ManagedAttribute(description = "RedeliveryPolicy for logging level when attempting retry")
+    void setRetryAttemptedLogLevel(String level);
+
+    @ManagedAttribute(description = "RedeliveryPolicy for logging stack traces")
+    Boolean getLogStackTrace();
+
+    @ManagedAttribute(description = "RedeliveryPolicy for logging stack traces")
+    void setLogStackTrace(Boolean log);
+
+    @ManagedAttribute(description = "RedeliveryPolicy for logging redelivery stack traces")
+    Boolean getLogRetryStackTrace();
+
+    @ManagedAttribute(description = "RedeliveryPolicy for logging redelivery stack traces")
+    void setLogRetryStackTrace(Boolean log);
+
+    @ManagedAttribute(description = "RedeliveryPolicy for logging handled exceptions")
+    Boolean getLogHandled();
+
+    @ManagedAttribute(description = "RedeliveryPolicy for logging handled exceptions")
+    void setLogHandled(Boolean log);
+
+    @ManagedAttribute(description = "RedeliveryPolicy for logging handled and continued exceptions")
+    Boolean getLogContinued();
+
+    @ManagedAttribute(description = "RedeliveryPolicy for logging handled and continued exceptions")
+    void setLogContinued(Boolean log);
+
+    @ManagedAttribute(description = "RedeliveryPolicy for logging exhausted exceptions")
+    Boolean getLogExhausted();
+
+    @ManagedAttribute(description = "RedeliveryPolicy for logging exhausted exceptions")
+    void setLogExhausted(Boolean log);
+
+    @ManagedAttribute(description = "RedeliveryPolicy for using collision avoidance")
+    Boolean getUseCollisionAvoidance();
+
+    @ManagedAttribute(description = "RedeliveryPolicy for using collision avoidance")
+    void setUseCollisionAvoidance(Boolean avoidance);
+
+    @ManagedAttribute(description = "RedeliveryPolicy for using exponential backoff")
+    Boolean getUseExponentialBackOff();
+
+    @ManagedAttribute(description = "RedeliveryPolicy for using exponential backoff")
+    void setUseExponentialBackOff(Boolean backoff);
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedErrorHandlerMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedErrorHandlerMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedPerformanceCounterMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedPerformanceCounterMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedPerformanceCounterMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedPerformanceCounterMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,74 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import java.util.Date;
+
+import org.apache.camel.api.management.ManagedAttribute;
+import org.apache.camel.api.management.ManagedOperation;
+
+public interface ManagedPerformanceCounterMBean {
+
+    @ManagedOperation(description = "Reset counters")
+    void reset();
+
+    @ManagedAttribute(description = "Number of completed exchanges")
+    long getExchangesCompleted() throws Exception;
+
+    @ManagedAttribute(description = "Number of failed exchanges")
+    long getExchangesFailed() throws Exception;
+
+    @ManagedAttribute(description = "Number of failures handled")
+    long getFailuresHandled() throws Exception;
+
+    @ManagedAttribute(description = "Number of redeliveries")
+    long getRedeliveries() throws Exception;
+
+    @ManagedAttribute(description = "Min Processing Time [milliseconds]")
+    long getMinProcessingTime() throws Exception;
+
+    @ManagedAttribute(description = "Mean Processing Time [milliseconds]")
+    long getMeanProcessingTime() throws Exception;
+
+    @ManagedAttribute(description = "Max Processing Time [milliseconds]")
+    long getMaxProcessingTime() throws Exception;
+
+    @ManagedAttribute(description = "Total Processing Time [milliseconds]")
+    long getTotalProcessingTime() throws Exception;
+
+    @ManagedAttribute(description = "Last Processing Time [milliseconds]")
+    long getLastProcessingTime() throws Exception;
+
+    @ManagedAttribute(description = "Last Exchange Completed Timestamp")
+    Date getLastExchangeCompletedTimestamp();
+
+    @ManagedAttribute(description = "First Exchange Completed Timestamp")
+    Date getFirstExchangeCompletedTimestamp();
+
+    @ManagedAttribute(description = "Last Exchange Failed Timestamp")
+    Date getLastExchangeFailureTimestamp();
+
+    @ManagedAttribute(description = "First Exchange Failed Timestamp")
+    Date getFirstExchangeFailureTimestamp();
+
+    @ManagedAttribute(description = "Statistics enabled")
+    boolean isStatisticsEnabled();
+
+    @ManagedAttribute(description = "Statistics enabled")
+    void setStatisticsEnabled(boolean statisticsEnabled);
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedPerformanceCounterMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedPerformanceCounterMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProcessorMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProcessorMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProcessorMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProcessorMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,42 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+import org.apache.camel.api.management.ManagedOperation;
+
+public interface ManagedProcessorMBean {
+
+    @ManagedAttribute(description = "Processor State")
+    String getState();
+
+    @ManagedAttribute(description = "Camel id")
+    String getCamelId();
+
+    @ManagedAttribute(description = "Route id")
+    String getRouteId();
+
+    @ManagedAttribute(description = "Processor id")
+    String getProcessorId();
+
+    @ManagedOperation(description = "Start Processor")
+    void start() throws Exception;
+
+    @ManagedOperation(description = "Stop Processor")
+    void stop() throws Exception;
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProcessorMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProcessorMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProducerCacheMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProducerCacheMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProducerCacheMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProducerCacheMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,45 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+import org.apache.camel.api.management.ManagedOperation;
+
+public interface ManagedProducerCacheMBean {
+
+    @ManagedAttribute(description = "Source")
+    String getSource();
+
+    @ManagedAttribute(description = "Number of elements cached")
+    Integer getSize();
+
+    @ManagedAttribute(description = "Maximum cache size (capacity)")
+    Integer getMaximumCacheSize();
+
+    @ManagedAttribute(description = "Cache hits")
+    Long getHits();
+
+    @ManagedAttribute(description = "Cache misses")
+    Long getMisses();
+
+    @ManagedOperation(description = "Reset cache statistics")
+    void resetStatistics();
+
+    @ManagedOperation(description = "Purges the cache")
+    void purge();
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProducerCacheMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProducerCacheMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProducerMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProducerMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProducerMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProducerMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,29 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+
+public interface ManagedProducerMBean {
+
+    @ManagedAttribute(description = "Endpoint Uri")
+    String getEndpointUri();
+
+    @ManagedAttribute(description = "Singleton")
+    boolean isSingleton();
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProducerMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProducerMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedRouteMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedRouteMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedRouteMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedRouteMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,95 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+import org.apache.camel.api.management.ManagedOperation;
+
+public interface ManagedRouteMBean {
+
+    @ManagedAttribute(description = "Route id")
+    String getRouteId();
+
+    @ManagedAttribute(description = "Route Description")
+    String getDescription();
+
+    @ManagedAttribute(description = "Route Endpoint Uri")
+    String getEndpointUri();
+
+    @ManagedAttribute(description = "Route State")
+    String getState();
+
+    @ManagedAttribute(description = "Current number of inflight Exchanges")
+    Integer getInflightExchanges();
+
+    @ManagedAttribute(description = "Camel id")
+    String getCamelId();
+
+    @ManagedAttribute(description = "Tracing")
+    Boolean getTracing();
+
+    @ManagedAttribute(description = "Tracing")
+    void setTracing(Boolean tracing);
+
+    @ManagedAttribute(description = "Route Policy List")
+    String getRoutePolicyList();
+
+    @ManagedAttribute(description = "Average load over the last minute")
+    String getLoad01();
+
+    @ManagedAttribute(description = "Average load over the last five minutes")
+    String getLoad05();
+
+    @ManagedAttribute(description = "Average load over the last fifteen minutes")
+    String getLoad15();
+
+    @ManagedOperation(description = "Start route")
+    void start() throws Exception;
+
+    @ManagedOperation(description = "Stop route")
+    void stop() throws Exception;
+
+    @ManagedOperation(description = "Stop route (using timeout in seconds)")
+    void stop(long timeout) throws Exception;
+
+    @ManagedOperation(description = "Stop route, abort stop after timeout (in seconds)")
+    boolean stop(Long timeout, Boolean abortAfterTimeout) throws Exception;
+
+    /**
+     * @deprecated will be removed in the near future. Use stop and remove instead
+     */
+    @ManagedOperation(description = "Shutdown route")
+    @Deprecated
+    void shutdown() throws Exception;
+
+    /**
+     * @deprecated will be removed in the near future. Use stop and remove instead
+     */
+    @ManagedOperation(description = "Shutdown route (using timeout in seconds)")
+    @Deprecated
+    void shutdown(long timeout) throws Exception;
+
+    @ManagedOperation(description = "Remove route (must be stopped)")
+    boolean remove() throws Exception;
+
+    @ManagedOperation(description = "Dumps the route as XML")
+    String dumpRouteAsXml() throws Exception;
+
+    @ManagedOperation(description = "Updates the route from XML")
+    void updateRouteFromXml(String xml) throws Exception;
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedRouteMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedRouteMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSchedulePollConsumerMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSchedulePollConsumerMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSchedulePollConsumerMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSchedulePollConsumerMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,47 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+
+public interface ManagedSchedulePollConsumerMBean {
+
+    @ManagedAttribute(description = "Scheduled Delay")
+    long getDelay();
+
+    @ManagedAttribute(description = "Scheduled Delay")
+    void setDelay(long delay);
+
+    @ManagedAttribute(description = "Scheduled Initial Delay")
+    long getInitialDelay();
+
+    @ManagedAttribute(description = "Scheduled Initial Delay")
+    void setInitialDelay(long initialDelay);
+
+    @ManagedAttribute(description = "Scheduled Fixed Delay")
+    boolean isUseFixedDelay();
+
+    @ManagedAttribute(description = "Scheduled Fixed Delay")
+    void setUseFixedDelay(boolean useFixedDelay);
+
+    @ManagedAttribute(description = "Scheduled TimeUnit")
+    String getTimeUnit();
+
+    @ManagedAttribute(description = "Scheduled TimeUnit")
+    void setTimeUnit(String timeUnit);
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSchedulePollConsumerMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSchedulePollConsumerMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSendProcessorMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSendProcessorMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSendProcessorMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSendProcessorMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,32 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+
+public interface ManagedSendProcessorMBean {
+
+    @ManagedAttribute(description = "Destination as Endpoint Uri")
+    String getDestination();
+
+    @ManagedAttribute(description = "Destination as Endpoint Uri")
+    void setDestination(String uri);
+
+    @ManagedAttribute(description = "Message Exchange Pattern")
+    String getMessageExchangePattern();
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSendProcessorMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSendProcessorMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedServiceMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedServiceMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedServiceMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedServiceMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,51 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+import org.apache.camel.api.management.ManagedOperation;
+
+public interface ManagedServiceMBean {
+
+    @ManagedAttribute(description = "Service State")
+    String getState();
+
+    @ManagedAttribute(description = "Camel id")
+    String getCamelId();
+
+    @ManagedAttribute(description = "Route id")
+    String getRouteId();
+
+    @ManagedOperation(description = "Start Service")
+    void start() throws Exception;
+
+    @ManagedOperation(description = "Stop Service")
+    void stop() throws Exception;
+
+    @ManagedAttribute(description = "Whether this service supports suspension")
+    boolean isSupportSuspension();
+
+    @ManagedAttribute(description = "Whether this service is suspended")
+    boolean isSuspended();
+
+    @ManagedOperation(description = "Suspend Service")
+    void suspend() throws Exception;
+
+    @ManagedOperation(description = "Resume Service")
+    void resume() throws Exception;
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedServiceMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedServiceMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSuspendableRouteMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSuspendableRouteMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSuspendableRouteMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSuspendableRouteMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,32 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedOperation;
+
+public interface ManagedSuspendableRouteMBean {
+
+    @ManagedOperation(description = "Suspend route")
+    void suspend() throws Exception;
+
+    @ManagedOperation(description = "Suspend route (using timeout in seconds)")
+    void suspend(long timeout) throws Exception;
+
+    @ManagedOperation(description = "Resume Route")
+    void resume() throws Exception;
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSuspendableRouteMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedSuspendableRouteMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThreadPoolMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThreadPoolMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThreadPoolMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThreadPoolMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,81 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+import org.apache.camel.api.management.ManagedOperation;
+
+public interface ManagedThreadPoolMBean {
+
+    @ManagedAttribute(description = "Thread Pool id")
+    String getId();
+
+    @ManagedAttribute(description = "Id of source for creating Thread Pool")
+    String getSourceId();
+
+    @ManagedAttribute(description = "Route id for the source, which created the Thread Pool")
+    String getRouteId();
+
+    @ManagedAttribute(description = "Id of the thread pool profile which this pool is based upon")
+    String getThreadPoolProfileId();
+
+    @ManagedAttribute(description = "Core pool size")
+    int getCorePoolSize();
+
+    @ManagedAttribute(description = "Core pool size")
+    void setCorePoolSize(int corePoolSize);
+
+    @ManagedAttribute(description = "Pool size")
+    int getPoolSize();
+
+    @ManagedAttribute(description = "Maximum pool size")
+    int getMaximumPoolSize();
+
+    @ManagedAttribute(description = "Maximum pool size")
+    void setMaximumPoolSize(int maximumPoolSize);
+
+    @ManagedAttribute(description = "Largest pool size")
+    int getLargestPoolSize();
+
+    @ManagedAttribute(description = "Active count")
+    int getActiveCount();
+
+    @ManagedAttribute(description = "Task count")
+    long getTaskCount();
+
+    @ManagedAttribute(description = "Completed task count")
+    long getCompletedTaskCount();
+
+    @ManagedAttribute(description = "Task queue size")
+    long getTaskQueueSize();
+
+    @ManagedAttribute(description = "Is task queue empty")
+    boolean isTaskQueueEmpty();
+
+    @ManagedAttribute(description = "Keep alive time in seconds")
+    long getKeepAliveTime();
+
+    @ManagedAttribute(description = "Keep alive time in seconds")
+    void setKeepAliveTime(long keepAliveTimeInSeconds);
+
+    @ManagedAttribute(description = "Is shutdown")
+    boolean isShutdown();
+
+    @ManagedOperation(description = "Purges the pool")
+    void purge();
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThreadPoolMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThreadPoolMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThrottlerMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThrottlerMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThrottlerMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThrottlerMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,35 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+
+public interface ManagedThrottlerMBean {
+
+    @ManagedAttribute(description = "Maximum requires per period")
+    long getMaximumRequestsPerPeriod();
+
+    @ManagedAttribute(description = "Maximum requires per period")
+    void setMaximumRequestsPerPeriod(long maximumRequestsPerPeriod);
+
+    @ManagedAttribute(description = "Time period in millis")
+    long getTimePeriodMillis();
+
+    @ManagedAttribute(description = "Time period in millis")
+    void setTimePeriodMillis(long timePeriodMillis);
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThrottlerMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThrottlerMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThrottlingInflightRoutePolicyMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThrottlingInflightRoutePolicyMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThrottlingInflightRoutePolicyMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThrottlingInflightRoutePolicyMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,47 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+
+public interface ManagedThrottlingInflightRoutePolicyMBean {
+
+    @ManagedAttribute(description = "Maximum inflight exchanges")
+    int getMaxInflightExchanges();
+
+    @ManagedAttribute(description = "Maximum inflight exchanges")
+    void setMaxInflightExchanges(int maxInflightExchanges);
+
+    @ManagedAttribute(description = "Resume percentage of maximum inflight exchanges")
+    int getResumePercentOfMax();
+
+    @ManagedAttribute(description = "Resume percentage of maximum inflight exchanges")
+    void setResumePercentOfMax(int resumePercentOfMax);
+
+    @ManagedAttribute(description = "Scope")
+    String getScope();
+
+    @ManagedAttribute(description = "Scope")
+    void setScope(String scope);
+
+    @ManagedAttribute(description = "Logging Level")
+    String getLoggingLevel();
+
+    @ManagedAttribute(description = "Logging Level")
+    void setLoggingLevel(String loggingLevel);
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThrottlingInflightRoutePolicyMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedThrottlingInflightRoutePolicyMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Added: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedTracerMBean.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedTracerMBean.java?rev=1210806&view=auto
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedTracerMBean.java (added)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedTracerMBean.java Tue Dec  6 07:29:02 2011
@@ -0,0 +1,188 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.api.management.mbean;
+
+import org.apache.camel.api.management.ManagedAttribute;
+
+public interface ManagedTracerMBean {
+
+    @ManagedAttribute(description = "Tracer enabled")
+    boolean getEnabled();
+
+    @ManagedAttribute(description = "Tracer enabled")
+    void setEnabled(boolean enabled);
+
+    @ManagedAttribute(description = "Additional destination Uri")
+    String getDestinationUri();
+
+    @ManagedAttribute(description = "Additional destination Uri")
+    void setDestinationUri(String uri);
+
+    @ManagedAttribute(description = "Logging Name")
+    String getLogName();
+
+    @ManagedAttribute(description = "Using Jpa")
+    boolean getUseJpa();
+
+    @ManagedAttribute(description = "Logging Name")
+    void setLogName(String logName);
+
+    @ManagedAttribute(description = "Logging Level")
+    String getLogLevel();
+
+    @ManagedAttribute(description = "Logging Level")
+    void setLogLevel(String logLevel);
+
+    @ManagedAttribute(description = "Log Stacktrace")
+    boolean getLogStackTrace();
+
+    @ManagedAttribute(description = "Log Stacktrace")
+    void setLogStackTrace(boolean logStackTrace);
+
+    @ManagedAttribute(description = "Trace Interceptors")
+    boolean getTraceInterceptors();
+
+    @ManagedAttribute(description = "Trace Interceptors")
+    void setTraceInterceptors(boolean traceInterceptors);
+
+    @ManagedAttribute(description = "Trace Exceptions")
+    boolean getTraceExceptions();
+
+    @ManagedAttribute(description = "Trace Exceptions")
+    void setTraceExceptions(boolean traceExceptions);
+
+    @ManagedAttribute(description = "Trace Out Exchanges")
+    boolean getTraceOutExchanges();
+
+    @ManagedAttribute(description = "Trace Out Exchanges")
+    void setTraceOutExchanges(boolean traceOutExchanges);
+
+    @ManagedAttribute(description = "Formatter show body")
+    boolean getFormatterShowBody();
+
+    @ManagedAttribute(description = "Formatter show body")
+    void setFormatterShowBody(boolean showBody);
+
+    @ManagedAttribute(description = "Formatter show body type")
+    boolean getFormatterShowBodyType();
+
+    @ManagedAttribute(description = "Formatter show body type")
+    void setFormatterShowBodyType(boolean showBodyType);
+
+    @ManagedAttribute(description = "Formatter show out body")
+    boolean getFormatterShowOutBody();
+
+    @ManagedAttribute(description = "Formatter show out body")
+    void setFormatterShowOutBody(boolean showOutBody);
+
+    @ManagedAttribute(description = "Formatter show out body type")
+    boolean getFormatterShowOutBodyType();
+
+    @ManagedAttribute(description = "Formatter show out body type")
+    void setFormatterShowOutBodyType(boolean showOutBodyType);
+
+    @ManagedAttribute(description = "Formatter show breadcrumb")
+    boolean getFormatterShowBreadCrumb();
+
+    @ManagedAttribute(description = "Formatter show breadcrumb")
+    void setFormatterShowBreadCrumb(boolean showBreadCrumb);
+
+    @ManagedAttribute(description = "Formatter show exchange id")
+    boolean getFormatterShowExchangeId();
+
+    @ManagedAttribute(description = "Formatter show exchange id")
+    void setFormatterShowExchangeId(boolean showExchangeId);
+
+    @ManagedAttribute(description = "Formatter show headers")
+    boolean getFormatterShowHeaders();
+
+    @ManagedAttribute(description = "Formatter show headers")
+    void setFormatterShowHeaders(boolean showHeaders);
+
+    @ManagedAttribute(description = "Formatter show out headers")
+    boolean getFormatterShowOutHeaders();
+
+    @ManagedAttribute(description = "Formatter show out headers")
+    void setFormatterShowOutHeaders(boolean showOutHeaders);
+
+    @ManagedAttribute(description = "Formatter show properties")
+    boolean getFormatterShowProperties();
+
+    @ManagedAttribute(description = "Formatter show properties")
+    void setFormatterShowProperties(boolean showProperties);
+
+    @ManagedAttribute(description = "Formatter show node")
+    boolean getFormatterShowNode();
+
+    @ManagedAttribute(description = "Formatter show node")
+    void setFormatterShowNode(boolean showNode);
+
+    @ManagedAttribute(description = "Formatter show exchange pattern")
+    boolean getFormatterShowExchangePattern();
+
+    @ManagedAttribute(description = "Formatter show exchange pattern")
+    void setFormatterShowExchangePattern(boolean showExchangePattern);
+
+    @ManagedAttribute(description = "Formatter show exception")
+    boolean getFormatterShowException();
+
+    @ManagedAttribute(description = "Formatter show exception")
+    void setFormatterShowException(boolean showException);
+
+    @ManagedAttribute(description = "Formatter show route id")
+    boolean getFormatterShowRouteId();
+
+    @ManagedAttribute(description = "Formatter show route id")
+    void setFormatterShowRouteId(boolean showRouteId);
+
+    @ManagedAttribute(description = "Formatter breadcrumb length")
+    int getFormatterBreadCrumbLength();
+
+    @ManagedAttribute(description = "Formatter breadcrumb length")
+    void setFormatterBreadCrumbLength(int breadCrumbLength);
+
+    @ManagedAttribute(description = "Formatter show short exchange id")
+    boolean getFormatterShowShortExchangeId();
+
+    @ManagedAttribute(description = "Formatter show short exchange id")
+    void setFormatterShowShortExchangeId(boolean showShortExchangeId);
+
+    @ManagedAttribute(description = "Formatter node length")
+    int getFormatterNodeLength();
+
+    @ManagedAttribute(description = "Formatter node length")
+    void setFormatterNodeLength(int nodeLength);
+
+    @ManagedAttribute(description = "Formatter max chars")
+    int getFormatterMaxChars();
+
+    @ManagedAttribute(description = "Formatter max chars")
+    void setFormatterMaxChars(int maxChars);
+
+    @ManagedAttribute(description = "Should trace events be sent as jmx notifications")
+    boolean isJmxTraceNotifications();
+
+    @ManagedAttribute(description = "Should trace events be sent as jmx notifications")
+    void setJmxTraceNotifications(boolean jmxTraceNotifications);
+
+    @ManagedAttribute(description = "Maximum size of a message body for trace notification")
+    int getTraceBodySize();
+
+    @ManagedAttribute(description = "Maximum size of a message body for trace notification")
+    void setTraceBodySize(int traceBodySize);
+
+}
\ No newline at end of file

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedTracerMBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedTracerMBean.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date