You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2015/06/22 09:26:16 UTC
[2/3] camel git commit: Component docs
Component docs
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/67505910
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/67505910
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/67505910
Branch: refs/heads/master
Commit: 67505910e9788a4361d6d9c42c32bc052f32edab
Parents: 90d337e
Author: Claus Ibsen <da...@apache.org>
Authored: Mon Jun 22 09:28:28 2015 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Mon Jun 22 09:28:28 2015 +0200
----------------------------------------------------------------------
.../component/twitter/TwitterEndpointDirect.java | 6 ++----
.../component/twitter/TwitterEndpointEvent.java | 15 ++++++++-------
2 files changed, 10 insertions(+), 11 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/67505910/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java
----------------------------------------------------------------------
diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java
index 2c6103f..bc5b350 100644
--- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java
+++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java
@@ -26,16 +26,14 @@ import org.apache.camel.component.direct.DirectEndpoint;
import org.apache.camel.component.twitter.consumer.Twitter4JConsumer;
import org.apache.camel.component.twitter.consumer.TwitterConsumerDirect;
import org.apache.camel.component.twitter.data.EndpointType;
-import org.apache.camel.spi.UriEndpoint;
-import org.apache.camel.spi.UriParam;
/**
* Twitter direct endpoint
*/
-@UriEndpoint(scheme = "twitter", title = "Twitter", syntax = "twitter:type", consumerClass = Twitter4JConsumer.class, label = "api,social")
public class TwitterEndpointDirect extends DirectEndpoint implements TwitterEndpoint {
- @UriParam
+ // only TwitterEndpointPolling is annotated
+
private TwitterConfiguration properties;
public TwitterEndpointDirect(String uri, TwitterComponent component, TwitterConfiguration properties) {
http://git-wip-us.apache.org/repos/asf/camel/blob/67505910/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointEvent.java
----------------------------------------------------------------------
diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointEvent.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointEvent.java
index a250ceb..0690664 100644
--- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointEvent.java
+++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointEvent.java
@@ -19,17 +19,14 @@ package org.apache.camel.component.twitter;
import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
-import org.apache.camel.component.direct.DirectEndpoint;
import org.apache.camel.component.twitter.consumer.Twitter4JConsumer;
import org.apache.camel.component.twitter.consumer.TwitterConsumerEvent;
import org.apache.camel.component.twitter.data.EndpointType;
-import org.apache.camel.spi.UriEndpoint;
-import org.apache.camel.spi.UriParam;
+import org.apache.camel.impl.DefaultEndpoint;
-@UriEndpoint(scheme = "twitter", title = "Twitter", syntax = "twitter:type", consumerClass = Twitter4JConsumer.class, label = "api,social")
-public class TwitterEndpointEvent extends DirectEndpoint implements TwitterEndpoint {
+public class TwitterEndpointEvent extends DefaultEndpoint implements TwitterEndpoint {
- @UriParam
+ // only TwitterEndpointPolling is annotated
private TwitterConfiguration properties;
public TwitterEndpointEvent(String uri, TwitterComponent component, TwitterConfiguration properties) {
@@ -62,11 +59,15 @@ public class TwitterEndpointEvent extends DirectEndpoint implements TwitterEndpo
}
@Override
+ public boolean isSingleton() {
+ return true;
+ }
+
+ @Override
protected void doStop() throws Exception {
super.doStop();
if (properties.getTwitterStream() != null) {
properties.getTwitterStream().shutdown();
}
}
-
}