File tree Expand file tree Collapse file tree 1 file changed +0
-35
lines changed Expand file tree Collapse file tree 1 file changed +0
-35
lines changed Original file line number Diff line number Diff line change @@ -797,38 +797,3 @@ def delete_user(self, name: str):
797
797
@delete_component .register
798
798
def _delete_user (self , user : UserSpec ):
799
799
self .delete_user (name = user .name )
800
-
801
-
802
- if __name__ == "__main__" :
803
- import time
804
-
805
- zc = zocalo .configuration .from_file ()
806
- zc .activate ()
807
- rmq = RabbitMQAPI .from_zocalo_configuration (zc )
808
- print (rmq .users ())
809
- print (rmq .users (name = "guest" ))
810
- print (rmq .queues ())
811
- print (rmq .queues (vhost = "zocalo" , name = "processing_recipe" ))
812
- # time.sleep(5)
813
- rmq .queue_declare (
814
- vhost = "zocalo" ,
815
- queue = QueueSpec (
816
- name = "foo" , auto_delete = True , arguments = {"x-single-active-consumer" : True }
817
- ),
818
- )
819
- time .sleep (5 )
820
- print (rmq .queues (vhost = "zocalo" , name = "foo" ))
821
- rmq .queue_delete (vhost = "zocalo" , name = "foo" )
822
- # print(rmq.queues(vhost="zocalo", name="foo"))
823
- for q in rmq .queues ():
824
- print (q .message_stats )
825
- print ()
826
- for ex in rmq .exchanges ():
827
- print (ex )
828
- print (rmq .exchanges (vhost = "zocalo" , name = "" ))
829
-
830
- nodes = rmq .nodes ()
831
- print (rmq .nodes (name = nodes [0 ].name ))
832
-
833
- connections = rmq .connections ()
834
- print (rmq .connections (name = connections [0 ].name ))
You can’t perform that action at this time.
0 commit comments