(self, connection=None, hostname=None, enabled=True,
channel=None, buffer_while_offline=True, app=None,
serializer=None, groups=None, delivery_mode=1,
buffer_group=None, buffer_limit=24, on_send_buffered=None)
| 56 | on_disabled = None |
| 57 | |
| 58 | def __init__(self, connection=None, hostname=None, enabled=True, |
| 59 | channel=None, buffer_while_offline=True, app=None, |
| 60 | serializer=None, groups=None, delivery_mode=1, |
| 61 | buffer_group=None, buffer_limit=24, on_send_buffered=None): |
| 62 | self.app = app_or_default(app or self.app) |
| 63 | self.connection = connection |
| 64 | self.channel = channel |
| 65 | self.hostname = hostname or anon_nodename() |
| 66 | self.buffer_while_offline = buffer_while_offline |
| 67 | self.buffer_group = buffer_group or frozenset() |
| 68 | self.buffer_limit = buffer_limit |
| 69 | self.on_send_buffered = on_send_buffered |
| 70 | self._group_buffer = defaultdict(list) |
| 71 | self.mutex = threading.Lock() |
| 72 | self.producer = None |
| 73 | self._outbound_buffer = deque() |
| 74 | self.serializer = serializer or self.app.conf.event_serializer |
| 75 | self.on_enabled = set() |
| 76 | self.on_disabled = set() |
| 77 | self.groups = set(groups or []) |
| 78 | self.tzoffset = [-time.timezone, -time.altzone] |
| 79 | self.clock = self.app.clock |
| 80 | self.delivery_mode = delivery_mode |
| 81 | if not connection and channel: |
| 82 | self.connection = channel.connection.client |
| 83 | self.enabled = enabled |
| 84 | conninfo = self.connection or self.app.connection_for_write() |
| 85 | self.exchange = get_exchange(conninfo, |
| 86 | name=self.app.conf.event_exchange) |
| 87 | if conninfo.transport.driver_type in self.DISABLED_TRANSPORTS: |
| 88 | self.enabled = False |
| 89 | if self.enabled: |
| 90 | self.enable() |
| 91 | self.headers = {'hostname': self.hostname} |
| 92 | self.pid = os.getpid() |
| 93 | |
| 94 | def __enter__(self): |
| 95 | return self |
nothing calls this directly
no test coverage detected