Skip to content

Commit

Permalink
update aiomqtt version
Browse files Browse the repository at this point in the history
  • Loading branch information
toxazhl committed May 20, 2024
1 parent fdee318 commit 4c99461
Show file tree
Hide file tree
Showing 3 changed files with 105 additions and 124 deletions.
11 changes: 6 additions & 5 deletions fastmqtt/fastmqtt.py
Original file line number Diff line number Diff line change
@@ -1,9 +1,8 @@
import asyncio
import logging
import ssl
from typing import Any, Callable, Iterable, Sequence
from typing import Any, Callable, Iterable, Literal, Sequence

import paho.mqtt.client as mqtt
from aiomqtt import Client as MQTTClient
from aiomqtt import (
Message,
Expand All @@ -13,6 +12,8 @@
Will,
)
from aiomqtt.types import PayloadType, SocketOption
from paho.mqtt import client as mqtt
from paho.mqtt import properties as mqtt_properties
from paho.mqtt.packettypes import PacketTypes

from .message_handler import MessageHandler
Expand All @@ -37,17 +38,17 @@ def __init__(
queue_type: type[asyncio.Queue[Message]] | None = None,
will: Will | None = None,
clean_session: bool | None = None,
transport: str = "tcp",
transport: Literal["tcp", "websockets"] = "tcp",
timeout: float | None = None,
keepalive: int = 60,
bind_address: str = "",
bind_port: int = 0,
clean_start: int = mqtt.MQTT_CLEAN_START_FIRST_ONLY,
clean_start: mqtt.CleanStartOption = mqtt.MQTT_CLEAN_START_FIRST_ONLY,
max_queued_incoming_messages: int | None = None,
max_queued_outgoing_messages: int | None = None,
max_inflight_messages: int | None = None,
max_concurrent_outgoing_calls: int | None = None,
properties: mqtt.Properties | None = None,
properties: mqtt_properties.Properties | None = None,
tls_context: ssl.SSLContext | None = None,
tls_params: TLSParameters | None = None,
tls_insecure: bool | None = None,
Expand Down
Loading

0 comments on commit 4c99461

Please sign in to comment.