be5fefd35d
Add lexer, parser, and evaluator
> A message selector is a String whose syntax is based on a subset of the SQL92[2] conditional expression syntax.
* `leex` is used to scan this string into a flat structure of tokens.
* `yecc` is used to parse these tokens into a tree (conforming with the grammar rules).
Example:
```erl
1> String = "JMSType = 'car' AND color = 'blue' AND weight > 2500".
"JMSType = 'car' AND color = 'blue' AND weight > 2500"
2> {ok, Tokens, _} = rabbit_jms_selector_lexer:string(String).
{ok,[{identifier,1,<<"JMSType">>},
{'=',1},
{string,1,<<"car">>},
{'AND',1},
{identifier,1,<<"color">>},
{'=',1},
{string,1,<<"blue">>},
{'AND',1},
{identifier,1,<<"weight">>},
{'>',1},
{integer,1,2500}],
1}
3> {ok, Expr} = rabbit_jms_selector_parser:parse(Tokens).
{ok,{'and',{'and',{'=',{identifier,<<"JMSType">>},
{string,<<"car">>}},
{'=',{identifier,<<"color">>},{string,<<"blue">>}}},
{'>',{identifier,<<"weight">>},{integer,2500}}}}
4> Headers = [{<<"JMSType">>, <<"car">>}, {<<"color">>, <<"blue">>}, {<<"weight">>, 3000}].
[{<<"JMSType">>,<<"car">>},
{<<"color">>,<<"blue">>},
{<<"weight">>,3000}]
5> rabbit_fifo_filter:evaluate(Expr, Headers).
true
```
|
||
|---|---|---|
| .github | ||
| deps | ||
| doc | ||
| mk | ||
| packaging | ||
| release-notes | ||
| scripts | ||
| selenium | ||
| .dockerignore | ||
| .elp.toml | ||
| .git-blame-ignore-revs | ||
| .gitignore | ||
| .mailmap | ||
| CODE_OF_CONDUCT.md | ||
| COMMUNITY_SUPPORT.md | ||
| CONTRIBUTING.md | ||
| LICENSE | ||
| LICENSE-APACHE2 | ||
| LICENSE-MPL-RabbitMQ | ||
| Makefile | ||
| PKG_LINUX.md | ||
| PKG_WINDOWS.md | ||
| README.md | ||
| SERVER_RELEASES.md | ||
| erlang.mk | ||
| erlang_ls.config | ||
| plugins.mk | ||
| rabbitmq-components.mk | ||
| rebar.config | ||
README.md
RabbitMQ Server
RabbitMQ is a feature rich, multi-protocol messaging and streaming broker. It supports:
- AMQP 1.0
- AMQP 0-9-1
- RabbitMQ Stream Protocol
- MQTT 3.1, 3.1.1, and 5.0
- STOMP 1.0 through 1.2
- MQTT over WebSocket
- STOMP over WebSocket
- AMQP 1.0 over WebSocket (supported in VMware Tanzu RabbitMQ)
Installation
- Currently supported released series
- Installation guides for various platforms
- Kubernetes Cluster Operator
- Changelog
- Releases on GitHub
- Community Support Eligibility Policy
- Supported Erlang versions
Tutorials and Documentation
Some key doc guides include
- CLI tools guide
- Clustering and Cluster Formation
- Configuration guide
- Client libraries and tools
- Monitoring and Prometheus/Grafana
- Upgrading
- Kubernetes Cluster Operator
- Production checklist
- Quorum queues: a replicated, data safety- and consistency-oriented queue type
- Streams: a persistent and replicated append-only log with non-destructive consumer semantics
- Runtime Parameters and Policies
- Runnable tutorials
RabbitMQ documentation is also developed on GitHub.
Commercial Features and Support
- Commercial editions of RabbitMQ
- Commercial edition for Kubernetes
- Commercial support from Broadcom for open source RabbitMQ
Getting Help from the Community
Please read the Community Support Eligibility Policy document first.
The recommended community forums are
- GitHub Discussions
- Community Discord server
#rabbitmqon Libera Chat
Contributing
See CONTRIBUTING.md and our development process overview.
Questions about contributing, internals and so on are very welcome in GitHub Discussions
or community Discord server in the core-and-plugin-dev channel.
Licensing
RabbitMQ server is licensed under the MPL 2.0.
Community Support Eligibility Policy document explains the open source RabbitMQ support policy adopted by the RabbitMQ Core Team.
Building From Source and Packaging
Copyright
(c) 2007-2025 Broadcom. All Rights Reserved. The term “Broadcom” refers to Broadcom Inc. and/or its subsidiaries.