@@ -192,10 +192,10 @@ public void handleDelivery(String consumerTag,
192192 String replyId = properties .getCorrelationId ();
193193 BlockingCell <Object > blocker =_continuationMap .remove (replyId );
194194 if (blocker != null ) {
195- blocker .set (new Response (consumerTag , envelope , properties , body ));
195+ blocker .set (new Response (consumerTag , envelope , properties , body ));
196196 } else {
197- // Not an error. Entry will have been removed if request timed out.
198- }
197+ // Not an error. Entry will have been removed if request timed out.
198+ }
199199 }
200200 }
201201 };
@@ -218,7 +218,7 @@ public Response doCall(AMQP.BasicProperties props, byte[] message, int timeout)
218218 throws IOException , ShutdownSignalException , TimeoutException {
219219 checkConsumer ();
220220 BlockingCell <Object > k = new BlockingCell <Object >();
221- String replyId ;
221+ String replyId ;
222222 synchronized (_continuationMap ) {
223223 _correlationId ++;
224224 replyId = "" + _correlationId ;
@@ -227,14 +227,14 @@ public Response doCall(AMQP.BasicProperties props, byte[] message, int timeout)
227227 _continuationMap .put (replyId , k );
228228 }
229229 publish (props , message );
230- Object reply ;
230+ Object reply ;
231231 try {
232- reply = k .uninterruptibleGet (timeout );
233- } catch (TimeoutException ex ) {
234- // Avoid potential leak. This entry is no longer needed by caller.
235- _continuationMap .remove (replyId );
236- throw ex ;
237- }
232+ reply = k .uninterruptibleGet (timeout );
233+ } catch (TimeoutException ex ) {
234+ // Avoid potential leak. This entry is no longer needed by caller.
235+ _continuationMap .remove (replyId );
236+ throw ex ;
237+ }
238238 if (reply instanceof ShutdownSignalException ) {
239239 ShutdownSignalException sig = (ShutdownSignalException ) reply ;
240240 ShutdownSignalException wrapper =
0 commit comments