diff --git a/TransactionProcessor.IntegrationTests/Common/Retry.cs b/TransactionProcessor.IntegrationTests/Common/Retry.cs
index f4742dad..ee8b5651 100644
--- a/TransactionProcessor.IntegrationTests/Common/Retry.cs
+++ b/TransactionProcessor.IntegrationTests/Common/Retry.cs
@@ -6,6 +6,7 @@ namespace TransactionProcessor.IntegrationTests
 {
     using System.Threading;
     using System.Threading.Tasks;
+    using global::Shared.Logger;
 
     public static class Retry
     {
diff --git a/TransactionProcessor.IntegrationTests/Shared/SharedSteps.cs b/TransactionProcessor.IntegrationTests/Shared/SharedSteps.cs
index b1f15e08..192d0a2a 100644
--- a/TransactionProcessor.IntegrationTests/Shared/SharedSteps.cs
+++ b/TransactionProcessor.IntegrationTests/Shared/SharedSteps.cs
@@ -534,10 +534,15 @@ private async Task<SerialisedMessage> PerformSaleTransaction(Guid estateId, Guid
                                                                                                        TypeNameHandling = TypeNameHandling.All
                                                                                                    });
 
-            SerialisedMessage responseSerialisedMessage =
-                await this.TestingContext.DockerHelper.TransactionProcessorClient.PerformTransaction(this.TestingContext.AccessToken,
-                                                                                                     serialisedMessage,
-                                                                                                     cancellationToken);
+            SerialisedMessage responseSerialisedMessage = null;
+            await Retry.For(async () =>
+                            {
+                                responseSerialisedMessage =
+                                    await this.TestingContext.DockerHelper.TransactionProcessorClient.PerformTransaction(this.TestingContext.AccessToken,
+                                        serialisedMessage,
+                                        cancellationToken);
+                            }, TimeSpan.FromSeconds(60), TimeSpan.FromSeconds(15));
+            
 
             return responseSerialisedMessage;
         }