From 80826442bb6ed7232f52f182064bcad32e737b1c Mon Sep 17 00:00:00 2001 From: Raphael Santo Domingo Date: Wed, 11 Aug 2021 11:32:36 -0500 Subject: [PATCH] Pass in config transfer to stream service --- .gitignore | 4 +++- internal/events/service_stream.go | 3 ++- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/.gitignore b/.gitignore index 2510283..f35cc52 100644 --- a/.gitignore +++ b/.gitignore @@ -26,4 +26,6 @@ pkged.go /storage/ /storage-*/ /testdata/ftp-server/outbound/*.ach -/internal/test/storage/ \ No newline at end of file +/internal/test/storage/ + +.idea/ \ No newline at end of file diff --git a/internal/events/service_stream.go b/internal/events/service_stream.go index 22e24e2..8ec8400 100644 --- a/internal/events/service_stream.go +++ b/internal/events/service_stream.go @@ -45,7 +45,8 @@ func newStreamService(logger log.Logger, transformConfig *models.TransformConfig return nil, fmt.Errorf("events stream: %v", err) } return &streamService{ - topic: topic, + topic: topic, + transformConfig: transformConfig, }, nil }