Lib.rs

基于 Rust 实现的 RSMQ (Redis 简单消息队列)。

安装

将以下行添加到您的应用 Cargo.toml 中

[dependencies]
rsmq = "*"

使用

extern crate rsmq;

use rsmq::*;

fn main() {
  let rsmq = Rsmq::new("redis://127.0.0.1/").expect("Can't connect to Redis");
  let qopts = QueueOpts {
    qname: "my-queue".into(),
    vt: 60,
    delay: 120,
    maxsize: 3000,
  };
  rsmq.create_queue(qopts).expect("queue creation failed");
  let qs = rsmq.list_queues().expect("Nope, no listing for you");
  println!("List queues: {:?}", qs);
  rsmq.delete_queue("my-queue").expect("q deletion failed");
}

贡献

1. 分叉它 ( http://github.com/dvdplm/rsmq-rust )
2. 创建您的功能分支 (git checkout -b my-new-feature)
3. 提交您的更改 (git commit -am 'Add some feature')
4. 推送到分支 (git push origin my-new-feature)
5. 创建新的 Pull Request