Skip to content

Commit c5c0f64

Browse files
committed
Use connection prefix for auto-recovery keys
References #324
1 parent 580677c commit c5c0f64

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

src/main/java/com/rabbitmq/client/ConnectionFactoryConfigurator.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -65,9 +65,9 @@ public class ConnectionFactoryConfigurator {
6565
public static final String SHUTDOWN_TIMEOUT = "shutdown.timeout";
6666
public static final String USE_DEFAULT_CLIENT_PROPERTIES = "use.default.client.properties";
6767
public static final String CLIENT_PROPERTIES_PREFIX = "client.properties.";
68-
public static final String AUTOMATIC_RECOVERY_ENABLED = "automatic.recovery.enabled";
68+
public static final String CONNECTION_RECOVERY_ENABLED = "connection.recovery.enabled";
6969
public static final String TOPOLOGY_RECOVERY_ENABLED = "topology.recovery.enabled";
70-
public static final String NETWORK_RECOVERY_INTERVAL = "network.recovery.interval";
70+
public static final String CONNECTION_RECOVERY_INTERVAL = "connection.recovery.interval";
7171
public static final String CHANNEL_RPC_TIMEOUT = "channel.rpc.timeout";
7272
public static final String CHANNEL_SHOULD_CHECK_RPC_RESPONSE_TYPE = "channel.should.check.rpc.response.type";
7373
public static final String USE_NIO = "use.nio";
@@ -183,15 +183,15 @@ public static void load(ConnectionFactory cf, Map<String, String> properties, St
183183
}
184184
cf.setClientProperties(clientProperties);
185185

186-
String automaticRecovery = properties.get(prefix + AUTOMATIC_RECOVERY_ENABLED);
186+
String automaticRecovery = properties.get(prefix + CONNECTION_RECOVERY_ENABLED);
187187
if (automaticRecovery != null) {
188188
cf.setAutomaticRecoveryEnabled(Boolean.valueOf(automaticRecovery));
189189
}
190190
String topologyRecovery = properties.get(prefix + TOPOLOGY_RECOVERY_ENABLED);
191191
if (topologyRecovery != null) {
192192
cf.setTopologyRecoveryEnabled(Boolean.getBoolean(topologyRecovery));
193193
}
194-
String networkRecoveryInterval = properties.get(prefix + NETWORK_RECOVERY_INTERVAL);
194+
String networkRecoveryInterval = properties.get(prefix + CONNECTION_RECOVERY_INTERVAL);
195195
if (networkRecoveryInterval != null) {
196196
cf.setNetworkRecoveryInterval(Long.valueOf(networkRecoveryInterval));
197197
}

src/test/resources/property-file-initialisation/configuration.properties

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,9 +12,9 @@ rabbitmq.handshake.timeout=5000
1212
rabbitmq.shutdown.timeout=20000
1313
rabbitmq.use.default.client.properties=true
1414
rabbitmq.client.properties.foo=bar
15-
rabbitmq.automatic.recovery.enabled=false
15+
rabbitmq.connection.recovery.enabled=false
1616
rabbitmq.topology.recovery.enabled=false
17-
rabbitmq.network.recovery.interval=10000
17+
rabbitmq.connection.recovery.interval=10000
1818
rabbitmq.channel.rpc.timeout=10000
1919
rabbitmq.channel.should.check.rpc.response.type=true
2020
rabbitmq.use.nio=true

0 commit comments

Comments
 (0)