Skip to content

Commit 29aa76a

Browse files
author
Steve Powell
committed
Use Collections.emptyMap() in ValueReader for empty maps;
remove commented out line; eliminate some generic warnings from cmpiler.
1 parent 5d353d6 commit 29aa76a

File tree

4 files changed

+12
-8
lines changed

4 files changed

+12
-8
lines changed

codegen.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -305,6 +305,7 @@ def printClassProperties(c):
305305
for c in spec.classes:
306306
if c.hasContentProperties:
307307
printClassProperties(c)
308+
308309
print "}"
309310

310311
#--------------------------------------------------------------------------------

src/com/rabbitmq/client/RpcServer.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -141,12 +141,14 @@ public void processRequest(QueueingConsumer.Delivery request)
141141
throws IOException
142142
{
143143
AMQP.BasicProperties requestProperties = request.getProperties();
144-
if (requestProperties.getCorrelationId() != null && requestProperties.getReplyTo() != null)
144+
String correlationId = requestProperties.getCorrelationId();
145+
String replyTo = requestProperties.getReplyTo();
146+
if (correlationId != null && replyTo != null)
145147
{
146148
AMQP.BasicProperties replyProperties = new AMQP.BasicProperties();
147149
byte[] replyBody = handleCall(request, replyProperties);
148-
replyProperties.setCorrelationId(requestProperties.getCorrelationId());
149-
_channel.basicPublish("", requestProperties.getReplyTo(),
150+
replyProperties.setCorrelationId(correlationId);
151+
_channel.basicPublish("", replyTo,
150152
replyProperties, replyBody);
151153
} else {
152154
handleCast(request);

src/com/rabbitmq/client/impl/AMQConnection.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,6 @@ public void ensureIsOpen()
146146
private int _heartbeat;
147147

148148
private final String _virtualHost;
149-
// private final int _requestedChannelMax, _requestedFrameMax, _requestedHeartbeat;
150149
private final Map<String, Object> _clientProperties;
151150

152151
/** Saved server properties field from connection.start */

src/com/rabbitmq/client/impl/ValueReader.java

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
import java.io.IOException;
2222
import java.math.BigDecimal;
2323
import java.math.BigInteger;
24+
import java.util.Collections;
2425
import java.util.Date;
2526
import java.util.HashMap;
2627
import java.util.Map;
@@ -146,9 +147,10 @@ public final long readLonglong()
146147
public static final Map<String, Object> readTable(DataInputStream in)
147148
throws IOException
148149
{
149-
Map<String, Object> table = new HashMap<String, Object>();
150150
long tableLength = unsignedExtend(in.readInt());
151-
151+
if (tableLength == 0) return Collections.emptyMap();
152+
153+
Map<String, Object> table = new HashMap<String, Object>();
152154
DataInputStream tableIn = new DataInputStream
153155
(new TruncatedInputStream(in, tableLength));
154156
while(tableIn.available() > 0) {
@@ -217,13 +219,13 @@ public static final Object readFieldValue(DataInputStream in)
217219
}
218220

219221
/** Read a field-array */
220-
public static List readArray(DataInputStream in)
222+
public static List<Object> readArray(DataInputStream in)
221223
throws IOException
222224
{
223225
long length = unsignedExtend(in.readInt());
224226
DataInputStream arrayIn = new DataInputStream
225227
(new TruncatedInputStream(in, length));
226-
List array = new ArrayList();
228+
List<Object> array = new ArrayList<Object>();
227229
while(arrayIn.available() > 0) {
228230
Object value = readFieldValue(arrayIn);
229231
array.add(value);

0 commit comments

Comments
 (0)