| /** |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You 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.apache.activemq.security; |
| |
| import javax.jms.InvalidClientIDException; |
| import javax.security.auth.login.AppConfigurationEntry; |
| import javax.security.auth.login.Configuration; |
| import java.util.HashMap; |
| import java.util.concurrent.CopyOnWriteArrayList; |
| |
| import junit.framework.TestCase; |
| |
| import org.apache.activemq.broker.Broker; |
| import org.apache.activemq.broker.ConnectionContext; |
| import org.apache.activemq.broker.StubBroker; |
| import org.apache.activemq.command.ConnectionInfo; |
| |
| public class JaasAuthenticationBrokerTest extends TestCase { |
| StubBroker receiveBroker; |
| |
| JaasAuthenticationBroker authBroker; |
| |
| ConnectionContext connectionContext; |
| ConnectionInfo connectionInfo; |
| |
| CopyOnWriteArrayList<SecurityContext> visibleSecurityContexts; |
| |
| class JaasAuthenticationBrokerTester extends JaasAuthenticationBroker { |
| public JaasAuthenticationBrokerTester(Broker next, String jassConfiguration) { |
| super(next, jassConfiguration); |
| visibleSecurityContexts = securityContexts; |
| } |
| } |
| |
| @Override |
| protected void setUp() throws Exception { |
| receiveBroker = new StubBroker(); |
| |
| authBroker = new JaasAuthenticationBrokerTester(receiveBroker, ""); |
| |
| connectionContext = new ConnectionContext(); |
| connectionInfo = new ConnectionInfo(); |
| } |
| |
| @Override |
| protected void tearDown() throws Exception { |
| super.tearDown(); |
| } |
| |
| private void setConfiguration(boolean loginShouldSucceed) { |
| HashMap<String, String> configOptions = new HashMap<String, String>(); |
| |
| configOptions.put(StubLoginModule.ALLOW_LOGIN_PROPERTY, loginShouldSucceed ? "true" : "false"); |
| configOptions.put(StubLoginModule.USERS_PROPERTY, ""); |
| configOptions.put(StubLoginModule.GROUPS_PROPERTY, ""); |
| AppConfigurationEntry configEntry = new AppConfigurationEntry("org.apache.activemq.security.StubLoginModule", AppConfigurationEntry.LoginModuleControlFlag.REQUIRED, configOptions); |
| |
| StubJaasConfiguration jaasConfig = new StubJaasConfiguration(configEntry); |
| |
| Configuration.setConfiguration(jaasConfig); |
| } |
| |
| |
| public void testAddConnectionFailureOnDuplicateClientId() throws Exception { |
| setConfiguration(true); |
| |
| connectionInfo.setClientId("CliIdX"); |
| authBroker.addConnection(connectionContext, connectionInfo); |
| ConnectionContext secondContext = connectionContext.copy(); |
| secondContext.setSecurityContext(null); |
| ConnectionInfo secondInfo = connectionInfo.copy(); |
| try { |
| authBroker.addConnection(secondContext, secondInfo); |
| fail("Expect duplicate id"); |
| } catch (InvalidClientIDException expected) { |
| } |
| |
| assertEquals("one connection allowed.", 1, receiveBroker.addConnectionData.size()); |
| assertEquals("one context .", 1, visibleSecurityContexts.size()); |
| |
| } |
| } |