Skip to content

Commit a12c198

Browse files
Merge pull request #913 from rabbitmq/backport-pr-912
Backport #912 to 6.x
2 parents d344d61 + 375771c commit a12c198

File tree

3 files changed

+95
-271
lines changed

3 files changed

+95
-271
lines changed

projects/RabbitMQ.Client/client/impl/AutorecoveringModel.cs

Lines changed: 1 addition & 112 deletions
Original file line numberDiff line numberDiff line change
@@ -477,116 +477,6 @@ public void Close(ShutdownEventArgs reason, bool abort)
477477
}
478478
}
479479

480-
public bool DispatchAsynchronous(in IncomingCommand cmd)
481-
{
482-
if (_disposed)
483-
{
484-
throw new ObjectDisposedException(GetType().FullName);
485-
}
486-
487-
return _delegate.DispatchAsynchronous(in cmd);
488-
}
489-
490-
public void FinishClose()
491-
{
492-
if (_disposed)
493-
{
494-
throw new ObjectDisposedException(GetType().FullName);
495-
}
496-
497-
_delegate.FinishClose();
498-
}
499-
500-
public void OnBasicAck(BasicAckEventArgs args)
501-
{
502-
if (_disposed)
503-
{
504-
throw new ObjectDisposedException(GetType().FullName);
505-
}
506-
507-
_delegate.OnBasicAck(args);
508-
}
509-
510-
public void OnBasicNack(BasicNackEventArgs args)
511-
{
512-
if (_disposed)
513-
{
514-
throw new ObjectDisposedException(GetType().FullName);
515-
}
516-
517-
_delegate.OnBasicNack(args);
518-
}
519-
520-
public void OnBasicRecoverOk(EventArgs args)
521-
{
522-
if (_disposed)
523-
{
524-
throw new ObjectDisposedException(GetType().FullName);
525-
}
526-
527-
_delegate.OnBasicRecoverOk(args);
528-
}
529-
530-
public void OnBasicReturn(BasicReturnEventArgs args)
531-
{
532-
if (_disposed)
533-
{
534-
throw new ObjectDisposedException(GetType().FullName);
535-
}
536-
537-
_delegate.OnBasicReturn(args);
538-
}
539-
540-
public void OnCallbackException(CallbackExceptionEventArgs args)
541-
{
542-
if (_disposed)
543-
{
544-
throw new ObjectDisposedException(GetType().FullName);
545-
}
546-
547-
_delegate.OnCallbackException(args);
548-
}
549-
550-
public void OnFlowControl(FlowControlEventArgs args)
551-
{
552-
if (_disposed)
553-
{
554-
throw new ObjectDisposedException(GetType().FullName);
555-
}
556-
557-
_delegate.OnFlowControl(args);
558-
}
559-
560-
public void OnModelShutdown(ShutdownEventArgs reason)
561-
{
562-
if (_disposed)
563-
{
564-
throw new ObjectDisposedException(GetType().FullName);
565-
}
566-
567-
_delegate.OnModelShutdown(reason);
568-
}
569-
570-
public void OnSessionShutdown(ISession session, ShutdownEventArgs reason)
571-
{
572-
if (_disposed)
573-
{
574-
throw new ObjectDisposedException(GetType().FullName);
575-
}
576-
577-
_delegate.OnSessionShutdown(session, reason);
578-
}
579-
580-
public bool SetCloseReason(ShutdownEventArgs reason)
581-
{
582-
if (_disposed)
583-
{
584-
throw new ObjectDisposedException(GetType().FullName);
585-
}
586-
587-
return _delegate.SetCloseReason(reason);
588-
}
589-
590480
public override string ToString()
591481
{
592482
if (_disposed)
@@ -637,8 +527,7 @@ public void ConnectionTuneOk(ushort channelMax,
637527
_delegate.ConnectionTuneOk(channelMax, frameMax, heartbeat);
638528
}
639529

640-
public void HandleBasicAck(ulong deliveryTag,
641-
bool multiple)
530+
public void HandleBasicAck(ulong deliveryTag, bool multiple)
642531
{
643532
if (_disposed)
644533
{

projects/RabbitMQ.Client/client/impl/ExtensionMethods.cs

Lines changed: 0 additions & 74 deletions
This file was deleted.

0 commit comments

Comments
 (0)