diff --git a/models/resources/workflow.go b/models/resources/workflow.go index a78e814..baa4f5a 100755 --- a/models/resources/workflow.go +++ b/models/resources/workflow.go @@ -51,3 +51,5 @@ func (w *WorkflowResource) ConvertToPricedResource(t tools.DataType, selectedIns CreatorID: w.CreatorID, }, nil // TODO ??? } + +// TODO : as instanciated resource ! diff --git a/tools/api.go b/tools/api.go index 3d0bff1..7bffe81 100644 --- a/tools/api.go +++ b/tools/api.go @@ -92,7 +92,7 @@ func (a *API) GetState() (State, int, error) { } func (a *API) ListenRouter(exec func(msg map[string]string)) { - go NewNATSCaller().ListenNats(DISCOVERY.GenerateKey(), map[NATSMethod]func(msg map[string]string){ + go NewNATSCaller().ListenNats(map[NATSMethod]func(msg map[string]string){ DISCOVERY: exec, }) } @@ -113,7 +113,7 @@ func (a *API) SubscribeRouter(infos []*beego.ControllerInfo) { } } } - go nats.SetNATSPub("api", DISCOVERY, discovery) + go nats.SetNATSPub(DISCOVERY, discovery) } // CheckRemotePeer checks the state of a remote peer