Commit 66284d48 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

NBI component - VNTM Recommendations: 

- Corrected namespace name
- Corrected Kafka listener logic
parent 6c3da65d

src/nbi/service/vntm_recommend/Constants.py

+2 −2
Original line number Diff line number Diff line
@@ -13,5 +13,5 @@ 
# limitations under the License.





SIO_NAMESPACE = '/vnt-recomm'

SIO_ROOM      = 'vnt-recomm'
 
SIO_NAMESPACE = '/recommendations'

SIO_ROOM      = 'recommendations'

src/nbi/service/vntm_recommend/VntRecommThread.py

+1 −1
Original line number Diff line number Diff line
@@ -50,7 +50,7 @@ class VntRecommThread(threading.Thread): 
            while not self._terminate.is_set():

                topic_records : Dict[TopicPartition, List[ConsumerRecord]] = \

                    kafka_consumer.poll(timeout_ms=1000, max_records=1)

                if len(topic_records) == 0: return  # no pending records

                if len(topic_records) == 0: continue    # no pending records

                self.process_topic_records(topic_records)



            LOGGER.info('[run] Closing...')