#queue #worker #ironmq

beanstalkd

适用于Rust(兼容IronMQ)的简单易用的beanstalkd客户端

12个版本

使用旧的Rust 2015

0.4.1 2018年5月31日
0.3.2 2015年2月23日
0.2.4 2015年1月23日
0.1.0 2015年1月22日
0.0.1 2014年12月7日

#64 in #worker


用于 2 crates

MIT/Apache

14KB
290

rust-beanstalkd 构建状态

适用于Rust(兼容IronMQ)的简单易用的beanstalkd客户端

安装

将此依赖项添加到您的 Cargo.toml

beanstalkd = "*"

文档

更多文档可以在此处找到 http://schickling.me/rust-beanstalkd.

用法

生产者

extern crate beanstalkd;

use beanstalkd::Beanstalkd;

fn main() {
    let mut beanstalkd = Beanstalkd::localhost().unwrap();
    let _ = beanstalkd.put("Hello World", 0, 0, 10000);
}

消费者

extern crate beanstalkd;

use beanstalkd::Beanstalkd;

fn main() {
    let mut beanstalkd = Beanstalkd::localhost().unwrap();
    let (id, body) = beanstalkd.reserve().unwrap();
    println!("{}", body);
    let _ = beanstalkd.delete(id);
}

IronMQ示例

extern crate beanstalkd;

use beanstalkd::Beanstalkd;

fn main() {
    let host = "mq-aws-us-east-1.iron.io";
    let token = "your token";
    let project_id = "your project id - not the name";

    let mut beanstalkd = Beanstalkd::connect(host, 11300).unwrap();
    let _ = beanstalkd.put(format!("oauth {} {}", token, project_id).as_slice(), 0, 0, 10000);
    let _ = beanstalkd.put("Hello World", 0, 0, 10000);
}

许可证

MIT许可证

许可证

根据您的选择,许可协议可以是

贡献

除非您明确表示,否则您有意提交的任何贡献,根据Apache-2.0许可证的定义,将按上述方式双重许可,没有额外的条款或条件。

依赖关系

~11KB