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 <[email protected]> Authored: Mon Sep 21 13:43:50 2015 -0700 Committer: Johny Rufus <[email protected]> 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(
