Skip to content

Commit 2f2c610

Browse files
Formatting
1 parent b6d8773 commit 2f2c610

File tree

1 file changed

+12
-11
lines changed

1 file changed

+12
-11
lines changed

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

Lines changed: 12 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -101,18 +101,19 @@ public void run() {
101101
}
102102

103103
public void handleCancel(final String consumerTag, final Consumer delegate) {
104-
executeUnlessShuttingDown(new Runnable() {
104+
executeUnlessShuttingDown(
105+
new Runnable() {
105106
public void run() {
106-
try {
107-
delegate.handleCancel(consumerTag);
108-
} catch (Throwable ex) {
109-
connection.getExceptionHandler().handleConsumerException(
110-
channel,
111-
ex,
112-
delegate,
113-
consumerTag,
114-
"handleCancel");
115-
}
107+
try {
108+
delegate.handleCancel(consumerTag);
109+
} catch (Throwable ex) {
110+
connection.getExceptionHandler().handleConsumerException(
111+
channel,
112+
ex,
113+
delegate,
114+
consumerTag,
115+
"handleCancel");
116+
}
116117
}
117118
});
118119
}

0 commit comments

Comments
 (0)