1.07 anywheresoftware.b4j.objects.MqttBroker MqttBroker process SetUserAndPassword The server will only allow connections with the provided user names and password. void Username java.lang.String Password java.lang.String Start Starts the server. void Stop Stops the server. void Initialize Initializes the broker and sets the broker port (currently there are no events). void EventName java.lang.String Port int DebugLog b boolean io.moquette.BrokerConstants process DEFAULT_MOQUETTE_STORE_H2_DB_FILENAME java.lang.String BUGSNAG_TOKEN_PROPERTY_NAME java.lang.String PASSWORD_FILE_PROPERTY_NAME java.lang.String HOST java.lang.String BROKER_INTERCEPTOR_THREAD_POOL_SIZE java.lang.String DISABLED_PORT_BIND java.lang.String WEB_SOCKET_PORT_PROPERTY_NAME java.lang.String NETTY_MAX_BYTES_PROPERTY_NAME java.lang.String METRICS_LIBRATO_EMAIL_PROPERTY_NAME java.lang.String NETTY_EPOLL_PROPERTY_NAME java.lang.String DEFAULT_NETTY_MAX_BYTES_IN_MESSAGE int SSL_PORT_PROPERTY_NAME java.lang.String HOST_PROPERTY_NAME java.lang.String ALLOW_ANONYMOUS_PROPERTY_NAME java.lang.String AUTHORIZATOR_CLASS_NAME java.lang.String DB_AUTHENTICATOR_DIGEST java.lang.String NETTY_TCP_NODELAY_PROPERTY_NAME java.lang.String AUTOSAVE_INTERVAL_PROPERTY_NAME java.lang.String SSL_PROVIDER Defines the SSL implementation to use, default to "JDK". java.lang.String INTERCEPT_HANDLER_PROPERTY_NAME java.lang.String BUGSNAG_ENABLE_PROPERTY_NAME java.lang.String PORT int KEY_STORE_PASSWORD_PROPERTY_NAME java.lang.String PERSISTENT_STORE_PROPERTY_NAME java.lang.String ALLOW_ZERO_BYTE_CLIENT_ID_PROPERTY_NAME java.lang.String AUTHENTICATOR_CLASS_NAME java.lang.String WEBSOCKET_PORT int DB_AUTHENTICATOR_URL java.lang.String NETTY_SO_KEEPALIVE_PROPERTY_NAME java.lang.String METRICS_LIBRATO_TOKEN_PROPERTY_NAME java.lang.String NETTY_SO_REUSEADDR_PROPERTY_NAME java.lang.String KEY_MANAGER_PASSWORD_PROPERTY_NAME java.lang.String STORAGE_CLASS_NAME java.lang.String METRICS_ENABLE_PROPERTY_NAME java.lang.String PORT_PROPERTY_NAME java.lang.String KEY_STORE_TYPE java.lang.String JKS_PATH_PROPERTY_NAME java.lang.String ACL_FILE_PROPERTY_NAME java.lang.String REAUTHORIZE_SUBSCRIPTIONS_ON_CONNECT java.lang.String DB_AUTHENTICATOR_DRIVER java.lang.String METRICS_LIBRATO_SOURCE_PROPERTY_NAME java.lang.String NEED_CLIENT_AUTH java.lang.String NETTY_CHANNEL_TIMEOUT_SECONDS_PROPERTY_NAME java.lang.String DB_AUTHENTICATOR_QUERY java.lang.String DEFAULT_PERSISTENT_PATH java.lang.String NETTY_SO_BACKLOG_PROPERTY_NAME java.lang.String WSS_PORT_PROPERTY_NAME java.lang.String io.moquette.broker.AutoFlushHandler Auto-flush data on channel after a read timeout. It's inspired by IdleStateHandler but it's specialized version, just flushing data after no read is done on the channel after a period. It's used to avoid aggressively flushing from the ProtocolProcessor. process disconnect void arg0 io.netty.channel.ChannelHandlerContext arg1 io.netty.channel.ChannelPromise read void arg0 io.netty.channel.ChannelHandlerContext channelReadComplete void arg0 io.netty.channel.ChannelHandlerContext deregister void arg0 io.netty.channel.ChannelHandlerContext arg1 io.netty.channel.ChannelPromise channelActive void ctx io.netty.channel.ChannelHandlerContext exceptionCaught void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Throwable handlerAdded void ctx io.netty.channel.ChannelHandlerContext isSharable boolean handlerRemoved void ctx io.netty.channel.ChannelHandlerContext ensureNotSharable void channelRead void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Object channelWritabilityChanged void arg0 io.netty.channel.ChannelHandlerContext channelInactive void ctx io.netty.channel.ChannelHandlerContext channelUnregistered void arg0 io.netty.channel.ChannelHandlerContext bind void arg0 io.netty.channel.ChannelHandlerContext arg1 java.net.SocketAddress arg2 io.netty.channel.ChannelPromise flush void arg0 io.netty.channel.ChannelHandlerContext userEventTriggered void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Object channelRegistered void ctx io.netty.channel.ChannelHandlerContext close void arg0 io.netty.channel.ChannelHandlerContext arg1 io.netty.channel.ChannelPromise write void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Object arg2 io.netty.channel.ChannelPromise connect void arg0 io.netty.channel.ChannelHandlerContext arg1 java.net.SocketAddress arg2 java.net.SocketAddress arg3 io.netty.channel.ChannelPromise io.moquette.broker.BugSnagErrorsHandler process init void props io.moquette.broker.config.IConfig channelReadComplete void arg0 io.netty.channel.ChannelHandlerContext exceptionCaught void ctx io.netty.channel.ChannelHandlerContext cause java.lang.Throwable channelActive void arg0 io.netty.channel.ChannelHandlerContext handlerAdded void arg0 io.netty.channel.ChannelHandlerContext isSharable boolean ensureNotSharable void handlerRemoved void arg0 io.netty.channel.ChannelHandlerContext channelRead void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Object channelWritabilityChanged void arg0 io.netty.channel.ChannelHandlerContext channelInactive void arg0 io.netty.channel.ChannelHandlerContext channelUnregistered void arg0 io.netty.channel.ChannelHandlerContext userEventTriggered void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Object channelRegistered void arg0 io.netty.channel.ChannelHandlerContext io.moquette.broker.ClientDescriptor process hashCode int equals boolean o java.lang.Object toString java.lang.String Address java.lang.String Port int ClientID java.lang.String io.moquette.broker.DebugUtils process payload2Str java.lang.String content io.netty.buffer.ByteBuf io.moquette.broker.InflightResender Resend inflight not ack'ed publish packets (QoS1 PUB and QoS2 PUB/PUBREL). It's inspired by IdleStateHandler but it's specialized version, just invoking Session's resendInflightNotAcked by the channel after a period. process disconnect void arg0 io.netty.channel.ChannelHandlerContext arg1 io.netty.channel.ChannelPromise read void arg0 io.netty.channel.ChannelHandlerContext channelReadComplete void arg0 io.netty.channel.ChannelHandlerContext deregister void arg0 io.netty.channel.ChannelHandlerContext arg1 io.netty.channel.ChannelPromise channelActive void ctx io.netty.channel.ChannelHandlerContext exceptionCaught void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Throwable handlerAdded void ctx io.netty.channel.ChannelHandlerContext isSharable boolean handlerRemoved void ctx io.netty.channel.ChannelHandlerContext ensureNotSharable void channelRead void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Object channelWritabilityChanged void arg0 io.netty.channel.ChannelHandlerContext channelInactive void ctx io.netty.channel.ChannelHandlerContext channelUnregistered void arg0 io.netty.channel.ChannelHandlerContext bind void arg0 io.netty.channel.ChannelHandlerContext arg1 java.net.SocketAddress arg2 io.netty.channel.ChannelPromise flush void arg0 io.netty.channel.ChannelHandlerContext userEventTriggered void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Object channelRegistered void ctx io.netty.channel.ChannelHandlerContext close void arg0 io.netty.channel.ChannelHandlerContext arg1 io.netty.channel.ChannelPromise write void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Object arg2 io.netty.channel.ChannelPromise connect void arg0 io.netty.channel.ChannelHandlerContext arg1 java.net.SocketAddress arg2 java.net.SocketAddress arg3 io.netty.channel.ChannelPromise io.moquette.broker.InflightResender.ResendNotAckedPublishes Placeholder event to resend not-acked publish messages in the in flight window. process io.moquette.broker.MemoryQueueRepository process createQueue java.util.Queue cli java.lang.String clean boolean io.moquette.broker.MoquetteIdleTimeoutHandler process disconnect void arg0 io.netty.channel.ChannelHandlerContext arg1 io.netty.channel.ChannelPromise read void arg0 io.netty.channel.ChannelHandlerContext channelReadComplete void arg0 io.netty.channel.ChannelHandlerContext deregister void arg0 io.netty.channel.ChannelHandlerContext arg1 io.netty.channel.ChannelPromise channelActive void arg0 io.netty.channel.ChannelHandlerContext exceptionCaught void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Throwable handlerAdded void arg0 io.netty.channel.ChannelHandlerContext isSharable boolean ensureNotSharable void handlerRemoved void arg0 io.netty.channel.ChannelHandlerContext channelRead void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Object channelWritabilityChanged void arg0 io.netty.channel.ChannelHandlerContext channelInactive void arg0 io.netty.channel.ChannelHandlerContext channelUnregistered void arg0 io.netty.channel.ChannelHandlerContext bind void arg0 io.netty.channel.ChannelHandlerContext arg1 java.net.SocketAddress arg2 io.netty.channel.ChannelPromise flush void arg0 io.netty.channel.ChannelHandlerContext userEventTriggered void ctx io.netty.channel.ChannelHandlerContext evt java.lang.Object channelRegistered void arg0 io.netty.channel.ChannelHandlerContext close void arg0 io.netty.channel.ChannelHandlerContext arg1 io.netty.channel.ChannelPromise write void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Object arg2 io.netty.channel.ChannelPromise connect void arg0 io.netty.channel.ChannelHandlerContext arg1 java.net.SocketAddress arg2 java.net.SocketAddress arg3 io.netty.channel.ChannelPromise io.moquette.broker.NettyUtils Some Netty's channels utilities. process getAttribute java.lang.Object ctx io.netty.channel.ChannelHandlerContext key io.netty.util.AttributeKey keepAlive void channel io.netty.channel.Channel keepAlive int clientID void channel io.netty.channel.Channel clientID java.lang.String userName void channel io.netty.channel.Channel username java.lang.String cleanSession void channel io.netty.channel.Channel cleanSession boolean ATTR_USERNAME java.lang.String io.moquette.broker.NewNettyMQTTHandler process channelReadComplete void arg0 io.netty.channel.ChannelHandlerContext channelActive void ctx io.netty.channel.ChannelHandlerContext exceptionCaught void ctx io.netty.channel.ChannelHandlerContext cause java.lang.Throwable handlerAdded void arg0 io.netty.channel.ChannelHandlerContext isSharable boolean ensureNotSharable void handlerRemoved void arg0 io.netty.channel.ChannelHandlerContext channelRead void ctx io.netty.channel.ChannelHandlerContext message java.lang.Object channelWritabilityChanged void ctx io.netty.channel.ChannelHandlerContext channelInactive void ctx io.netty.channel.ChannelHandlerContext channelUnregistered void arg0 io.netty.channel.ChannelHandlerContext userEventTriggered void ctx io.netty.channel.ChannelHandlerContext evt java.lang.Object channelRegistered void arg0 io.netty.channel.ChannelHandlerContext io.moquette.broker.RetainedMessage process qosLevel io.netty.handler.codec.mqtt.MqttQoS Payload byte[] io.moquette.broker.Server process addInterceptHandler SPI method used by Broker embedded applications to add intercept handlers. interceptHandler: the handler to add. void interceptHandler io.moquette.interception.InterceptHandler startServer Starts Moquette bringing the configuration from the file located at m_config/moquette.conf void internalPublish Use the broker to publish a message. It's intended for embedding applications. It can be used only after the integration is correctly started with startServer. msg: the message to forward. clientId: the id of the sending integration. void msg io.netty.handler.codec.mqtt.MqttPublishMessage clientId java.lang.String stopServer void removeInterceptHandler SPI method used by Broker embedded applications to remove intercept handlers. interceptHandler: the handler to remove. void interceptHandler io.moquette.interception.InterceptHandler main void args java.lang.String[] io.moquette.broker.SessionCorruptedException process printStackTrace void addSuppressed void arg0 java.lang.Throwable initCause java.lang.Throwable arg0 java.lang.Throwable toString java.lang.String fillInStackTrace java.lang.Throwable Message java.lang.String StackTrace java.lang.StackTraceElement[] arg0 java.lang.StackTraceElement[] Suppressed java.lang.Throwable[] Cause java.lang.Throwable LocalizedMessage java.lang.String io.moquette.broker.SessionRegistry process disconnect void clientID java.lang.String remove void clientID java.lang.String io.moquette.broker.SessionRegistry.EnqueuedMessage process io.moquette.broker.Utils Utility static methods, like Map get with default value, or elvis operator. process readBytesAndRewind byte[] payload io.netty.buffer.ByteBuf defaultGet T map java.util.Map key K defaultValue T messageId int msg io.netty.handler.codec.mqtt.MqttMessage io.moquette.broker.config.ClasspathResourceLoader process loadResource java.io.Reader relativePath java.lang.String loadDefaultResource java.io.Reader Name java.lang.String io.moquette.broker.config.FileResourceLoader process loadResource java.io.Reader relativePath java.lang.String loadDefaultResource java.io.Reader Name java.lang.String io.moquette.broker.config.IConfig Base interface for all configuration implementations (filesystem, memory or classpath) process getProperty Same semantic of Properties name: property name. Return type: @return:property value. java.lang.String name java.lang.String boolProp boolean propertyName java.lang.String defaultValue boolean setProperty void name java.lang.String value java.lang.String intProp int propertyName java.lang.String defaultValue int ResourceLoader io.moquette.broker.config.IResourceLoader DEFAULT_CONFIG java.lang.String io.moquette.broker.config.IResourceLoader.ResourceIsDirectoryException process printStackTrace void addSuppressed void arg0 java.lang.Throwable initCause java.lang.Throwable arg0 java.lang.Throwable toString java.lang.String fillInStackTrace java.lang.Throwable Message java.lang.String StackTrace java.lang.StackTraceElement[] arg0 java.lang.StackTraceElement[] Suppressed java.lang.Throwable[] Cause java.lang.Throwable LocalizedMessage java.lang.String io.moquette.broker.config.MemoryConfig Configuration backed by memory. process getProperty Same semantic of Properties name: property name. Return type: @return:property value. java.lang.String name java.lang.String boolProp boolean propertyName java.lang.String defaultValue boolean setProperty void name java.lang.String value java.lang.String intProp int propertyName java.lang.String defaultValue int ResourceLoader io.moquette.broker.config.IResourceLoader DEFAULT_CONFIG java.lang.String io.moquette.broker.config.ResourceLoaderConfig Configuration that loads config stream from a {@link IResourceLoader} instance. process getProperty Same semantic of Properties name: property name. Return type: @return:property value. java.lang.String name java.lang.String boolProp boolean propertyName java.lang.String defaultValue boolean setProperty void name java.lang.String value java.lang.String intProp int propertyName java.lang.String defaultValue int ResourceLoader io.moquette.broker.config.IResourceLoader DEFAULT_CONFIG java.lang.String io.moquette.broker.metrics.BytesMetrics process wroteBytes long readBytes long io.moquette.broker.metrics.BytesMetricsCollector Collects all the metrics from the various pipeline. process sumWroteBytes void count long sumReadBytes void count long computeMetrics io.moquette.broker.metrics.BytesMetrics io.moquette.broker.metrics.BytesMetricsHandler process disconnect void arg0 io.netty.channel.ChannelHandlerContext arg1 io.netty.channel.ChannelPromise read void arg0 io.netty.channel.ChannelHandlerContext channelReadComplete void arg0 io.netty.channel.ChannelHandlerContext getBytesMetrics io.moquette.broker.metrics.BytesMetrics channel io.netty.channel.Channel deregister void arg0 io.netty.channel.ChannelHandlerContext arg1 io.netty.channel.ChannelPromise channelActive void ctx io.netty.channel.ChannelHandlerContext exceptionCaught void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Throwable handlerAdded void arg0 io.netty.channel.ChannelHandlerContext isSharable boolean ensureNotSharable void handlerRemoved void arg0 io.netty.channel.ChannelHandlerContext channelRead void ctx io.netty.channel.ChannelHandlerContext msg java.lang.Object channelWritabilityChanged void arg0 io.netty.channel.ChannelHandlerContext channelInactive void arg0 io.netty.channel.ChannelHandlerContext channelUnregistered void arg0 io.netty.channel.ChannelHandlerContext bind void arg0 io.netty.channel.ChannelHandlerContext arg1 java.net.SocketAddress arg2 io.netty.channel.ChannelPromise flush void arg0 io.netty.channel.ChannelHandlerContext userEventTriggered void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Object channelRegistered void arg0 io.netty.channel.ChannelHandlerContext write void ctx io.netty.channel.ChannelHandlerContext msg java.lang.Object promise io.netty.channel.ChannelPromise close void ctx io.netty.channel.ChannelHandlerContext promise io.netty.channel.ChannelPromise connect void arg0 io.netty.channel.ChannelHandlerContext arg1 java.net.SocketAddress arg2 java.net.SocketAddress arg3 io.netty.channel.ChannelPromise io.moquette.broker.metrics.DropWizardMetricsHandler Pipeline handler use to track some MQTT metrics. process init void props io.moquette.broker.config.IConfig channelReadComplete void arg0 io.netty.channel.ChannelHandlerContext channelActive void arg0 io.netty.channel.ChannelHandlerContext exceptionCaught void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Throwable handlerAdded void arg0 io.netty.channel.ChannelHandlerContext isSharable boolean ensureNotSharable void handlerRemoved void arg0 io.netty.channel.ChannelHandlerContext channelRead void ctx io.netty.channel.ChannelHandlerContext message java.lang.Object channelWritabilityChanged void arg0 io.netty.channel.ChannelHandlerContext channelInactive void ctx io.netty.channel.ChannelHandlerContext channelUnregistered void arg0 io.netty.channel.ChannelHandlerContext userEventTriggered void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Object channelRegistered void arg0 io.netty.channel.ChannelHandlerContext io.moquette.broker.metrics.MessageMetrics process messagesRead long messagesWrote long io.moquette.broker.metrics.MessageMetricsCollector Collects all the metrics from the various pipeline. process sumWroteMessages void count long sumReadMessages void count long computeMetrics io.moquette.broker.metrics.MessageMetrics io.moquette.broker.metrics.MessageMetricsHandler process disconnect void arg0 io.netty.channel.ChannelHandlerContext arg1 io.netty.channel.ChannelPromise read void arg0 io.netty.channel.ChannelHandlerContext channelReadComplete void arg0 io.netty.channel.ChannelHandlerContext deregister void arg0 io.netty.channel.ChannelHandlerContext arg1 io.netty.channel.ChannelPromise channelActive void ctx io.netty.channel.ChannelHandlerContext exceptionCaught void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Throwable handlerAdded void arg0 io.netty.channel.ChannelHandlerContext isSharable boolean ensureNotSharable void handlerRemoved void arg0 io.netty.channel.ChannelHandlerContext channelRead void ctx io.netty.channel.ChannelHandlerContext msg java.lang.Object channelWritabilityChanged void arg0 io.netty.channel.ChannelHandlerContext channelInactive void arg0 io.netty.channel.ChannelHandlerContext channelUnregistered void arg0 io.netty.channel.ChannelHandlerContext bind void arg0 io.netty.channel.ChannelHandlerContext arg1 java.net.SocketAddress arg2 io.netty.channel.ChannelPromise getMessageMetrics io.moquette.broker.metrics.MessageMetrics channel io.netty.channel.Channel flush void arg0 io.netty.channel.ChannelHandlerContext userEventTriggered void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Object channelRegistered void arg0 io.netty.channel.ChannelHandlerContext write void ctx io.netty.channel.ChannelHandlerContext msg java.lang.Object promise io.netty.channel.ChannelPromise close void ctx io.netty.channel.ChannelHandlerContext promise io.netty.channel.ChannelPromise connect void arg0 io.netty.channel.ChannelHandlerContext arg1 java.net.SocketAddress arg2 java.net.SocketAddress arg3 io.netty.channel.ChannelPromise io.moquette.broker.metrics.MQTTMessageLogger process disconnect void arg0 io.netty.channel.ChannelHandlerContext arg1 io.netty.channel.ChannelPromise read void arg0 io.netty.channel.ChannelHandlerContext channelReadComplete void arg0 io.netty.channel.ChannelHandlerContext deregister void arg0 io.netty.channel.ChannelHandlerContext arg1 io.netty.channel.ChannelPromise channelActive void arg0 io.netty.channel.ChannelHandlerContext exceptionCaught void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Throwable handlerAdded void arg0 io.netty.channel.ChannelHandlerContext isSharable boolean ensureNotSharable void handlerRemoved void arg0 io.netty.channel.ChannelHandlerContext channelRead void ctx io.netty.channel.ChannelHandlerContext message java.lang.Object channelWritabilityChanged void arg0 io.netty.channel.ChannelHandlerContext channelInactive void ctx io.netty.channel.ChannelHandlerContext channelUnregistered void arg0 io.netty.channel.ChannelHandlerContext bind void arg0 io.netty.channel.ChannelHandlerContext arg1 java.net.SocketAddress arg2 io.netty.channel.ChannelPromise flush void arg0 io.netty.channel.ChannelHandlerContext userEventTriggered void arg0 io.netty.channel.ChannelHandlerContext arg1 java.lang.Object channelRegistered void arg0 io.netty.channel.ChannelHandlerContext write void ctx io.netty.channel.ChannelHandlerContext msg java.lang.Object promise io.netty.channel.ChannelPromise close void arg0 io.netty.channel.ChannelHandlerContext arg1 io.netty.channel.ChannelPromise connect void arg0 io.netty.channel.ChannelHandlerContext arg1 java.net.SocketAddress arg2 java.net.SocketAddress arg3 io.netty.channel.ChannelPromise io.moquette.broker.security.AcceptAllAuthenticator process checkValid boolean clientId java.lang.String username java.lang.String password byte[] io.moquette.broker.security.ACLFileParser Parses the acl configuration file. If a line starts with # it's comment. Blank lines are skipped. The format is "topic [read|write|readwrite] {topic name}" process parse Parse the configuration from file. file: to parse Return type: @return:the collector of authorizations form reader passed into. io.moquette.broker.security.AuthorizationsCollector file java.io.File io.moquette.broker.security.Authorization Carries the read/write authorization to topics for the users. process hashCode int equals boolean o java.lang.Object grant boolean desiredPermission io.moquette.broker.security.Authorization.Permission topic io.moquette.broker.subscriptions.Topic permission io.moquette.broker.security.Authorization.Permission io.moquette.broker.security.DBAuthenticator Load user credentials from a SQL database. sql driver must be provided at runtime process checkValid boolean clientId java.lang.String username java.lang.String password byte[] io.moquette.broker.security.DenyAllAuthorizatorPolicy process canRead boolean topic io.moquette.broker.subscriptions.Topic user java.lang.String client java.lang.String canWrite boolean topic io.moquette.broker.subscriptions.Topic user java.lang.String client java.lang.String io.moquette.broker.security.FileAuthenticator Load user credentials from a text file. Each line of the file is formatted as "[username]:[sha256(password)]". The username mustn't contains : char. To encode your password from command line on Linux systems, you could use: <pre> echo -n "yourpassword" | sha256sum </pre> NB -n is important because echo append a newline by default at the of string. -n avoid this behaviour. process checkValid boolean clientId java.lang.String username java.lang.String password byte[] LOG org.slf4j.Logger io.moquette.broker.security.PermitAllAuthorizatorPolicy process canRead boolean topic io.moquette.broker.subscriptions.Topic user java.lang.String client java.lang.String canWrite boolean topic io.moquette.broker.subscriptions.Topic user java.lang.String client java.lang.String io.moquette.broker.security.ResourceAuthenticator Load user credentials from a text resource. Each line of the file is formatted as "[username]:[sha256(password)]". The username mustn't contains : char. To encode your password from command line on Linux systems, you could use: <pre> echo -n "yourpassword" | sha256sum </pre> NB -n is important because echo append a newline by default at the of string. -n avoid this behaviour. process checkValid boolean clientId java.lang.String username java.lang.String password byte[] LOG org.slf4j.Logger io.moquette.broker.subscriptions.CTrie process dumpTree java.lang.String size int addToTree void newSubscription io.moquette.broker.subscriptions.Subscription removeFromTree void topic io.moquette.broker.subscriptions.Topic clientID java.lang.String recursiveMatch java.util.Set topic io.moquette.broker.subscriptions.Topic io.moquette.broker.subscriptions.CTrieSubscriptionDirectory process add void newSubscription io.moquette.broker.subscriptions.Subscription init void subscriptionsRepository io.moquette.broker.ISubscriptionsRepository dumpTree java.lang.String size int removeSubscription Removes subscription from CTrie, adds TNode when the last client unsubscribes, then calls for cleanTomb in a separate atomic CAS operation. topic: the subscription's topic to remove. clientID: the Id of client owning the subscription. void topic io.moquette.broker.subscriptions.Topic clientID java.lang.String matchQosSharpening java.util.Set topic io.moquette.broker.subscriptions.Topic matchWithoutQosSharpening Given a topic string return the clients subscriptions that matches it. Topic string can't contain character # and + because they are reserved to listeners subscriptions, and not topic publishing. topic: to use fo searching matching subscriptions. Return type: @return:the list of matching subscriptions, or empty if not matching. java.util.Set topic io.moquette.broker.subscriptions.Topic io.moquette.broker.subscriptions.Subscription Maintain the information about which Topic a certain ClientID is subscribed and at which QoS process hashCode int equals boolean o java.lang.Object clone io.moquette.broker.subscriptions.Subscription toString java.lang.String qosLessThan boolean sub io.moquette.broker.subscriptions.Subscription RequestedQos io.netty.handler.codec.mqtt.MqttQoS TopicFilter io.moquette.broker.subscriptions.Topic ClientId java.lang.String io.moquette.broker.subscriptions.Token Internal use only class. process hashCode int equals boolean obj java.lang.Object name java.lang.String match boolean t io.moquette.broker.subscriptions.Token toString java.lang.String io.moquette.broker.subscriptions.Topic process asTopic Factory method s: the topic string (es "/a/b"). Return type: @return:the created Topic instance. io.moquette.broker.subscriptions.Topic s java.lang.String headToken io.moquette.broker.subscriptions.Token hashCode int isValid boolean equals boolean obj java.lang.Object isEmpty boolean match Verify if the 2 topics matching respecting the rules of MQTT Appendix A subscriptionTopic: the topic filter of the subscription Return type: @return:true if the two topics match. boolean subscriptionTopic io.moquette.broker.subscriptions.Topic exceptHeadToken Return type: @return:a new Topic corresponding to this less than the head token io.moquette.broker.subscriptions.Topic toString java.lang.String Tokens java.util.List io.moquette.interception.AbstractInterceptHandler Basic abstract class usefull to avoid empty methods creation in subclasses. process onUnsubscribe void msg io.moquette.interception.messages.InterceptUnsubscribeMessage onConnect void msg io.moquette.interception.messages.InterceptConnectMessage onDisconnect void msg io.moquette.interception.messages.InterceptDisconnectMessage onSubscribe void msg io.moquette.interception.messages.InterceptSubscribeMessage onMessageAcknowledged void msg io.moquette.interception.messages.InterceptAcknowledgedMessage onConnectionLost void msg io.moquette.interception.messages.InterceptConnectionLostMessage onPublish void msg io.moquette.interception.messages.InterceptPublishMessage InterceptedMessageTypes java.lang.Class[] io.moquette.interception.BrokerInterceptor An interceptor that execute the interception tasks asynchronously. process addInterceptHandler void interceptHandler io.moquette.interception.InterceptHandler notifyTopicUnsubscribed void topic java.lang.String clientID java.lang.String username java.lang.String notifyTopicPublished void msg io.netty.handler.codec.mqtt.MqttPublishMessage clientID java.lang.String username java.lang.String notifyTopicSubscribed void sub io.moquette.broker.subscriptions.Subscription username java.lang.String removeInterceptHandler void interceptHandler io.moquette.interception.InterceptHandler notifyMessageAcknowledged void msg io.moquette.interception.messages.InterceptAcknowledgedMessage notifyClientConnectionLost void clientID java.lang.String username java.lang.String notifyClientConnected void msg io.netty.handler.codec.mqtt.MqttConnectMessage notifyClientDisconnected void clientID java.lang.String username java.lang.String io.moquette.interception.messages.InterceptAbstractMessage process isDupFlag boolean isRetainFlag boolean Qos io.netty.handler.codec.mqtt.MqttQoS io.moquette.interception.messages.InterceptAcknowledgedMessage process Msg io.moquette.interception.messages.InterceptAcknowledgedMessage.StoredMessage Username java.lang.String Topic java.lang.String PacketID int io.moquette.interception.messages.InterceptConnectionLostMessage process Username java.lang.String ClientID java.lang.String io.moquette.interception.messages.InterceptConnectMessage process isDupFlag boolean isWillRetain boolean isPasswordFlag boolean isCleanSession boolean isWillFlag boolean isRetainFlag boolean isUserFlag boolean WillTopic java.lang.String ProtocolName java.lang.String Qos io.netty.handler.codec.mqtt.MqttQoS Username java.lang.String KeepAlive int ClientID java.lang.String ProtocolVersion byte WillQos byte WillMessage byte[] Password byte[] io.moquette.interception.messages.InterceptDisconnectMessage process Username java.lang.String ClientID java.lang.String io.moquette.interception.messages.InterceptPublishMessage process isDupFlag boolean isRetainFlag boolean Qos io.netty.handler.codec.mqtt.MqttQoS Username java.lang.String ClientID java.lang.String Payload io.netty.buffer.ByteBuf TopicName java.lang.String io.moquette.interception.messages.InterceptSubscribeMessage process RequestedQos io.netty.handler.codec.mqtt.MqttQoS TopicFilter java.lang.String Username java.lang.String ClientID java.lang.String io.moquette.interception.messages.InterceptUnsubscribeMessage process TopicFilter java.lang.String Username java.lang.String ClientID java.lang.String io.moquette.logging.LoggingUtils process getInterceptorIds java.util.Collection handlers java.util.Collection io.moquette.persistence.H2Builder process queueRepository io.moquette.broker.IQueueRepository initStore io.moquette.persistence.H2Builder subscriptionsRepository io.moquette.broker.ISubscriptionsRepository retainedRepository io.moquette.broker.IRetainedRepository closeStore void io.moquette.persistence.H2QueueRepository process createQueue java.util.Queue cli java.lang.String clean boolean io.moquette.persistence.H2RetainedRepository process retainedOnTopic java.util.List topic java.lang.String retain void topic io.moquette.broker.subscriptions.Topic msg io.netty.handler.codec.mqtt.MqttPublishMessage isEmpty boolean cleanRetained void topic io.moquette.broker.subscriptions.Topic io.moquette.persistence.H2SubscriptionsRepository process removeSubscription void topicFilter java.lang.String clientID java.lang.String listAllSubscriptions java.util.List addNewSubscription void subscription io.moquette.broker.subscriptions.Subscription io.moquette.persistence.MemorySubscriptionsRepository process removeSubscription void topic java.lang.String clientID java.lang.String listAllSubscriptions java.util.List addNewSubscription void subscription io.moquette.broker.subscriptions.Subscription 2.02 moquette2