Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Implemented delayed messages #18

Merged
merged 1 commit into from
Mar 2, 2016
Merged

Implemented delayed messages #18

merged 1 commit into from
Mar 2, 2016

Conversation

pkruithof
Copy link
Contributor

Changes

  • Added support for delayed messages, via the delayed message exchange plugin
  • Added ack/nack support to consumers
  • Consumers now work via a callback that calls the given processor
  • Consumers now dispatch events when consuming messages
  • Added getter/setter for headers on Message class

Breaking changes

  • Moved TreeHouse\Queue\Consumer to TreeHouse\Queue\Consumer\Consumer
  • Consumers now work with EnvelopeInterface instances instead of Message
    instances, which are only for composing new messages.
  • Removed MessageProvider and its interface, as it was basically a copy of
    the consumer class. Instead, consumers now work directly with a queue/processor.

@fieg
Copy link
Contributor

fieg commented Mar 2, 2016

lgtm

pkruithof added a commit that referenced this pull request Mar 2, 2016
@pkruithof pkruithof merged commit 046bb83 into treehouselabs:master Mar 2, 2016
@pkruithof pkruithof deleted the consumer-improvements branch March 2, 2016 10:31
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

2 participants