• MqttBroker
  • MqttBroker Class

    (nymeaserver::MqttBroker)
    Inherits:

    Public Functions

    MqttBroker(QObject * parent = nullptr)
    ~MqttBroker()
    QList<ServerConfiguration> configurations() const
    bool isRunning(const QString & configId) const
    bool isRunning() const
    QList<MqttPolicy> policies()
    MqttPolicy policy(const QString & clientId)
    void publish(const QString & topic, const QByteArray & payload)
    bool removePolicy(const QString & clientId)
    bool startServer(const ServerConfiguration & config, const QSslConfiguration & sslConfiguration = QSslConfiguration())
    void stopServer(const QString & configId)
    void updatePolicies(const QList<MqttPolicy> & policies)
    void updatePolicy(const MqttPolicy & policy)

    Signals

    void clientConnected(const QString & clientId)
    void clientDisconnected(const QString & clientId)
    void clientSubscribed(const QString & clientId, const QString & topicFilter)
    void clientUnsubscribed(const QString & clientId, const QString & topicFilter)
    void policyAdded(const MqttPolicy & policy)
    void policyChanged(const MqttPolicy & policy)
    void policyRemoved(const MqttPolicy & policy)
    void publishReceived(const QString & clientId, const QString & topic, const QByteArray & payload)

    Member Function Documentation

    MqttBroker::MqttBroker(QObject * parent = nullptr)

    MqttBroker::~MqttBroker()

    [signal] void MqttBroker::clientConnected(const QString & clientId)

    [signal] void MqttBroker::clientDisconnected(const QString & clientId)

    [signal] void MqttBroker::clientSubscribed(const QString & clientId, const QString & topicFilter)

    [signal] void MqttBroker::clientUnsubscribed(const QString & clientId, const QString & topicFilter)

    QList<ServerConfiguration> MqttBroker::configurations() const

    bool MqttBroker::isRunning(const QString & configId) const

    bool MqttBroker::isRunning() const

    QList<MqttPolicy> MqttBroker::policies()

    MqttPolicy MqttBroker::policy(const QString & clientId)

    [signal] void MqttBroker::policyAdded(const MqttPolicy & policy)

    [signal] void MqttBroker::policyChanged(const MqttPolicy & policy)

    [signal] void MqttBroker::policyRemoved(const MqttPolicy & policy)

    void MqttBroker::publish(const QString & topic, const QByteArray & payload)

    [signal] void MqttBroker::publishReceived(const QString & clientId, const QString & topic, const QByteArray & payload)

    bool MqttBroker::removePolicy(const QString & clientId)

    bool MqttBroker::startServer(const ServerConfiguration & config, const QSslConfiguration & sslConfiguration = QSslConfiguration())

    void MqttBroker::stopServer(const QString & configId)

    void MqttBroker::updatePolicies(const QList<MqttPolicy> & policies)

    void MqttBroker::updatePolicy(const MqttPolicy & policy)