             dispatchPrecondition(condition: .onQueue(queue))
         }
         
-        print("Before \(events.count)")
-        
         guard !events.isEmpty else {
             return
         }

        ack.forEach { (cfg) in
            events.removeValue(forKey: cfg.intValue)
        }
        print("After \(events.count)")
        
        guard transport?.isConnected == true,
            !events.isEmpty else

            if let cfn = confirmNumber {
                events[cfn] = data
            }
        } else {
            // else save to publish later when connection restore
            items.append(data)
        }
    }
    
