File tree Expand file tree Collapse file tree 1 file changed +4
-7
lines changed Expand file tree Collapse file tree 1 file changed +4
-7
lines changed Original file line number Diff line number Diff line change @@ -1356,20 +1356,17 @@ def test_get_partitioned_topic_name(self):
13561356 client .close ()
13571357
13581358 def test_shutdown_client (self ):
1359- client = Client (self .serviceUrl ,
1360- logger = pulsar .ConsoleLogger (pulsar .LoggerLevel .Debug ))
1361- producer = client .create_producer ("persistent://public/default/test_shutdown_client" )
1359+ client = Client (self .serviceUrl )
1360+ producer = client .create_producer ("persistent://public/default/partitioned_topic_name_test" )
13621361 producer .send (b"hello" )
13631362 client .shutdown ()
13641363
13651364 try :
13661365 producer .send (b"hello" )
13671366 self .assertTrue (False )
1368- except pulsar .PulsarException as e :
1369- print (f'{ type (e )} | { e } ' )
1367+ except pulsar .PulsarException :
13701368 # Expected
1371- time .sleep (1 )
1372- print ('done' )
1369+ pass
13731370
13741371 def test_listener_name_client (self ):
13751372 client = Client (self .serviceUrl , listener_name = 'test' )
You can’t perform that action at this time.
0 commit comments