可以在AMQPSSLConnection构造方法中增加连接超时时间的配置,具体示例如下:
import ssl
from proton import SSLDomain, AMQPSSLConnection
ssl_domain = SSLDomain(SSLDomain.MODE_CLIENT)
ssl_domain.set_credentials("client.pem", "client-key.pem", None)
ssl_domain.set_trusted_ca_db("ca.crt")
connection = AMQPSSLConnection(
host="example.com",
port=amqp_port,
username="username",
password="password",
ssl_domain=ssl_domain,
timeout=10) # 连接超时时间为10秒