import org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter; //导入依赖的package包/类
/**
 * This method essentially performs initialization of this Processor by
 * obtaining an instance of the {@link ConnectionFactory} from the
 * {@link JMSConnectionFactoryProvider} (ControllerService) and performing a
 * series of {@link ConnectionFactory} adaptations which eventually results
 * in an instance of the {@link CachingConnectionFactory} used to construct
 * {@link JmsTemplate} used by this Processor.
 */
private void buildTargetResource(ProcessContext context) {
    if (this.targetResource == null) {
        JMSConnectionFactoryProviderDefinition cfProvider = context.getProperty(CF_SERVICE).asControllerService(JMSConnectionFactoryProviderDefinition.class);
        ConnectionFactory connectionFactory = cfProvider.getConnectionFactory();

        UserCredentialsConnectionFactoryAdapter cfCredentialsAdapter = new UserCredentialsConnectionFactoryAdapter();
        cfCredentialsAdapter.setTargetConnectionFactory(connectionFactory);
        cfCredentialsAdapter.setUsername(context.getProperty(USER).getValue());
        cfCredentialsAdapter.setPassword(context.getProperty(PASSWORD).getValue());

        this.cachingConnectionFactory = new CachingConnectionFactory(cfCredentialsAdapter);
        this.cachingConnectionFactory.setSessionCacheSize(Integer.parseInt(context.getProperty(SESSION_CACHE_SIZE).getValue()));

        JmsTemplate jmsTemplate = new JmsTemplate();
        jmsTemplate.setConnectionFactory(this.cachingConnectionFactory);
        jmsTemplate.setPubSubDomain(TOPIC.equals(context.getProperty(DESTINATION_TYPE).getValue()));

        // set of properties that may be good candidates for exposure via configuration
        jmsTemplate.setReceiveTimeout(1000);

        this.targetResource = this.finishBuildingTargetResource(jmsTemplate, context);
    }
}
 

import org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter; //导入依赖的package包/类
@Test
public void shouldUseAutoconfigurationToCreateMissingBeanWithCredentials() {
    ctx = new AnnotationConfigApplicationContext();
    Properties properties = new Properties();
    properties.setProperty("spring.hornetq.user", "user");
    ctx.getEnvironment().getPropertySources().addFirst(new PropertiesPropertySource(
            "credentials", properties));
    ctx.register(ClusteredHornetQAutoConfiguration.class);
    ctx.refresh();
    UserCredentialsConnectionFactoryAdapter jmsConnectionFactory = (UserCredentialsConnectionFactoryAdapter) ctx
            .getBean("jmsConnectionFactory");
    assertNotNull(jmsConnectionFactory);

    ConnectionFactory viaType = ctx.getBean(ConnectionFactory.class);
    assertSame(jmsConnectionFactory, viaType);
}
 

import org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter; //导入依赖的package包/类
@Primary
@Bean
UserCredentialsConnectionFactoryAdapter jmsConnectionFactory(
        @NonNull ListableBeanFactory beanFactory,
        @NonNull ClusteredHornetQProperties properties) {
    log.info("creating user credentials wrapper for available HornetQConnectionFactory");
    UserCredentialsConnectionFactoryAdapter secureFactory = new UserCredentialsConnectionFactoryAdapter();
    secureFactory.setUsername(properties.getUser());
    secureFactory.setPassword(properties.getPassword());
    secureFactory.setTargetConnectionFactory(new ClusteredHornetQConnectionFactoryFactory(
            beanFactory, properties).createConnectionFactory(HornetQConnectionFactory.class));
    return secureFactory;
}
 

import org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter; //导入依赖的package包/类
@Test
public void testSetUsernameAndPassword() throws Exception {
    JmsEndpoint endpoint = resolveMandatoryEndpoint("jms:topic:Foo.Bar?username=James&password=ABC", JmsEndpoint.class);
    ConnectionFactory cf = endpoint.getConfiguration().getConnectionFactory();
    assertNotNull("The connectionFactory should not be null", cf);
    assertTrue("The connectionFactory should be the instance of UserCredentialsConnectionFactoryAdapter", cf instanceof UserCredentialsConnectionFactoryAdapter);
}
 

import org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter; //导入依赖的package包/类
@Test
public void testSetConnectionFactoryAndUsernameAndPassword() throws Exception {
    JmsEndpoint endpoint = resolveMandatoryEndpoint("jms:topic:Foo.Bar?connectionFactory=#myConnectionFactory&username=James&password=ABC", JmsEndpoint.class);
    ConnectionFactory cf = endpoint.getConfiguration().getConnectionFactory();
    assertNotNull("The connectionFactory should not be null", cf);
    assertTrue("The connectionFactory should be the instance of UserCredentialsConnectionFactoryAdapter", cf instanceof UserCredentialsConnectionFactoryAdapter);
}