File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
src/com/rabbitmq/client/impl Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change 5050 */
5151public abstract class AMQChannel extends ShutdownNotifierComponent {
5252 /**
53- * Private ; used instead of synchronizing on the channel itself,
53+ * Protected ; used instead of synchronizing on the channel itself,
5454 * so that clients can themselves use the channel to synchronize
5555 * on.
5656 */
@@ -217,7 +217,7 @@ public void rpc(Method m, RpcContinuation k)
217217 quiescingRpc (m , k );
218218 }
219219 }
220-
220+
221221 public void quiescingRpc (Method m , RpcContinuation k )
222222 throws IOException
223223 {
@@ -239,7 +239,7 @@ public void quiescingRpc(Method m, RpcContinuation k)
239239 @ Override public String toString () {
240240 return "AMQChannel(" + _connection + "," + _channelNumber + ")" ;
241241 }
242-
242+
243243 /**
244244 * Protected API - respond, in the driver thread, to a {@link ShutdownSignalException}.
245245 * @param signal the signal to handle
@@ -257,15 +257,15 @@ public void processShutdownSignal(ShutdownSignalException signal,
257257 ensureIsOpen (); // invariant: we should never be shut down more than once per instance
258258 if (isOpen ())
259259 _shutdownCause = signal ;
260-
260+
261261 _channelMutex .notifyAll ();
262262 }
263263 } finally {
264264 if (notifyRpc )
265265 notifyOutstandingRpc (signal );
266266 }
267267 }
268-
268+
269269 public void notifyOutstandingRpc (ShutdownSignalException signal ) {
270270 RpcContinuation k = nextOutstandingRpc ();
271271 if (k != null ) {
You can’t perform that action at this time.
0 commit comments