pyflink.datastream.connectors.rabbitmq.RMQConnectionConfig

class RMQConnectionConfig(j_rmq_connection_config)

Connection Configuration for RMQ.

Methods

get_connection_timeout()
get_host()
get_network_recovery_interval()
get_password()
get_port()
get_requested_channel_max()
get_requested_frame_max()
get_requested_heartbeat()
get_uri()
get_user_name()
get_virtual_host()
is_automatic_recovery()
is_topology_recovery()