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

update amqp: add multiple channel, add waitForConfirms and waitForMessages #65

Merged
merged 1 commit into from
Nov 4, 2013

Conversation

zhihuij
Copy link
Contributor

@zhihuij zhihuij commented Nov 1, 2013

add following features:

  1. client can do things(open channel, publish messages, consume messages, etc) on multiple channel;
  2. add request type "waitForConfirms" for waiting confirms from sever when publishing messages;
  3. and request type "waitForMessages" for waiting messages deliveries from server when consuming messages;
  4. update amqp stat, add/update following stat:
    amqp_connected: counter for connection created;
    amqp_closed: counter for connection closed;
    amqp_channel_opened: counter for channel opened;
    amqp_channel_closed: counter for channel closed;
    amqp_consumer: counter for consumer(basic.consume)
    amqp_published: counter for messages published;
    amqp_confirmed: counter for messages confirmed;
    amqp_delivered: counter for message delivered to the client(and acked by the client);

nniclausse added a commit that referenced this pull request Nov 4, 2013
update amqp: add multiple channel, add waitForConfirms and waitForMessages
@nniclausse nniclausse merged commit 9691c55 into processone:master Nov 4, 2013
@zhihuij zhihuij deleted the update_amqp branch November 4, 2013 11:52
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.

2 participants