Skip to content

Commit 7e7087f

Browse files
author
Steve Powell
committed
Whitespace changes.
1 parent 40c7927 commit 7e7087f

File tree

4 files changed

+11
-11
lines changed

4 files changed

+11
-11
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ public final void writeShortstr(String str)
5050
if (length > 255) {
5151
throw new IllegalArgumentException(
5252
"Short string too long; utf-8 encoded length = " + length +
53-
", max = 255.");
53+
", max = 255.");
5454
}
5555
out.writeByte(bytes.length);
5656
out.write(bytes);
@@ -205,7 +205,7 @@ public void writeArray(List value)
205205
}
206206
}
207207
}
208-
208+
209209
/** Public API - encodes an octet from an int. */
210210
public final void writeOctet(int octet)
211211
throws IOException

src/com/rabbitmq/tools/jsonrpc/JsonRpcClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ public Object call(String method, Object[] params)
112112
} catch(ShutdownSignalException ex) {
113113
throw new IOException(ex.getMessage()); // wrap, re-throw
114114
}
115-
115+
116116
//System.out.println(requestStr + " --->\n---> " + replyStr);
117117
Map<String, Object> map = (Map) (new JSONReader().read(replyStr));
118118
return checkReply(map);

src/com/rabbitmq/tools/jsonrpc/JsonRpcException.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ public class JsonRpcException extends Exception {
3939
public Object error;
4040

4141
public JsonRpcException() {
42-
// no work needed in default no-argconstructor
42+
// no work needed in default no-arg constructor
4343
}
4444

4545
public JsonRpcException(Map<String, Object> errorMap) {

src/com/rabbitmq/utility/BlockingCell.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -28,9 +28,9 @@ public class BlockingCell<T> {
2828

2929
/** Will be null until a value is supplied, and possibly still then. */
3030
private T _value;
31-
31+
3232
private static final long NANOS_IN_MILLI = 1000 * 1000;
33-
33+
3434
private static final long INFINITY = -1;
3535

3636
/** Instantiate a new BlockingCell waiting for a value of the specified type. */
@@ -75,10 +75,10 @@ public synchronized T get(long timeout) throws InterruptedException, TimeoutExce
7575

7676
if (!_filled)
7777
throw new TimeoutException();
78-
78+
7979
return _value;
8080
}
81-
81+
8282
/**
8383
* As get(), but catches and ignores InterruptedException, retrying until a value appears.
8484
* @return the waited-for value
@@ -92,7 +92,7 @@ public synchronized T uninterruptibleGet() {
9292
}
9393
}
9494
}
95-
95+
9696
/**
9797
* As get(long timeout), but catches and ignores InterruptedException, retrying until
9898
* a value appears or until specified timeout is reached. If timeout is reached,
@@ -105,15 +105,15 @@ public synchronized T uninterruptibleGet() {
105105
public synchronized T uninterruptibleGet(int timeout) throws TimeoutException {
106106
long now = System.nanoTime() / NANOS_IN_MILLI;
107107
long runTime = now + timeout;
108-
108+
109109
do {
110110
try {
111111
return get(runTime - now);
112112
} catch (InterruptedException e) {
113113
// Ignore.
114114
}
115115
} while ((timeout == INFINITY) || ((now = System.nanoTime() / NANOS_IN_MILLI) < runTime));
116-
116+
117117
throw new TimeoutException();
118118
}
119119

0 commit comments

Comments
 (0)