Skip to content

Commit

Permalink
Changed SubscriptionBuilder::create() to SubscriptionBuilder::start()
Browse files Browse the repository at this point in the history
  • Loading branch information
zslayton committed Feb 8, 2015
1 parent 6c3178c commit 52e520e
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion examples/send_and_subscribe/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ fn main() {
.with(AckMode::Client)
.with(Header::new("custom-subscription-header", "lozenge"))
.with(ReceiptHandler(on_subscribe))
.create();
.start();

session.message(destination, "Animal").send();
session.message(destination, "Vegetable").send();
Expand Down
2 changes: 1 addition & 1 deletion src/subscription_builder.rs
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ pub struct SubscriptionBuilder <'a, 'session: 'a, 'sub: 'session> {
impl <'a, 'session, 'sub> SubscriptionBuilder <'a, 'session, 'sub> {

#[allow(dead_code)]
pub fn create(mut self) -> IoResult<String> {
pub fn start(mut self) -> IoResult<String> {
let next_id = self.session.generate_subscription_id();
let subscription = Subscription::new(next_id, self.destination, self.ack_mode, self.handler);
let mut subscribe_frame = Frame::subscribe(subscription.id.as_slice(), self.destination, self.ack_mode);
Expand Down

0 comments on commit 52e520e

Please sign in to comment.