View GitHub Repository fullcycle

Schedule Inspection
Subscribe
Passed
Push — master ( 1bf5cf...d6ff14 )
by Dave
02:20
created

tests.func_broadcast   A

↳ Parent: Project

Complexity

Total Complexity 0

Size/Duplication

Total Lines 12
Duplicated Lines 0 %

Importance

Changes 0
Metric Value
eloc 7
dl 0
loc 12
rs 10
c 0
b 0
f 0
wmc 0
1 
'''test broadcast'''
2 
from helpers.queuehelper import BroadcastSender, QueueName
3 
#from messaging.messages import *
4 
#from domain import mining, rep
5 
from backend.fcmapp import ApplicationService, ServiceName
6 

            


            
                                                        
            
                                    
            
            

                
                    7
                

                                    
                                                    
                
                
                
APP = ApplicationService()

            


            
                                                        
            
                                    
            
            

                
                    8
                

                                    
                                                    
                
                
                

            


            
                                                        
            
                                    
            
            

                
                    9
                

                                    
                                                    
                
                
                
QBROAD = BroadcastSender(QueueName.Q_LOG, APP.getservice(ServiceName.messagebus))

            


            
                                                        
            
                                    
            
            

                
                    10
                

                                    
                                                    
                
                
                
QBROAD.broadcast('{0} WORKING! test_broadcast {1}'.format(APP.now(), QBROAD.queue_name))

            


            
                                                        
            
                                    
            
            

                
                    11
                

                                    
                                                    
                
                
                
QBROAD.close()

            


            
                                                        
            
                                    
            
            

                
                    12