You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by he...@apache.org on 2014/01/07 21:40:35 UTC
git commit: [JGroups] Improved Javadoc.
Updated Branches:
refs/heads/master 09f389aa6 -> 3f7900382
[JGroups] Improved Javadoc.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3f790038
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3f790038
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3f790038
Branch: refs/heads/master
Commit: 3f790038240316b8319ece83609a8bf37778cf4c
Parents: 09f389a
Author: Henryk Konsek <he...@gmail.com>
Authored: Tue Jan 7 21:40:17 2014 +0100
Committer: Henryk Konsek <he...@gmail.com>
Committed: Tue Jan 7 21:40:17 2014 +0100
----------------------------------------------------------------------
.../apache/camel/component/jgroups/JGroupsProducer.java | 11 +++++++++++
1 file changed, 11 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/3f790038/components/camel-jgroups/src/main/java/org/apache/camel/component/jgroups/JGroupsProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-jgroups/src/main/java/org/apache/camel/component/jgroups/JGroupsProducer.java b/components/camel-jgroups/src/main/java/org/apache/camel/component/jgroups/JGroupsProducer.java
index 5368b2e..b134320 100644
--- a/components/camel-jgroups/src/main/java/org/apache/camel/component/jgroups/JGroupsProducer.java
+++ b/components/camel-jgroups/src/main/java/org/apache/camel/component/jgroups/JGroupsProducer.java
@@ -23,18 +23,27 @@ import org.jgroups.Address;
import org.jgroups.Channel;
import org.jgroups.Message;
+/**
+ * Producer sending messages to the JGroups cluster.
+ */
public class JGroupsProducer extends DefaultProducer {
+ // Producer settings
+
private final Channel channel;
private final String clusterName;
+ // Constructor
+
public JGroupsProducer(Endpoint endpoint, Channel channel, String clusterName) {
super(endpoint);
this.channel = channel;
this.clusterName = clusterName;
}
+ // Life cycle callbacks
+
@Override
protected void doStart() throws Exception {
super.doStart();
@@ -47,6 +56,8 @@ public class JGroupsProducer extends DefaultProducer {
super.doStop();
}
+ // Processing logic
+
@Override
public void process(Exchange exchange) throws Exception {
Object body = exchange.getIn().getBody();