diff --git a/internal/module/db-sqlite.go b/internal/module/db-sqlite.go index 924789d..07f5adb 100644 --- a/internal/module/db-sqlite.go +++ b/internal/module/db-sqlite.go @@ -66,10 +66,6 @@ func (t *DbSqlite) Start(ctx context.Context) error { return nil } -func (t *DbSqlite) Output(ctx context.Context, payload any) error { - return nil -} - func (t *DbSqlite) Stop() { if t.db != nil { t.db.Close() diff --git a/internal/module/redis-client.go b/internal/module/redis-client.go index 1e1071c..05aee07 100644 --- a/internal/module/redis-client.go +++ b/internal/module/redis-client.go @@ -79,11 +79,6 @@ func (rc *RedisClient) Start(ctx context.Context) error { return nil } -func (rc *RedisClient) Output(ctx context.Context, payload any) error { - - return errors.ErrUnsupported -} - func (rc *RedisClient) Stop() { rc.cancel() }