Skip to content

Commit df665ac

Browse files
committed
Iron out some sync/async issues
1 parent cb5330c commit df665ac

File tree

7 files changed

+5
-1097
lines changed

7 files changed

+5
-1097
lines changed

src/InEngine.Core.Test/job_scheduling_data_2_0.xsd

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

src/InEngine.Core/Queuing/Clients/FileClient.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ public ICommandEnvelope Consume()
116116
try
117117
{
118118
command.WriteSummaryToConsole();
119-
command.RunWithLifeCycle();
119+
command.RunWithLifeCycle().RunSynchronously();
120120
}
121121
catch (Exception exception)
122122
{

src/InEngine.Core/Queuing/Clients/RabbitMQClient.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ public void Consume(CancellationToken cancellationToken)
115115
try
116116
{
117117
command.WriteSummaryToConsole();
118-
command.RunWithLifeCycle();
118+
command.RunWithLifeCycle().RunSynchronously();
119119
}
120120
catch (Exception exception)
121121
{
@@ -155,7 +155,7 @@ public ICommandEnvelope Consume()
155155
try
156156
{
157157
command.WriteSummaryToConsole();
158-
command.RunWithLifeCycle();
158+
command.RunWithLifeCycle().RunSynchronously();
159159
}
160160
catch (Exception exception)
161161
{

src/InEngine.Core/Queuing/Clients/RedisClient.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,7 @@ public ICommandEnvelope Consume()
122122
try
123123
{
124124
command.WriteSummaryToConsole();
125-
command.RunWithLifeCycle();
125+
command.RunWithLifeCycle().RunSynchronously();
126126
}
127127
catch (Exception exception)
128128
{

src/InEngine.Core/Queuing/Clients/SyncClient.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ public bool UseCompression
3636

3737
public void Publish(AbstractCommand command)
3838
{
39-
command.RunAsync();
39+
command.RunAsync().RunSynchronously();
4040
}
4141

4242
public void Recover()

src/InEngine.Core/job_scheduling_data_2_0.xsd

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

src/InEngine/job_scheduling_data_2_0.xsd

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

0 commit comments

Comments
 (0)