import org.apache.activemq.ActiveMQSslConnectionFactory; //导入依赖的package包/类
@Override
    protected void initConnectionFactory(javax.jms.ConnectionFactory connectionFactory) {
        ActiveMQSslConnectionFactory activeMQConnectionFactory = (ActiveMQSslConnectionFactory) connectionFactory;//NOSONAR

        // TODO: Setup
//        activeMQConnectionFactory.setConnectionURLs(destinationUrl);

//        activeMQConnectionFactory.setLoadBalancing(loadBalancing);
//        activeMQConnectionFactory.setSequential(sequential);
//        activeMQConnectionFactory.setDurableMessageOrder(durableMessageOrder);
//        activeMQConnectionFactory.setFaultTolerant(faultTolerant);
//        activeMQConnectionFactory.setFaultTolerantReconnectTimeout(faultTolerantReconnectTimeoutSeconds);
//        activeMQConnectionFactory.setSocketConnectTimeout(socketConnectTimeoutSeconds * 1000);
//        activeMQConnectionFactory.setInitialConnectTimeout(initialConnectTimeoutInSeconds);
//        activeMQConnectionFactory.setReconnectTimeout(reconnectTimeoutInMinutes);
//        activeMQConnectionFactory.setMonitorInterval(monitorIntervalInSeconds);
//        activeMQConnectionFactory.setPingInterval(pingIntervalInSeconds);
    }
 

import org.apache.activemq.ActiveMQSslConnectionFactory; //导入依赖的package包/类
@Test
public void testJAASSecurityManagerAuthenticationWithCertsAndOpenWire() throws Exception {
   ActiveMQJAASSecurityManager securityManager = new ActiveMQJAASSecurityManager("CertLogin");
   ActiveMQServer server = addServer(ActiveMQServers.newActiveMQServer(createDefaultInVMConfig().setSecurityEnabled(true), ManagementFactory.getPlatformMBeanServer(), securityManager, false));

   Map<String, Object> params = new HashMap<>();
   params.put(TransportConstants.SSL_ENABLED_PROP_NAME, true);
   params.put(TransportConstants.KEYSTORE_PATH_PROP_NAME, "server-side-keystore.jks");
   params.put(TransportConstants.KEYSTORE_PASSWORD_PROP_NAME, "secureexample");
   params.put(TransportConstants.TRUSTSTORE_PATH_PROP_NAME, "server-side-truststore.jks");
   params.put(TransportConstants.TRUSTSTORE_PASSWORD_PROP_NAME, "secureexample");
   params.put(TransportConstants.NEED_CLIENT_AUTH_PROP_NAME, true);

   server.getConfiguration().addAcceptorConfiguration(new TransportConfiguration(NETTY_ACCEPTOR_FACTORY, params));

   server.start();

   ActiveMQSslConnectionFactory factory = new ActiveMQSslConnectionFactory("ssl://localhost:61616");
   factory.setTrustStore("client-side-truststore.jks");
   factory.setTrustStorePassword("secureexample");
   factory.setKeyStore("client-side-keystore.jks");
   factory.setKeyStorePassword("secureexample");

   try (ActiveMQConnection connection = (ActiveMQConnection) factory.createConnection()) {
      Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
      session.close();
   } catch (Throwable e) {
      e.printStackTrace();
      Assert.fail("should not throw exception");
   }
}
 

import org.apache.activemq.ActiveMQSslConnectionFactory; //导入依赖的package包/类
private ActiveMQConnectionFactory createConnectionFactory(String username, String password, String completeBrokerUrl) {

		ActiveMQSslConnectionFactory reliableConnectionFactory = new ActiveMQSslConnectionFactory();
		
		// dummy trust manager
//		reliableConnectionFactory.setKeyAndTrustManagers(null, new TrustManager[] {new X509TrustManager() {
//
//			
//			public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {
//			}
//
//			public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {
//			}
//
//			public X509Certificate[] getAcceptedIssuers() {
//				return null;
//			}}}, new SecureRandom());
//		}
		
		reliableConnectionFactory.setUserName(username);
		reliableConnectionFactory.setPassword(password);
		reliableConnectionFactory.setBrokerURL(completeBrokerUrl);
		

		reliableConnectionFactory.setWatchTopicAdvisories(false);
		return reliableConnectionFactory;
	}
 

import org.apache.activemq.ActiveMQSslConnectionFactory; //导入依赖的package包/类
public ActiveMQEventTransportImpl() throws JMSException {
    this(new ActiveMQSslConnectionFactory());
}