Permalink
Commits on Jan 10, 2009
  1. Merge commit 'chuckremes/master' into reconnect

    * commit 'chuckremes/master':
      Clarified and corrected new #unbind/#unsubscribe/#subscribed? rdoc
      Small patch to add #subscribed? metho to MQ::Queue API
      Removed a debug statement used while creating rdoc
      Reworked all code examples so they use the MQ API instead of the
      Added rdoc to the main classes and modules used for building clients.
    tmm1 committed Jan 10, 2009
Commits on Jan 9, 2009
  1. Small patch to add #subscribed? metho to MQ::Queue API

    - also adds some documentation to #unbind, #unsubscribe
      and #subscribed?
    cremes committed Jan 9, 2009
Commits on Jan 8, 2009
  1. Merge branch 'master' into reconnect

    * master:
      method_missing for header wrapper
    tmm1 committed Jan 8, 2009
  2. method_missing for header wrapper

    tmm1 committed Jan 8, 2009
Commits on Jan 7, 2009
  1. Merge branch 'master' of git://github.com/tmm1/amqp

    conflicts resolved
    
    Conflicts:
    
    	lib/amqp.rb
    	lib/amqp/protocol.rb
    	lib/mq.rb
    	lib/mq/exchange.rb
    	lib/mq/queue.rb
    	lib/mq/rpc.rb
    cremes committed Jan 7, 2009
  2. Reworked all code examples so they use the MQ API instead of the

    subclass APIs. Fixed several factual errors and added a larger
    'clock' example to the main MQ description.
    cremes committed Jan 7, 2009
Commits on Jan 3, 2009
  1. Merge branch 'master' into reconnect

    * master:
      Allow for client controlled acks. Patch by Doug Barth.
      changed example host to localhost - dev.rabbitmq.com is not always up
      Added rdoc to the main classes and modules used for building clients.
    
    Conflicts:
    	lib/mq/queue.rb
    tmm1 committed Jan 3, 2009
  2. Allow for client controlled acks. Patch by Doug Barth.

    Client code can pop or subscribe with the :ack => true. They can then
    ack the message as being received using the ack method on the header.
    
    For example:
      MQ.queue('foo').subscribe(:ack => true) do |header, message|
        # Processsed message
        header.ack
      end
    
    Failure to ack a message will cause the message to be redelivered when
    the connection and/or channel are closed.
    tmm1 committed Jan 3, 2009
  3. changed example host to localhost - dev.rabbitmq.com is not always up

    Signed-off-by: Aman Gupta <aman@tmm1.net>
    Simon Horne committed with tmm1 Oct 24, 2008
  4. Added rdoc to the main classes and modules used for building clients.

    - modified the gemspec to build the rdoc during installation and use
      the README file as the default index
    
    - added :nodoc: or :stopdoc: rdoc directives to all files in lib/ext
    
    - added :stopdoc: directives to codegen.rb so the spec.rb file does
      not get indexed by rdoc
    
    - added descriptive documentation to most of the major classes. A good
      chunk of the descriptions were copied verbatim from the
      amqp-0.8.xml file. Some code examples were repurposed from the
      examples directory to add color. More code examples needed.
    
    - removed some metaprogramming from mq.rb so that a few convenience
      methods could be properly documented.
    
    Signed-off-by: Aman Gupta <aman@tmm1.net>
    cremes committed with tmm1 Jan 3, 2009
  5. Added rdoc to the main classes and modules used for building clients.

    - modified the gemspec to build the rdoc during installation and use
      the README file as the default index
    
    - added :nodoc: or :stopdoc: rdoc directives to all files in lib/ext
    
    - added :stopdoc: directives to codegen.rb so the spec.rb file does
      not get indexed by rdoc
    
    - added descriptive documentation to most of the major classes. A good
      chunk of the descriptions were copied verbatim from the
      amqp-0.8.xml file. Some code examples were repurposed from the
      examples directory to add color. More code examples needed.
    
    - removed some metaprogramming from mq.rb so that a few convenience
      methods could be properly documented.
    cremes committed Jan 3, 2009
Commits on Dec 26, 2008
  1. simple reconnect/reset logic

    tmm1 committed Dec 26, 2008
Commits on Dec 25, 2008
  1. Removing 'Shutting down...' puts.

    It clutters up test output.
    
    Signed-off-by: Aman Gupta <aman@tmm1.net>
    dougbarth committed with tmm1 Dec 5, 2008
  2. Reset closing after closed.

    Before, this guard was always true, causing reconnections to fail after
    closing.
    
    Signed-off-by: Aman Gupta <aman@tmm1.net>
    dougbarth committed with tmm1 Dec 2, 2008
  3. Merge branch 'master' of git@github.com:tmm1/amqp

    * 'master' of git@github.com:tmm1/amqp:
      allow users to pass through the insist option for rabbitmq clustered mode
      Changed all exception classes to descend from StandardError instead of Exception.
    tmm1 committed Dec 25, 2008
Commits on Dec 16, 2008
  1. allow users to pass through the insist option for rabbitmq clustered …

    …mode
    
    Signed-off-by: Aman Gupta <aman@tmm1.net>
    Cliff Moon committed with tmm1 Dec 9, 2008
  2. Changed all exception classes to descend from StandardError instead o…

    …f Exception.
    
    Technomancy explains why: http://technomancy.us/114
    
    Signed-off-by: Aman Gupta <aman@tmm1.net>
    codahale committed with tmm1 Dec 9, 2008
Commits on Oct 15, 2008
  1. whitespace cleanup

    tmm1 committed Oct 15, 2008
  2. raise error if subscribe is called twice; clear out status/subscribe …

    …callbacks to prevent memory leaks
    tmm1 committed Oct 15, 2008
  3. combine AMQP.start and AMQP.run

    tmm1 committed Oct 15, 2008
  4. TODO: header values cannot be nil

    tmm1 committed Oct 15, 2008
  5. require EM 0.12.2

    tmm1 committed Oct 15, 2008
Commits on Oct 11, 2008
Commits on Oct 2, 2008
  1. Ack and get now working...

    Chris Van Pelt committed Oct 2, 2008
  2. add Exchange#delete

    tmm1 committed Oct 2, 2008
  3. typos and other readme fixes

    tmm1 committed Oct 2, 2008