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 }