cli_proton_python.connector module

Proton reactive API python connector client

class cli_proton_python.connector.Connector(opts)

Bases: cli_proton_python.coreclient.CoreClient

Proton reactive API python connector client

close_objects()

closes all the open objects (after given close-sleep time)

get_conn_result()

returns the connection statistics triplet

connection statistictriplets are:

* connections opened, connections errors, connection requests

* connection requests stat is ignored, set to 1 for backwards compatibility

Returns:connector statistics triplet Return type:tuple

get_result()

called when the reactor’s exit

Returns:error message Return type:str

on_connection_opened(event)

called when the connection is opened

Parameters:event (proton.Event) – reactor event

on_connection_remote_open(event)

called when the remote connection is opening

Parameters:event (proton.Event) – reactor event

on_link_opened(event)

called when the link is opened

Parameters:event (proton.Event) – reactor event

on_session_opened(event)

called when the session is opened

Parameters:event (proton.Event) – reactor event

on_start(event)

called when the event loop starts

Parameters:event (proton.Event) – reactor event

on_transport_error(event)

called when the connection can’t be opened due to transport error

Parameters:event (proton.Event) – reactor event

cli_proton_python.connector.main()

main loop

cli_proton_python.connector.run_connectors(opts, results, errors, stats=None)

thread worker function

Parameters:

• opts (optparse.Values instance) – connector client options
• results (list) – list of connection results
• errors (int) – number of connection errors
• stats (list) – list containing statistics dictionary (default: None)