Repository: flume Updated Branches: refs/heads/flume-1.7 22083176c -> 7bfdc46fb
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/7bfdc46f Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/7bfdc46f Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/7bfdc46f Branch: refs/heads/flume-1.7 Commit: 7bfdc46fb897ee6a88a4713993f49e8d11ca1083 Parents: 2208317 Author: Johny Rufus <[email protected]> Authored: Mon Sep 21 13:43:50 2015 -0700 Committer: Johny Rufus <[email protected]> Committed: Mon Sep 21 14:00:48 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/7bfdc46f/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(
