Code Review
/
nonrtric.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Refactor for better naming of go producer
[nonrtric.git]
/
dmaap-mediator-producer
/
internal
/
server
/
server.go
diff --git
a/dmaap-mediator-producer/internal/server/server.go
b/dmaap-mediator-producer/internal/server/server.go
index
8bed1f9
..
79646c2
100644
(file)
--- a/
dmaap-mediator-producer/internal/server/server.go
+++ b/
dmaap-mediator-producer/internal/server/server.go
@@
-71,7
+71,7
@@
func (h *ProducerCallbackHandler) addInfoJobHandler(w http.ResponseWriter, r *ht
http.Error(w, fmt.Sprintf("Invalid json body. Cause: %v", unmarshalErr), http.StatusBadRequest)
return
}
http.Error(w, fmt.Sprintf("Invalid json body. Cause: %v", unmarshalErr), http.StatusBadRequest)
return
}
- if err := h.jobsManager.AddJob(jobInfo); err != nil {
+ if err := h.jobsManager.AddJob
FromRESTCall
(jobInfo); err != nil {
http.Error(w, fmt.Sprintf("Invalid job info. Cause: %v", err), http.StatusBadRequest)
}
}
http.Error(w, fmt.Sprintf("Invalid job info. Cause: %v", err), http.StatusBadRequest)
}
}
@@
-84,7
+84,7
@@
func (h *ProducerCallbackHandler) deleteInfoJobHandler(w http.ResponseWriter, r
return
}
return
}
- h.jobsManager.DeleteJob(id)
+ h.jobsManager.DeleteJob
FromRESTCall
(id)
}
type notFoundHandler struct{}
}
type notFoundHandler struct{}