+/*
+ * Copyright (C) 2010 Mathieu Baudier <mbaudier@argeo.org>
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
package org.argeo.security.activemq;
import java.io.InputStream;
public final static String AUTHMODE_UI = "ui";
public final static String AUTHMODE_OS = "os";
public final static String AUTHMODE_DEFAULT = AUTHMODE_OS;
-// private final static String LOGIN_CONFIG_PROPERTY = "java.security.auth.login.config";
+ // private final static String LOGIN_CONFIG_PROPERTY =
+ // "java.security.auth.login.config";
private final static Log log = LogFactory
.getLog(SecuredActiveMqConnectionFactory.class);
uccfa.setTargetConnectionFactory(activeMQSslConnectionFactory);
cachingConnectionFactory = new CachingConnectionFactory();
cachingConnectionFactory.setTargetConnectionFactory(uccfa);
+ cachingConnectionFactory.setCacheConsumers(false);
initConnectionFactoryCredentials(uccfa);
cachingConnectionFactory.initConnection();
authenticationMode = AUTHMODE_DEFAULT;
if (AUTHMODE_OS.equals(authenticationMode)) {
-// if (false) {
-// // Cache previous value of login conf location
-// String oldLoginConfLocation = System
-// .getProperty(LOGIN_CONFIG_PROPERTY);
-// // Find OS family
-// String osName = System.getProperty("os.name");
-// final String auth;
-// if (osName.startsWith("Windows"))
-// auth = "Windows";
-// else if (osName.startsWith("SunOS")
-// || osName.startsWith("Solaris"))
-// auth = "Solaris";
-// else
-// auth = "Unix";
-//
-// Subject subject;
-// // see http://old.nabble.com/osgi-and-jaas-td23485885.html
-// ClassLoader ccl = Thread.currentThread()
-// .getContextClassLoader();
-// try {
-// Thread.currentThread().setContextClassLoader(
-// getClass().getClassLoader());
-// URL url = getClass().getResource(
-// "/org/argeo/security/activemq/osLogin.conf");
-//
-// System.setProperty(LOGIN_CONFIG_PROPERTY, url.toString());
-// LoginContext lc = new LoginContext(auth);
-// lc.login();
-// subject = lc.getSubject();
-// } catch (LoginException le) {
-// throw new ArgeoException("OS authentication failed", le);
-// } finally {
-// if (oldLoginConfLocation != null)
-// System.setProperty(LOGIN_CONFIG_PROPERTY,
-// oldLoginConfLocation);
-// Thread.currentThread().setContextClassLoader(ccl);
-// }
-// // Extract user name
-// String osUsername = null;
-// for (Principal principal : subject.getPrincipals()) {
-// String className = principal.getClass().getName();
-// if ("Unix".equals(auth)
-// && "com.sun.security.auth.UnixPrincipal"
-// .equals(className))
-// osUsername = principal.getName();
-// else if ("Windows".equals(auth)
-// && "com.sun.security.auth.NTUserPrincipal"
-// .equals(className))
-// osUsername = principal.getName();
-// else if ("Solaris".equals(auth)
-// && "com.sun.security.auth.SolarisPrincipal"
-// .equals(className))
-// osUsername = principal.getName();
-// }
-//
-// if (osUsername == null)
-// throw new ArgeoException("Could not find OS user name");
-// }
+ // if (false) {
+ // // Cache previous value of login conf location
+ // String oldLoginConfLocation = System
+ // .getProperty(LOGIN_CONFIG_PROPERTY);
+ // // Find OS family
+ // String osName = System.getProperty("os.name");
+ // final String auth;
+ // if (osName.startsWith("Windows"))
+ // auth = "Windows";
+ // else if (osName.startsWith("SunOS")
+ // || osName.startsWith("Solaris"))
+ // auth = "Solaris";
+ // else
+ // auth = "Unix";
+ //
+ // Subject subject;
+ // // see http://old.nabble.com/osgi-and-jaas-td23485885.html
+ // ClassLoader ccl = Thread.currentThread()
+ // .getContextClassLoader();
+ // try {
+ // Thread.currentThread().setContextClassLoader(
+ // getClass().getClassLoader());
+ // URL url = getClass().getResource(
+ // "/org/argeo/security/activemq/osLogin.conf");
+ //
+ // System.setProperty(LOGIN_CONFIG_PROPERTY, url.toString());
+ // LoginContext lc = new LoginContext(auth);
+ // lc.login();
+ // subject = lc.getSubject();
+ // } catch (LoginException le) {
+ // throw new ArgeoException("OS authentication failed", le);
+ // } finally {
+ // if (oldLoginConfLocation != null)
+ // System.setProperty(LOGIN_CONFIG_PROPERTY,
+ // oldLoginConfLocation);
+ // Thread.currentThread().setContextClassLoader(ccl);
+ // }
+ // // Extract user name
+ // String osUsername = null;
+ // for (Principal principal : subject.getPrincipals()) {
+ // String className = principal.getClass().getName();
+ // if ("Unix".equals(auth)
+ // && "com.sun.security.auth.UnixPrincipal"
+ // .equals(className))
+ // osUsername = principal.getName();
+ // else if ("Windows".equals(auth)
+ // && "com.sun.security.auth.NTUserPrincipal"
+ // .equals(className))
+ // osUsername = principal.getName();
+ // else if ("Solaris".equals(auth)
+ // && "com.sun.security.auth.SolarisPrincipal"
+ // .equals(className))
+ // osUsername = principal.getName();
+ // }
+ //
+ // if (osUsername == null)
+ // throw new ArgeoException("Could not find OS user name");
+ // }
uccfa.setUsername(System.getProperty("user.name"));
uccfa.setPassword(null);
new SecureRandom());
} catch (Exception e) {
throw new ArgeoException(
- "Cannot initailize JMS conneciton factory", e);
+ "Cannot initialize JMS connection factory", e);
}
}