Skip to content

Commit 05ab592

Browse files
Untabify
1 parent 44ce7e2 commit 05ab592

File tree

6 files changed

+127
-127
lines changed

6 files changed

+127
-127
lines changed

docs/specs/amqp0-9-1.xml

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -901,9 +901,9 @@
901901
<doc>Notifies client that the connection is blocked</doc>
902902

903903
<field name = "reason" domain = "shortstr">
904-
<doc>
905-
Provides an explanation why the connection was blocked.
906-
</doc>
904+
<doc>
905+
Provides an explanation why the connection was blocked.
906+
</doc>
907907
</field>
908908

909909
<chassis name = "client" implement = "MUST" />

projects/client/RabbitMQ.Client/src/client/impl/ConnectionBase.cs

Lines changed: 60 additions & 60 deletions
Original file line numberDiff line numberDiff line change
@@ -151,38 +151,38 @@ public event ConnectionShutdownEventHandler ConnectionShutdown
151151

152152
public event ConnectionBlockedEventHandler ConnectionBlocked
153153
{
154-
add
155-
{
156-
lock (m_eventLock)
157-
{
158-
m_connectionBlocked += value;
159-
}
160-
}
161-
remove
162-
{
163-
lock (m_eventLock)
164-
{
165-
m_connectionBlocked -= value;
166-
}
167-
}
154+
add
155+
{
156+
lock (m_eventLock)
157+
{
158+
m_connectionBlocked += value;
159+
}
160+
}
161+
remove
162+
{
163+
lock (m_eventLock)
164+
{
165+
m_connectionBlocked -= value;
166+
}
167+
}
168168
}
169169

170170
public event ConnectionUnblockedEventHandler ConnectionUnblocked
171171
{
172-
add
173-
{
174-
lock (m_eventLock)
175-
{
176-
m_connectionUnblocked += value;
177-
}
178-
}
179-
remove
180-
{
181-
lock (m_eventLock)
182-
{
183-
m_connectionUnblocked -= value;
184-
}
185-
}
172+
add
173+
{
174+
lock (m_eventLock)
175+
{
176+
m_connectionUnblocked += value;
177+
}
178+
}
179+
remove
180+
{
181+
lock (m_eventLock)
182+
{
183+
m_connectionUnblocked -= value;
184+
}
185+
}
186186
}
187187

188188
public event CallbackExceptionEventHandler CallbackException
@@ -377,12 +377,12 @@ void IDisposable.Dispose()
377377
Abort();
378378
if (ShutdownReport.Count > 0)
379379
{
380-
foreach (ShutdownReportEntry entry in ShutdownReport)
381-
{
382-
if (entry.Exception != null)
383-
throw entry.Exception;
384-
}
385-
throw new OperationInterruptedException(null);
380+
foreach (ShutdownReportEntry entry in ShutdownReport)
381+
{
382+
if (entry.Exception != null)
383+
throw entry.Exception;
384+
}
385+
throw new OperationInterruptedException(null);
386386
}
387387
}
388388

@@ -899,57 +899,57 @@ public void PrettyPrintShutdownReport()
899899

900900
public void HandleConnectionBlocked(string reason)
901901
{
902-
ConnectionBlockedEventArgs args = new ConnectionBlockedEventArgs(reason);
903-
OnConnectionBlocked(args);
902+
ConnectionBlockedEventArgs args = new ConnectionBlockedEventArgs(reason);
903+
OnConnectionBlocked(args);
904904
}
905905

906906
public void OnConnectionBlocked(ConnectionBlockedEventArgs args)
907907
{
908-
ConnectionBlockedEventHandler handler;
909-
lock (m_eventLock)
910-
{
911-
handler = m_connectionBlocked;
912-
}
913-
if (handler != null)
914-
{
915-
foreach (ConnectionBlockedEventHandler h in handler.GetInvocationList()) {
916-
try {
908+
ConnectionBlockedEventHandler handler;
909+
lock (m_eventLock)
910+
{
911+
handler = m_connectionBlocked;
912+
}
913+
if (handler != null)
914+
{
915+
foreach (ConnectionBlockedEventHandler h in handler.GetInvocationList()) {
916+
try {
917917
h(this, args);
918918
} catch (Exception e) {
919919
CallbackExceptionEventArgs cee_args = new CallbackExceptionEventArgs(e);
920920
cee_args.Detail["context"] = "OnConnectionBlocked";
921921
OnCallbackException(cee_args);
922922
}
923-
}
924-
}
923+
}
924+
}
925925
}
926926

927927

928928
public void HandleConnectionUnblocked()
929929
{
930-
OnConnectionUnblocked();
930+
OnConnectionUnblocked();
931931
}
932932

933933
public void OnConnectionUnblocked()
934934
{
935-
ConnectionUnblockedEventHandler handler;
936-
lock (m_eventLock)
937-
{
938-
handler = m_connectionUnblocked;
939-
}
940-
if (handler != null)
941-
{
942-
foreach (ConnectionUnblockedEventHandler h in handler.GetInvocationList()) {
943-
try {
935+
ConnectionUnblockedEventHandler handler;
936+
lock (m_eventLock)
937+
{
938+
handler = m_connectionUnblocked;
939+
}
940+
if (handler != null)
941+
{
942+
foreach (ConnectionUnblockedEventHandler h in handler.GetInvocationList()) {
943+
try {
944944
h(this);
945945
} catch (Exception e) {
946946
CallbackExceptionEventArgs args = new CallbackExceptionEventArgs(e);
947947
args.Detail["context"] = "OnConnectionUnblocked";
948948
OnCallbackException(args);
949949
}
950-
}
951-
}
952-
}
950+
}
951+
}
952+
}
953953

954954
///<summary>Broadcasts notification of the final shutdown of the connection.</summary>
955955
public void OnShutdown()

projects/client/RabbitMQ.Client/src/client/impl/ModelBase.cs

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -726,17 +726,17 @@ public void HandleConnectionClose(ushort replyCode,
726726

727727
public void HandleConnectionBlocked(string reason)
728728
{
729-
ConnectionBase cb = ((ConnectionBase)m_session.Connection);
729+
ConnectionBase cb = ((ConnectionBase)m_session.Connection);
730730

731-
cb.HandleConnectionBlocked(reason);
732-
}
731+
cb.HandleConnectionBlocked(reason);
732+
}
733733

734734
public void HandleConnectionUnblocked()
735735
{
736-
ConnectionBase cb = ((ConnectionBase)m_session.Connection);
736+
ConnectionBase cb = ((ConnectionBase)m_session.Connection);
737737

738-
cb.HandleConnectionUnblocked();
739-
}
738+
cb.HandleConnectionUnblocked();
739+
}
740740

741741
public void HandleChannelClose(ushort replyCode,
742742
string replyText,
@@ -1335,12 +1335,12 @@ void IDisposable.Dispose()
13351335

13361336
public void Close()
13371337
{
1338-
Close(CommonFraming.Constants.ReplySuccess, "Goodbye");
1338+
Close(CommonFraming.Constants.ReplySuccess, "Goodbye");
13391339
}
13401340

13411341
public void Close(ushort replyCode, string replyText)
13421342
{
1343-
Close(replyCode, replyText, false);
1343+
Close(replyCode, replyText, false);
13441344
}
13451345

13461346
public void Abort()
@@ -1372,11 +1372,11 @@ public void Close(ShutdownEventArgs reason, bool abort)
13721372
}
13731373
k.Wait();
13741374
} catch (AlreadyClosedException ace) {
1375-
if (!abort)
1376-
throw ace;
1375+
if (!abort)
1376+
throw ace;
13771377
} catch (IOException ioe) {
1378-
if (!abort)
1379-
throw ioe;
1378+
if (!abort)
1379+
throw ioe;
13801380
}
13811381
}
13821382

projects/client/RabbitMQ.Client/src/client/impl/v0_9_1/ProtocolBase.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ public ProtocolBase() {
5252
Capabilities["exchange_exchange_bindings"] = true;
5353
Capabilities["basic.nack"] = true;
5454
Capabilities["consumer_cancel_notify"] = true;
55-
Capabilities["connection.blocked"] = true;
55+
Capabilities["connection.blocked"] = true;
5656
}
5757

5858
public override IFrameHandler CreateFrameHandler(AmqpTcpEndpoint endpoint,

projects/client/Unit/src/unit/Fixtures.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -62,12 +62,12 @@ public void Dispose()
6262
Model.Close();
6363
Conn.Close();
6464

65-
ReleaseResources();
65+
ReleaseResources();
6666
}
6767

6868
protected virtual void ReleaseResources()
6969
{
70-
// no-op
70+
// no-op
7171
}
7272
}
7373

0 commit comments

Comments
 (0)