Skip to content

Commit dc2ba04

Browse files
Merge pull request #846 from Pliner/drop-unused-use-background-threads-for-io
Deletion of unused UseBackgroundThreadsForIO
2 parents 20d81b1 + be24c05 commit dc2ba04

File tree

5 files changed

+2
-83
lines changed

5 files changed

+2
-83
lines changed

projects/RabbitMQ.Client/client/api/ConnectionFactory.cs

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -298,11 +298,6 @@ public AmqpTcpEndpoint Endpoint
298298
/// </summary>
299299
public TimeSpan RequestedHeartbeat { get; set; } = DefaultHeartbeat;
300300

301-
/// <summary>
302-
/// When set to true, background thread will be used for the I/O loop.
303-
/// </summary>
304-
public bool UseBackgroundThreadsForIO { get; set; }
305-
306301
/// <summary>
307302
/// Username to use when authenticating to the server.
308303
/// </summary>

projects/RabbitMQ.Client/client/api/IConnectionFactory.cs

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -72,11 +72,6 @@ public interface IConnectionFactory
7272
/// </summary>
7373
TimeSpan RequestedHeartbeat { get; set; }
7474

75-
/// <summary>
76-
/// When set to true, background threads will be used for I/O and heartbeats.
77-
/// </summary>
78-
bool UseBackgroundThreadsForIO { get; set; }
79-
8075
/// <summary>
8176
/// Username to use when authenticating to the server.
8277
/// </summary>

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,7 @@ public Connection(IConnectionFactory factory, bool insist, IFrameHandler frameHa
124124
_session0 = new MainSession(this) { Handler = NotifyReceivedCloseOk };
125125
_model0 = (ModelBase)Protocol.CreateModel(_session0);
126126

127-
StartMainLoop(factory.UseBackgroundThreadsForIO);
127+
StartMainLoop();
128128
Open(insist);
129129
}
130130

@@ -830,7 +830,7 @@ public void MaybeStartHeartbeatTimers()
830830
}
831831
}
832832

833-
public void StartMainLoop(bool useBackgroundThread)
833+
public void StartMainLoop()
834834
{
835835
_mainLoopTask = Task.Run((Action)MainLoop);
836836
}

projects/Unit/APIApproval.Approve.verified.txt

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,6 @@ namespace RabbitMQ.Client
9090
public RabbitMQ.Client.SslOption Ssl { get; set; }
9191
public bool TopologyRecoveryEnabled { get; set; }
9292
public System.Uri Uri { get; set; }
93-
public bool UseBackgroundThreadsForIO { get; set; }
9493
public string UserName { get; set; }
9594
public string VirtualHost { get; set; }
9695
public static System.Net.Sockets.AddressFamily DefaultAddressFamily { get; set; }
@@ -330,7 +329,6 @@ namespace RabbitMQ.Client
330329
uint RequestedFrameMax { get; set; }
331330
System.TimeSpan RequestedHeartbeat { get; set; }
332331
System.Uri Uri { get; set; }
333-
bool UseBackgroundThreadsForIO { get; set; }
334332
string UserName { get; set; }
335333
string VirtualHost { get; set; }
336334
RabbitMQ.Client.IAuthMechanismFactory AuthMechanismFactory(System.Collections.Generic.IList<string> mechanismNames);

projects/Unit/TestConnectionWithBackgroundThreads.cs

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

0 commit comments

Comments
 (0)