SendClient(target, auth=None, client_name=None, debug=False, msg_timeout=0, error_policy=None, keep_alive_interval=None, **kwargs)
target
str
,
bytes
或
Target
目标 AMQP 服务终结点。 这可以是字符串或 ~uamqp.address.Target 对象的 URI。
AMQPAuth
连接的身份验证。 这应该是 uamqp.authentication.AMQPAuth 的子类之一。 目前,这包括:
uamqp.authentication.SASLAnonymous
uamqp.authentication.SASLPlain
uamqp.authentication.SASTokenAuth
uamqp.authentication.JWTTokenAuth
如果未提供身份验证,则默认使用 SASLAnnoymous。
client_name
str
或
bytes
将一个或多个消息添加到发送队列。
在调用
SendClient.wait ()
或
SendClient.send_all_messages ()
之前,不会执行进一步操作。
尚未打开客户端,就可以将消息添加到队列。 可以同时将多个消息排队:
send_client.queue_message (my_message)
send_client.queue_message (message_1、message_2、message_3)
*send_client.queue_message (
my_message_list)
将一个或多个消息添加到发送队列。
在调用
SendClient.wait ()
或
SendClient.send_all_messages ()
之前,不会执行进一步操作。
尚未打开客户端,就可以将消息添加到队列。 可以同时将多个消息排队:
send_client.queue_message (my_message)
send_client.queue_message (message_1、message_2、message_3)
*send_client.queue_message (
my_message_list)