diff --git a/route.go b/route.go index 47660f2..bef1d16 100644 --- a/route.go +++ b/route.go @@ -26,14 +26,6 @@ type ProcessorRoute struct { output string } -func (r *ProcessorRoute) Input() string { - return r.input -} - -func (r *ProcessorRoute) Output() string { - return r.output -} - func NewRoute(config config.RouteConfig) (Route, error) { processors := []processing.Processor{} @@ -55,6 +47,14 @@ func NewRoute(config config.RouteConfig) (Route, error) { return &ProcessorRoute{input: config.Input, processors: processors, output: config.Output}, nil } +func (r *ProcessorRoute) Input() string { + return r.input +} + +func (r *ProcessorRoute) Output() string { + return r.output +} + func (r *ProcessorRoute) HandleInput(sourceId string, payload any, router *Router) error { var err error for _, processor := range r.processors {