Skip to content
This repository has been archived by the owner on Jan 29, 2020. It is now read-only.

Commit

Permalink
0.5.5
Browse files Browse the repository at this point in the history
  • Loading branch information
frederikbosch committed Aug 23, 2016
1 parent c0f98d1 commit 0c4096c
Show file tree
Hide file tree
Showing 6 changed files with 9 additions and 5 deletions.
3 changes: 3 additions & 0 deletions .travis.yml
Original file line number Diff line number Diff line change
@@ -1,8 +1,11 @@
language: rust
rust:
- 1.3
- stable
- beta
- nightly
matrix:
allow_failures:
- rust: stable
- rust: beta
- rust: nightly
2 changes: 1 addition & 1 deletion Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "gworkerd"
version = "0.5.4"
version = "0.5.5"
authors = [ "Frederik Bosch <[email protected]>" ]

[dependencies]
Expand Down
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ start with mysql, create a [table](assets/sql/mysql_worker_results.sql) where yo
### Build gworkerd

```
$ cd daemon && cargo build
$ cargo build
```

### Create a configuration file
Expand Down
3 changes: 2 additions & 1 deletion src/consumer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ extern crate rustc_serialize;

use self::stomp::session::Session;
use self::stomp::session_builder::SessionBuilder;
use self::stomp::connection::Credentials;
use self::stomp::connection::{Credentials, HeartBeat};
use self::stomp::frame::Frame;
use self::stomp::header::{Header, SuppressedHeader};
use self::stomp::subscription::AckOrNack::{Ack, Nack};
Expand Down Expand Up @@ -41,6 +41,7 @@ impl<'a> StompConsumer<'a> {
let session = match SessionBuilder::new(&config.address, config.port)
.with(Credentials(&config.username, &config.password))
.with(SuppressedHeader("host"))
.with(HeartBeat(5000, 2000))
.with(Header::new("host", &config.host))
.start() {
Ok(session) => session,
Expand Down

0 comments on commit 0c4096c

Please sign in to comment.