UDPStoppableRoutine runs a UDPRoutine that can be stopped by closing the stopCh passed as argument.

ErrAlreadyStarted error happens when you try to start twice a flow routine.

type DefaultLogTransport struct { } func (s *DefaultLogTransport) Publish(msgs []*flowmessage.FlowMessage) { for _, msg := range msgs { fmt.Printf("%v\n", FlowMessageToString(msg)) } } type DefaultJSONTransport struct { } func (s *DefaultJSONTransport) Publish(msgs []*flowmessage.FlowMessage) { for _, msg := range msgs { fmt.Printf("%v\n", FlowMessageToJSON(msg)) } } */.