diff --git a/app/ship_processor.go b/app/ship_processor.go
index f6746a4..8be8926 100644
--- a/app/ship_processor.go
+++ b/app/ship_processor.go
@@ -156,3 +156,7 @@ func (processor *ShipProcessor) processTraces(traces []*ship.TransactionTraceV0)
 		log.WithError(err).Error("Failed to send messages")
 	}
 }
+
+func (processor *ShipProcessor) Close() error {
+	return processor.writer.Close()
+}