def METHOD_NAME(srv, mocker, caplog):
    item = Item(
        config={"iothubname": "acmehub"},
        target="test",
        addrs=["device-id", "SharedAccessSignature sr=..."],
        message="⚽ Notification message ⚽",
    )
    module = load_module_from_file("mqttwarn/services/azure_iot.py")
    mqtt_single = mocker.patch.object(module.mqtt, "single")
    outcome = module.plugin(srv, item)
    mqtt_single.assert_called_once_with(
        "devices/device-id/messages/events/",
        bytearray(b"\xe2\x9a\xbd Notification message \xe2\x9a\xbd"),
        auth={
            "username": "acmehub.azure-devices.net/device-id/?api-version=2018-06-30",
            "password": "SharedAccessSignature sr=...",
        },
        tls={
            "ca_certs": None,
            "certfile": None,
            "keyfile": None,
            "tls_version": mock.ANY,
            "ciphers": None,
            "cert_reqs": mock.ANY,
        },
        hostname="acmehub.azure-devices.net",
        port=8883,
        protocol=4,
        qos=0,
        retain=False,
        client_id="device-id",
    )
    assert outcome is True
    assert (
        "Publishing to Azure IoT Hub for target=test (device-id): devices/device-id/messages/events/ "
        "'bytearray(b'\\xe2\\x9a\\xbd Notification message \\xe2\\x9a\\xbd')'" in caplog.messages
    )