Class AMSSyncProducer¶

Defined in File rmq.py

Inheritance Relationships¶

Derived Type¶

public rmq.AMSFanOutProducer (Class AMSFanOutProducer)

Class Documentation¶

class AMSSyncProducer¶

Subclassed by rmq.AMSFanOutProducer

Public Functions

__init__(self, str host, int port, str vhost, str user, str password, str cert, str publish_queue, Optional[logging.Logger] logger=None)¶

open(self)¶

close(self)¶

__enter__(self)¶

__exit__(self, exc_type, exc_val, exc_tb)¶

send_message(self, message)¶

Public Members

host¶

port¶

vhost¶

user¶

password¶

cert¶

connection_parameters¶

connection¶

channel¶

Protected Attributes

_connected¶

_publish_queue¶

_num_sent_messages¶

_num_confirmed_messages¶