Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-1580 this is a beanfactory that knows how to factory an SSL XMPPConnection (as opposed to the regular XmppConnectionFactory)

Browse Source
This commit is contained in:
Josh Long
2010-11-02 16:35:56 -07:00
parent daaa8dfc0b
commit d6891a2ea2
1 changed files with 34 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files

72
spring-integration-xmpp/src/main/java/org/springframework/integration/xmpp/SslXmppConnectionFactory.java
View File

@@ -1,9 +1,7 @@
package org.springframework.integration.xmpp;
import org.jivesoftware.smack.ConnectionConfiguration;
import org.springframework.core.io.Resource;
import org.springframework.util.Assert;
import org.springframework.util.StringUtils;
@@ -19,89 +17,87 @@ import javax.net.ssl.SSLSocketFactory;
* @author Josh Long
*/
public class SslXmppConnectionFactory extends XmppConnectionFactory {
private volatile String trustStorePassword;
private volatile String trustStoreType;
private volatile Resource trustStore;
private volatile boolean securityEnabled = true ;
private volatile SocketFactory socketFactory;
private volatile String trustStorePassword;
private volatile String trustStoreType;
private volatile Resource trustStore;
private volatile boolean securityEnabled = true;
private volatile SocketFactory socketFactory;
private volatile ConnectionConfiguration.SecurityMode securityMode = ConnectionConfiguration.SecurityMode.enabled;
/**
* This method is a callback provided by the super type that lets us plugin to the configuration mechanism
*
* @param connectionConfiguration the connection Configuration
* @param connectionConfiguration the connection Configuration
* @throws Exception
*/
@Override
protected void setupConnectionConfiguration( ConnectionConfiguration connectionConfiguration) throws Exception {
@Override
protected void setupConnectionConfiguration(ConnectionConfiguration connectionConfiguration) throws Exception {
this.securityEnabled = securityMode != null &&
(ConnectionConfiguration.SecurityMode.enabled.equals(securityMode)||
ConnectionConfiguration.SecurityMode.required.equals(securityMode) );
(ConnectionConfiguration.SecurityMode.enabled.equals(securityMode) ||
ConnectionConfiguration.SecurityMode.required.equals(securityMode));
if (this.securityEnabled) {
if (this.socketFactory == null) {
this.socketFactory = SSLSocketFactory.getDefault();
}
if (this.securityEnabled) {
if (this.socketFactory == null) {
this.socketFactory = SSLSocketFactory.getDefault();
}
Assert.notNull(this.trustStore, "'trustStore' must not be null");
Assert.notNull(this.trustStore, "'trustStore' must not be null");
String trustStorePath = this.trustStore.toString();
connectionConfiguration.setTruststorePath( trustStorePath);
connectionConfiguration.setTruststorePath(trustStorePath);
// not required
if(StringUtils.hasText( this.trustStorePassword))
if (StringUtils.hasText(this.trustStorePassword))
connectionConfiguration.setTruststorePassword(this.trustStorePassword);
// not required
if(StringUtils.hasText(this.trustStoreType))
connectionConfiguration.setTruststoreType( this.trustStoreType);
}
}
if (StringUtils.hasText(this.trustStoreType))
connectionConfiguration.setTruststoreType(this.trustStoreType);
}
}
/**
* Not required. If not specified, we will load reference using {@link javax.net.ssl.SSLSocketFactory#getDefault()}
*
* @param socketFactory the socket factory to be passed to the {@link org.jivesoftware.smack.ConnectionConfiguration}
*
*/
public void setSocketFactory(SocketFactory socketFactory) {
this.socketFactory = socketFactory;
}
public void setSocketFactory(SocketFactory socketFactory) {
this.socketFactory = socketFactory;
}
/**
* the password to use to access the trust store (optional)
*
* @param trustStorePassword
*/
public void setTrustStorePassword(String trustStorePassword) {
this.trustStorePassword = trustStorePassword;
}
public void setTrustStorePassword(String trustStorePassword) {
this.trustStorePassword = trustStorePassword;
}
/**
* This is required and specifies the path to the keystore (ie: /path/to/foo.jks)
*
* @param trustStore a {@link org.springframework.core.io.Resource} to the path itself
*
*/
public void setTrustStore(Resource trustStore) {
this.trustStore = trustStore;
}
public void setTrustStore(Resource trustStore) {
this.trustStore = trustStore;
}
/**
* the type of trust store.
*
* @param trustStoreType the type of trust store
*/
public void setTrustStoreType(String trustStoreType) {
this.trustStoreType = trustStoreType;
}
public void setTrustStoreType(String trustStoreType) {
this.trustStoreType = trustStoreType;
}
/**
* used on {@link org.jivesoftware.smack.ConnectionConfiguration#setSecurityMode(org.jivesoftware.smack.ConnectionConfiguration.SecurityMode)}
*
* <p/>
* basically, if you're using this class we assume you want security enabled. If you don't you can always override it by specifying {@link org.jivesoftware.smack.ConnectionConfiguration.SecurityMode#disabled}
*/
public void setSecurityMode(ConnectionConfiguration.SecurityMode securityMode) {