chan name fail
This commit is contained in:
@@ -56,7 +56,7 @@ func NewNATSCaller() *natsCaller {
|
||||
|
||||
// on workflows' scheduling. Messages must contain
|
||||
// workflow execution ID, to allow retrieval of execution infos
|
||||
func (s *natsCaller) ListenNats(chanName string, execs map[NATSMethod]func(map[string]string)) {
|
||||
func (s *natsCaller) ListenNats(execs map[NATSMethod]func(map[string]string)) {
|
||||
log := logs.GetLogger()
|
||||
if config.GetConfig().NATSUrl == "" {
|
||||
log.Error().Msg(" -> NATS_SERVER is not set")
|
||||
|
||||
Reference in New Issue
Block a user