Skip to content

Commit 61fcffb

Browse files
committed
Add IntegrationJobRunFailureException
1 parent c658e72 commit 61fcffb

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

IntegrationEngine.Core/IntegrationEngine.Core.csproj

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -86,6 +86,7 @@
8686
<Compile Include="Jobs\IIntegrationJob.cs" />
8787
<Compile Include="Jobs\ILogJob.cs" />
8888
<Compile Include="Jobs\IMailJob.cs" />
89+
<Compile Include="Jobs\IntegrationJobRunFailureException.cs" />
8990
<Compile Include="Jobs\IParameterizedJob.cs" />
9091
<Compile Include="Jobs\ISqlJob.cs" />
9192
<Compile Include="Jobs\SqlJob.cs" />

IntegrationEngine/MessageQueue/RabbitMQListener.cs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,13 +80,17 @@ void _listen()
8080
integrationJob.Run();
8181
}
8282
}
83+
catch (IntegrationJobRunFailureException exception)
84+
{
85+
Log.Error(x => x("Integration job did not run successfully ({0}).", message.JobTypeName), exception);
86+
}
8387
catch (EndOfStreamException exception)
8488
{
8589
Log.Debug(x => x("The message queue ({0}) has closed.", MessageQueueConfiguration.QueueName), exception);
8690
}
8791
catch (Exception exception)
8892
{
89-
Log.Error(x => x("Integration job did not run successfully ({0})", message.JobTypeName), exception);
93+
Log.Error("Issue receiving/decoding dispatch message or running job.", exception);
9094
}
9195
}
9296
}

0 commit comments

Comments
 (0)