folkmq icon indicating copy to clipboard operation
folkmq copied to clipboard

作一个体验最简单的消息中间件。支持Qos0、定时、过期、顺序、广播、事务、二进制等消息特性。有确认、重试、延时等机制。可嵌入、单机、集群等部署。

Results 5 folkmq issues
Sort by recently updated
recently updated
newest added

语法建议rabbitmq和mqtt都兼容 rabbitmq以.作为分隔符,#作为多层级通配符,*作为单层级通配符 mqtt以/作为分隔符,#作为多层级通配符,+作为单层级通配符 建议两种都兼容

欢迎尝试 folkmq-pro 模块下,已添加类:MqWatcherMetrics

`org.noear.socketd.transport.client.Client#open` 以及 `openOrThrow` 函数, 其签名感觉可以改成 ` T open();` 以规避强转这种感觉不优雅的情况?

软件版本:1.7.9 版本 系统版本:ubuntu20.04 运行环境:单机运行 根据官网执行服务端启动:sudo docker run -p 18602:18602 -p 8602:8602 -e folkmq.admin='admin' 7b3eed707d9a 然后启动python客户端进行测试,python _msg.py,总是报上面这个错误,找不到解决办法 ![Image](https://github.com/user-attachments/assets/146e7ef5-c3fb-4885-a909-ecbfc6d6ad6e) ![Image](https://github.com/user-attachments/assets/5a420d92-bb5e-4dfd-bfc2-7ce0ea984b6f)

像kafka那样,从指定位置(从头开始,从最新消息开始)消费要怎么配置呢?