annotate ugi as a parameter (to be passed by beanId)
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/67144c1f Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/67144c1f Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/67144c1f Branch: refs/heads/master Commit: 67144c1f7e7261ab834cedfd30f4fc5b34fe1c92 Parents: e0b3255 Author: woj-i <wojciechin...@gmail.com> Authored: Wed Oct 21 18:10:44 2015 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Tue Nov 24 19:07:55 2015 +0100 ---------------------------------------------------------------------- .../java/org/apache/camel/component/hbase/HBaseEndpoint.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/67144c1f/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java b/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java index 109418c..f89e742 100644 --- a/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java +++ b/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java @@ -68,14 +68,14 @@ public class HBaseEndpoint extends DefaultEndpoint { private HBaseRow rowModel; @UriParam(label = "consumer") private int maxMessagesPerPoll; + @UriParam(description = "UserGroupInformation for HBase communication. If not specified, then Camel talks with HBase without Kerberos") + private UserGroupInformation ugi; /** * in the purpose of performance optimization */ private byte[] tableNameBytes; - private UserGroupInformation ugi = null; - public HBaseEndpoint(String uri, HBaseComponent component, HTablePool tablePool, String tableName) { super(uri, component); this.tableName = tableName;
