summary |
shortlog |
log |
commit | commitdiff |
review |
tree
raw |
patch |
inline | side by side (from parent 1:
3923a2b)
Issue-ID: NONRTRIC-631
Signed-off-by: elinuxhenrik <henrik.b.andersson@est.tech>
Change-Id: I38d2255be7f180a10559152c385ee88fc8471ce4
}
func (jh *jobHandler) pollAndDistributeMessages(mRAddress string) {
}
func (jh *jobHandler) pollAndDistributeMessages(mRAddress string) {
- jh.mu.Lock()
- defer jh.mu.Unlock()
log.Debugf("Processing jobs for type: %v", jh.typeId)
messagesBody, error := restclient.Get(mRAddress+jh.topicUrl, jh.pollClient)
if error != nil {
log.Debugf("Processing jobs for type: %v", jh.typeId)
messagesBody, error := restclient.Get(mRAddress+jh.topicUrl, jh.pollClient)
if error != nil {
func (jh *jobHandler) distributeMessages(messages []byte) {
if len(messages) > 2 {
func (jh *jobHandler) distributeMessages(messages []byte) {
if len(messages) > 2 {
+ jh.mu.Lock()
+ defer jh.mu.Unlock()
for _, jobInfo := range jh.jobs {
go jh.sendMessagesToConsumer(messages, jobInfo)
}
for _, jobInfo := range jh.jobs {
go jh.sendMessagesToConsumer(messages, jobInfo)
}