Skip to content

Commit a5b271d

Browse files
committed
Prefer connection prefix over requested
Fixes #324
1 parent 6a9c1ab commit a5b271d

File tree

2 files changed

+9
-9
lines changed

2 files changed

+9
-9
lines changed

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

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -57,9 +57,9 @@ public class ConnectionFactoryConfigurator {
5757
public static final String VIRTUAL_HOST = "virtual.host";
5858
public static final String HOST = "host";
5959
public static final String PORT = "port";
60-
public static final String REQUESTED_CHANNEL_MAX = "requested.channel.max";
61-
public static final String REQUESTED_FRAME_MAX = "requested.frame.max";
62-
public static final String REQUESTED_HEARTBEAT = "requested.heartbeat";
60+
public static final String CONNECTION_CHANNEL_MAX = "connection.channel.max";
61+
public static final String CONNECTION_FRAME_MAX = "connection.frame.max";
62+
public static final String CONNECTION_HEARTBEAT = "connection.heartbeat";
6363
public static final String CONNECTION_TIMEOUT = "connection.timeout";
6464
public static final String HANDSHAKE_TIMEOUT = "handshake.timeout";
6565
public static final String SHUTDOWN_TIMEOUT = "shutdown.timeout";
@@ -142,15 +142,15 @@ public static void load(ConnectionFactory cf, Map<String, String> properties, St
142142
if (port != null) {
143143
cf.setPort(Integer.valueOf(port));
144144
}
145-
String requestedChannelMax = properties.get(prefix + REQUESTED_CHANNEL_MAX);
145+
String requestedChannelMax = properties.get(prefix + CONNECTION_CHANNEL_MAX);
146146
if (requestedChannelMax != null) {
147147
cf.setRequestedChannelMax(Integer.valueOf(requestedChannelMax));
148148
}
149-
String requestedFrameMax = properties.get(prefix + REQUESTED_FRAME_MAX);
149+
String requestedFrameMax = properties.get(prefix + CONNECTION_FRAME_MAX);
150150
if (requestedFrameMax != null) {
151151
cf.setRequestedFrameMax(Integer.valueOf(requestedFrameMax));
152152
}
153-
String requestedHeartbeat = properties.get(prefix + REQUESTED_HEARTBEAT);
153+
String requestedHeartbeat = properties.get(prefix + CONNECTION_HEARTBEAT);
154154
if (requestedHeartbeat != null) {
155155
cf.setRequestedHeartbeat(Integer.valueOf(requestedHeartbeat));
156156
}

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,9 @@ rabbitmq.password=bar
44
rabbitmq.virtual.host=dummy
55
rabbitmq.host=127.0.0.1
66
rabbitmq.port=5673
7-
rabbitmq.requested.channel.max=1
8-
rabbitmq.requested.frame.max=2
9-
rabbitmq.requested.heartbeat=10
7+
rabbitmq.connection.channel.max=1
8+
rabbitmq.connection.frame.max=2
9+
rabbitmq.connection.heartbeat=10
1010
rabbitmq.connection.timeout=10000
1111
rabbitmq.handshake.timeout=5000
1212
rabbitmq.shutdown.timeout=20000

0 commit comments

Comments
 (0)