You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by jo...@apache.org on 2015/09/21 23:00:15 UTC
flume git commit: FLUME-2095. JMS source with TIBCO
Repository: flume
Updated Branches:
refs/heads/trunk 67189ca84 -> 2cc93b777
FLUME-2095. JMS source with TIBCO
(Michelle Casbon via Johny Rufus)
Project: http://git-wip-us.apache.org/repos/asf/flume/repo
Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/2cc93b77
Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/2cc93b77
Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/2cc93b77
Branch: refs/heads/trunk
Commit: 2cc93b777865195a9bb2329946a14f301213ea3d
Parents: 67189ca
Author: Johny Rufus <jo...@apache.org>
Authored: Mon Sep 21 13:43:50 2015 -0700
Committer: Johny Rufus <jo...@apache.org>
Committed: Mon Sep 21 13:43:50 2015 -0700
----------------------------------------------------------------------
.../main/java/org/apache/flume/source/jms/JMSSource.java | 11 +++++++++++
1 file changed, 11 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flume/blob/2cc93b77/flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java
----------------------------------------------------------------------
diff --git a/flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java b/flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java
index 1d7f60f..c1cc9cf 100644
--- a/flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java
+++ b/flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java
@@ -220,6 +220,17 @@ public class JMSSource extends AbstractPollableSource {
initialContextFactoryName);
contextProperties.setProperty(
javax.naming.Context.PROVIDER_URL, providerUrl);
+
+ // Provide properties for connecting via JNDI
+ if (this.userName.isPresent()) {
+ contextProperties.setProperty(
+ javax.naming.Context.SECURITY_PRINCIPAL, this.userName.get());
+ }
+ if (this.password.isPresent()) {
+ contextProperties.setProperty(
+ javax.naming.Context.SECURITY_CREDENTIALS, this.password.get());
+ }
+
initialContext = initialContextFactory.create(contextProperties);
} catch (NamingException e) {
throw new FlumeException(String.format(