sz-orm-queue 1.0.0

SZ-ORM Message Queue Extension - 6 MQ Providers (RabbitMQ/NATS/Pulsar/Kafka/ActiveMQ real, RocketMQ stub)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

[package]
name = "sz-orm-queue"
version = "1.0.0"
edition = "2021"
authors = ["SZ-ORM Team"]
license = "MIT"
repository = "https://github.com/ljclz/sz-orm"
homepage = "https://github.com/ljclz/sz-orm"
keywords = ["orm", "database", "async", "sql", "tokio"]
categories = ["database", "asynchronous"]
description = "SZ-ORM Message Queue Extension - 6 MQ Providers (RabbitMQ/NATS/Pulsar/Kafka/ActiveMQ real, RocketMQ stub)"

[features]
default = []
# RabbitMQ: lapin (AMQP 0.9.1) — 真实实现
rabbitmq = ["lapin"]
# NATS: async-nats (纯 Rust) — 真实实现
nats = ["async-nats"]
# Pulsar: pulsar crate (纯 Rust) — 真实实现
pulsar = ["dep:pulsar"]
# Kafka: rdkafka (需 librdkafka，Windows 需 vcpkg) — 真实实现
kafka = ["rdkafka"]
# ActiveMQ: 复用 lapin (AMQP 1.0，ActiveMQ 5.14+ 支持) — 真实实现
activemq = ["lapin"]
# RocketMQ: 无成熟 Rust 客户端，保持 stub
# 全部真实实现（除 RocketMQ）
all-real = ["rabbitmq", "nats", "pulsar", "kafka", "activemq"]

[dependencies]
async-trait = "0.1"
tokio = { version = "1.40", features = ["full"] }
thiserror = "2.0"
serde = { version = "1.0", features = ["derive"] }
serde_json = "1.0"
futures = "0.3"
lapin = { version = "4", optional = true }
async-nats = { version = "0.38", optional = true }
pulsar = { version = "6", optional = true, default-features = false, features = ["tokio-rustls-runtime"] }
rdkafka = { version = "0.36", optional = true, default-features = false, features = ["cmake-build"] }

[dev-dependencies]
tokio-test = "0.4"