Skip to content

Commit

Permalink
QPID-3788: Remove remaining MINA configuration keys (and those from o…
Browse files Browse the repository at this point in the history
…ther retired impls) from the Java Broker's config.xml

* Remove remaining references to MINA transport configuration keys: enableDirectBuffers/enablePooledAllocator/filterchain from code and example config files.
* Remove references to compressBufferOnQueue from config XMLs.  The implementation that used it was removed back in 2007 by QPID-275.
* Remove references to broker-side configuration key enableJMSXUserID. This broker feature was removed by QPID-943 (which replaced the functionality with an equivilent client-side option). The old Broker side key plays no part in the client-side function.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1237088 13f79535-47bb-0310-9956-ffa450edef68
  • Loading branch information
k-wall committed Jan 28, 2012
1 parent 1b3fb7d commit ebb3caf
Show file tree
Hide file tree
Showing 6 changed files with 6 additions and 44 deletions.
3 changes: 0 additions & 3 deletions qpid/java/broker/etc/config.xml
Expand Up @@ -60,10 +60,7 @@
</ssl>
</management>
<advanced>
<filterchain enableExecutorPool="true"/>
<framesize>65535</framesize>
<compressBufferOnQueue>false</compressBufferOnQueue>
<enableJMSXUserID>false</enableJMSXUserID>
<locale>en_US</locale>
</advanced>

Expand Down
Expand Up @@ -88,7 +88,6 @@ public class ServerConfiguration extends ConfigurationPlugin

{
envVarMap.put("QPID_PORT", "connector.port");
envVarMap.put("QPID_ENABLEDIRECTBUFFERS", "advanced.enableDirectBuffers");
envVarMap.put("QPID_SSLPORT", "connector.ssl.port");
envVarMap.put("QPID_JMXPORT_REGISTRYSERVER", MGMT_JMXPORT_REGISTRYSERVER);
envVarMap.put("QPID_JMXPORT_CONNECTORSERVER", MGMT_JMXPORT_CONNECTORSERVER);
Expand All @@ -109,7 +108,6 @@ public class ServerConfiguration extends ConfigurationPlugin
envVarMap.put("QPID_SOCKETRECEIVEBUFFER", "connector.socketReceiveBuffer");
envVarMap.put("QPID_SOCKETWRITEBUFFER", "connector.socketWriteBuffer");
envVarMap.put("QPID_TCPNODELAY", "connector.tcpNoDelay");
envVarMap.put("QPID_ENABLEPOOLEDALLOCATOR", "advanced.enablePooledAllocator");
envVarMap.put("QPID_STATUS-UPDATES", "status-updates");
}

Expand Down Expand Up @@ -178,7 +176,7 @@ public void handle()
*/
public ServerConfiguration(Configuration conf)
{
_configuration = conf;
_configuration = conf;
}

/**
Expand Down Expand Up @@ -473,7 +471,7 @@ public void reparseConfigFileSecuritySections() throws ConfigurationException
{
VirtualHost vhost = vhostRegistry.getVirtualHost(hostName);
Configuration vhostConfig = newVhosts.subset("virtualhost." + hostName);
vhost.getConfiguration().setConfiguration("virtualhosts.virtualhost", vhostConfig); // XXX
vhost.getConfiguration().setConfiguration("virtualhosts.virtualhost", vhostConfig);
vhost.getSecurityManager().configureGlobalPlugins(this);
vhost.getSecurityManager().configureHostPlugins(vhost.getConfiguration());
}
Expand Down Expand Up @@ -609,11 +607,6 @@ public double getHeartBeatTimeout()
return getDoubleValue("heartbeat.timeoutFactor", 2.0);
}

public int getDeliveryPoolSize()
{
return getIntValue("delivery.poolsize");
}

public long getMaximumMessageAge()
{
return getLongValue("maximumMessageAge");
Expand Down Expand Up @@ -699,11 +692,6 @@ public boolean getTcpNoDelay()
return getBooleanValue("connector.tcpNoDelay", true);
}

public boolean getEnableExecutorPool()
{
return getBooleanValue("advanced.filterchain[@enableExecutorPool]");
}

public boolean getEnableSSL()
{
return getBooleanValue("connector.ssl.enabled");
Expand Down
Expand Up @@ -491,19 +491,6 @@ public void testGetTcpNoDelay() throws ConfigurationException
assertEquals(false, _serverConfig.getTcpNoDelay());
}

public void testGetEnableExecutorPool() throws ConfigurationException
{
// Check default
_serverConfig.initialise();
assertEquals(false, _serverConfig.getEnableExecutorPool());

// Check value we set
_config.setProperty("advanced.filterchain[@enableExecutorPool]", true);
_serverConfig = new ServerConfiguration(_config);
_serverConfig.initialise();
assertEquals(true, _serverConfig.getEnableExecutorPool());
}

public void testGetEnableSSL() throws ConfigurationException
{
// Check default
Expand Down
7 changes: 1 addition & 6 deletions qpid/java/systests/etc/config-systests-firewall-2.xml
Expand Up @@ -31,25 +31,20 @@
To disasble Non-SSL port set sslOnly to true -->
<ssl>
<enabled>false</enabled>
<port>8672</port>
<sslOnly>false</sslOnly>
<keyStorePath>/path/to/keystore.ks</keyStorePath>
<keyStorePassword>keystorepass</keyStorePassword>
</ssl>
<port>5672</port>
<sslport>8672</sslport>
<socketReceiveBuffer>262144</socketReceiveBuffer>
<socketSendBuffer>262144</socketSendBuffer>
</connector>
<management>
<enabled>false</enabled>
</management>
<advanced>
<filterchain enableExecutorPool="true"/>
<enablePooledAllocator>false</enablePooledAllocator>
<enableDirectBuffers>false</enableDirectBuffers>
<framesize>65535</framesize>
<compressBufferOnQueue>false</compressBufferOnQueue>
<enableJMSXUserID>false</enableJMSXUserID>
<locale>en_US</locale>
</advanced>

Expand Down
7 changes: 1 addition & 6 deletions qpid/java/systests/etc/config-systests-firewall-3.xml
Expand Up @@ -31,25 +31,20 @@
To disable Non-SSL port set sslOnly to true -->
<ssl>
<enabled>false</enabled>
<port>8672</port>
<sslOnly>false</sslOnly>
<keyStorePath>/path/to/keystore.ks</keyStorePath>
<keyStorePassword>keystorepass</keyStorePassword>
</ssl>
<port>5672</port>
<sslport>8672</sslport>
<socketReceiveBuffer>262144</socketReceiveBuffer>
<socketSendBuffer>262144</socketSendBuffer>
</connector>
<management>
<enabled>false</enabled>
</management>
<advanced>
<filterchain enableExecutorPool="true"/>
<enablePooledAllocator>false</enablePooledAllocator>
<enableDirectBuffers>false</enableDirectBuffers>
<framesize>65535</framesize>
<compressBufferOnQueue>false</compressBufferOnQueue>
<enableJMSXUserID>false</enableJMSXUserID>
<locale>en_US</locale>
</advanced>

Expand Down
Expand Up @@ -37,7 +37,7 @@
*
* BRK-1001 : Startup : Version: <Version> Build: <Build>
* BRK-1002 : Starting : Listening on <Transport> port <Port>
* BRK-1003 : Shuting down : <Transport> port <Port>
* BRK-1003 : Shutting down : <Transport> port <Port>
* BRK-1004 : Ready
* BRK-1005 : Stopped
* BRK-1006 : Using configuration : <path>
Expand Down Expand Up @@ -807,7 +807,7 @@ public void testBrokerShutdownListeningTCPSSL() throws Exception
setConfigurationProperty("connector.ssl.keyStorePath", getConfigurationStringProperty("management.ssl.keyStorePath"));
setConfigurationProperty("connector.ssl.keyStorePassword", getConfigurationStringProperty("management.ssl.keyStorePassword"));

Integer sslPort = Integer.parseInt(getConfigurationStringProperty("connector.sslport"));
Integer sslPort = Integer.parseInt(getConfigurationStringProperty("connector.ssl.port"));

startBroker();

Expand Down

0 comments on commit ebb3caf

Please sign in to comment.