equal
deleted
inserted
replaced
416 tx_dropped_stanzas:sample(unacked); |
416 tx_dropped_stanzas:sample(unacked); |
417 session.smacks = false; -- Disable queueing |
417 session.smacks = false; -- Disable queueing |
418 session.outgoing_stanza_queue = nil; |
418 session.outgoing_stanza_queue = nil; |
419 for stanza in queue._queue:consume() do |
419 for stanza in queue._queue:consume() do |
420 if not module:fire_event("delivery/failure", { session = session, stanza = stanza }) then |
420 if not module:fire_event("delivery/failure", { session = session, stanza = stanza }) then |
421 if stanza.attr.type ~= "error" and stanza.attr.to ~= session.full_jid then |
421 if stanza.attr.type ~= "error" and stanza.attr.from ~= session.full_jid then |
422 local reply = st.error_reply(stanza, "cancel", "recipient-unavailable"); |
422 local reply = st.error_reply(stanza, "cancel", "recipient-unavailable"); |
423 core_process_stanza(session, reply); |
423 core_process_stanza(session, reply); |
424 end |
424 end |
425 end |
425 end |
426 end |
426 end |