File tree Expand file tree Collapse file tree 1 file changed +11
-3
lines changed
IntegrationEngine/JobProcessor Expand file tree Collapse file tree 1 file changed +11
-3
lines changed Original file line number Diff line number Diff line change @@ -65,9 +65,17 @@ public void Listen(CancellationToken cancellationToken)
6565 var integrationJob = UnityContainer . Resolve ( type ) as IIntegrationJob ;
6666 if ( integrationJob != null )
6767 {
68- if ( integrationJob is IParameterizedJob )
69- ( integrationJob as IParameterizedJob ) . Parameters = message . Parameters ;
70- integrationJob . Run ( ) ;
68+ if ( integrationJob is IParameterizedJob ) {
69+ var parameterizedJob = integrationJob as IParameterizedJob ;
70+ parameterizedJob . Parameters = message . Parameters ;
71+ Log . Info ( x => x ( "Running job: {0} with parameters {1}" , integrationJob , message . Parameters ) ) ;
72+ parameterizedJob . Run ( ) ;
73+ }
74+ else {
75+ Log . Info ( x => x ( "Running job: {0}" , integrationJob ) ) ;
76+ integrationJob . Run ( ) ;
77+ }
78+ Log . Info ( x => x ( "Integration job ran successfully: {0}" , integrationJob ) ) ;
7179 }
7280 }
7381 catch ( OperationCanceledException exception )
You can’t perform that action at this time.
0 commit comments