Minor refactoring
diff --git a/src/DotPulsar/Internal/Connector.cs b/src/DotPulsar/Internal/Connector.cs
index 515347e..18d45b1 100644
--- a/src/DotPulsar/Internal/Connector.cs
+++ b/src/DotPulsar/Internal/Connector.cs
@@ -1,4 +1,4 @@
-/*
+/*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
@@ -30,7 +30,10 @@
private readonly bool _verifyCertificateAuthority;
private readonly bool _verifyCertificateName;
- public Connector(X509Certificate2Collection clientCertificates, X509Certificate2? trustedCertificateAuthority, bool verifyCertificateAuthority,
+ public Connector(
+ X509Certificate2Collection clientCertificates,
+ X509Certificate2? trustedCertificateAuthority,
+ bool verifyCertificateAuthority,
bool verifyCertificateName)
{
_clientCertificates = clientCertificates;
diff --git a/src/DotPulsar/Internal/Process.cs b/src/DotPulsar/Internal/Process.cs
index 28299b9..7e18dfc 100644
--- a/src/DotPulsar/Internal/Process.cs
+++ b/src/DotPulsar/Internal/Process.cs
@@ -1,4 +1,4 @@
-/*
+/*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
@@ -22,13 +22,13 @@
{
public abstract class Process : IProcess
{
- protected readonly CancellationTokenSource CancellationTokenSource = new CancellationTokenSource();
-
+ protected readonly CancellationTokenSource CancellationTokenSource;
protected ChannelState ChannelState;
protected ExecutorState ExecutorState;
- public Process(Guid correlationId)
+ protected Process(Guid correlationId)
{
+ CancellationTokenSource = new CancellationTokenSource();
ChannelState = ChannelState.Disconnected;
ExecutorState = ExecutorState.Ok;
CorrelationId = correlationId;
diff --git a/src/DotPulsar/MessageMetadata.cs b/src/DotPulsar/MessageMetadata.cs
index 46421b1..aa826a2 100644
--- a/src/DotPulsar/MessageMetadata.cs
+++ b/src/DotPulsar/MessageMetadata.cs
@@ -1,4 +1,4 @@
-/*
+/*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
@@ -71,7 +71,7 @@
{
get
{
- for (var i = 0; i < Metadata.Properties.Count; i++)
+ for (var i = 0; i < Metadata.Properties.Count; ++i)
{
var prop = Metadata.Properties[i];
@@ -83,7 +83,7 @@
}
set
{
- for (var i = 0; i < Metadata.Properties.Count; i++)
+ for (var i = 0; i < Metadata.Properties.Count; ++i)
{
var prop = Metadata.Properties[i];