Comments (3)
andsel
commented on July 27, 2024
Hi Alkan,
I expect to introduce some concept of plugins into Moquette in the near future. So you need an authorization verification on "subscribe event" from a client, the structure of moquette is based on non blocking io, so such a verification should be done in asych mode (else it blocks the processing of all other MQTT messages). To get things done in this way in an extenstion point, I've to restructure a little bit the protocol processing. To push new developmetn on the project 'm waiting the project is moved under the Eclpise repository (but at the moment I'm swaped with legal stuff in my employer side).
Regards
Andrea
from moquette.
francisdb
commented on July 27, 2024
+1 for this
from moquette.
andsel
commented on July 27, 2024
Introduced with the interceptors in pull request https://github.com/andsel/moquette/pull/76
from moquette.
Related Issues (20)
- Manage Will Delay Interval for MQTT5
- Does the moquette supports MQTT 5? (question) HOT 2
- io.netty.util.IllegalReferenceCountException: refCnt: 0 HOT 1
- Change signature of IRetainedRepository.retainedOnTopic to reflect the fact it return unordered collection HOT 1
- Generalize ExpirableTracker to become an scheduler service
- Server can define its own Keep Alive in CONNACK
- [Meta] Implement Shared Subscriptions HOT 1
- Support topic that starts with `$` character
- The official example code is misleading and may cause Java OutOfMemoryError. HOT 1
- Implement Subscription identifier
- Implements Subscription Options HOT 1
- java.lang.NoSuchMethodError: No static method encodeHexString([B)Ljava/lang/String; in class Lorg/apache/commons/codec/binary/Hex; or its super classes (declaration of 'org.apache.commons.codec.binary.Hex' appears in /system/framework/org.apache.http.legacy.boot.jar) HOT 2
- Confuse on SessionEventLoopGroup.routeCommand method HOT 4
- Implement message expiry intervals functionality HOT 1
- publish2Subscribers(payload, topic, qos); catch Exception java.lang.NullPointerException: null HOT 3
- io.moquette.broker.SessionCorruptedException: Session has already changed state: Session{clientId='xxx', clean=true, status=CONNECTING, inflightSlots=10} HOT 3
- Payload format and content type HOT 1
- Request / Response: Formalize the request/response pattern within MQTT HOT 2
- High CPU usage when MQTT client disconnect and reconnect
- Shrared buffer issues due to readerIndex
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from moquette.