Skip to content


Subversion checkout URL

You can clone with
Download ZIP
Branch: master
Commits on Jun 22, 2012
  1. Bump version to v0.03

    Eric Waters authored
  2. Revert "Merge branch 'master' of git://…

    Eric Waters authored
    This reverts commit dad271f, reversing
    changes made to acd6086.
  3. Merge branch 'master' of git://…

    Eric Waters authored
  4. Avoid sending too large of frames

    Eric Waters authored
      frame_max limits the total frame size, including header and end
      marker, which add up to 8 octects in total
      (contributed by Matthias Radestock
Commits on May 21, 2012
  1. Releasing version v0.02

    Eric Waters authored
  2. Merge pull request #1 from dconlon/master

    Implement basic.qos AMQP method
Commits on May 6, 2012
  1. @dconlon
Commits on Oct 20, 2011
  1. @jvanvleet

    Some people (myself included) don't want the address array of the AMQP

    jvanvleet authored
    servers random - the first one is there for a reason (localhost)
Commits on Jun 29, 2011
  1. hooked up the various disconnect and error callbacks to use the

    James Van Vleet authored
    existing code.  Removed dup key in AMQP::TCP new.
  2. wired up the reconnect logic so it can be used. Also added

    James Van Vleet authored
    connect_delay_max so the 2x delay progression on reconnect does not
    get too silly.
Commits on Jun 28, 2011
  1. remove leftover from the conversion of the old buffering scheme to the

    James Van Vleet authored
    new one
Commits on May 10, 2011
  1. @hotsphink

    Merge git://

    hotsphink authored
    Merge, removing buffered_input and the stateful {Reader} in favor of my
    POE::Filter approach.
  2. @hotsphink
Commits on Jan 11, 2010
  1. FrameSent callback to track out frames

    Eric Waters authored
    Added FrameSent callback in the AMQP client core.  Is called whenever a frame is sent; can be used to track exact moment messages are sent out on the wire.
    Refactored the examples/ to use which can provide callbacks at runtime.
    Added examples of FrameSent being used to do a simple 1-N publish and exit.  Call with a list of messages, and with the number of messages to wait for from the test queue.
Commits on Nov 6, 2009
  1. Support for Reconnect & round robin RemoteAddress

    You can now provide 'Reconnect => 1' and 'Callbacks => { Reconnected => [ sub {} ] }' in the new() args to the Client.
    Any queues, channels, subscriptions, etc. that were created synchronously will be recreated, however I'm unclear at this point how dynamically generated queue names will be handled.  For this reason, adding callbacks to the 'Disconnected' and 'Reconnected' triggers to resetup your queue/exchange/channel topology would be best practice, as is checking $amq->is_started before doing server_send events.
    If $amq->server_send is called while in the progress of reconnecting, the messages will be enqueued to $amq->{failed_server_send}, which the user is at this point expected to do something with.
Commits on Oct 29, 2009
  1. @joodie

    ignore emacs tmp files

    joodie authored
  2. @joodie

    move constants to their own module. Makes loading more predictable

    joodie authored
    This also eliminates redefinition warnings under certain conditions,
    such as when running the files in emacs/flymake-mode.
Commits on Oct 28, 2009
  1. @joodie

    merge from ewaters/master

    joodie authored
Commits on Oct 23, 2009
  1. Improved handling of larger TCP records

    Added respect for frame_max (Connection.Tune param) and proper splitting of body frames at this length (when using compose_basic_publish())
    Added ServerFlushed TCP client event, but for no real good reason.
    It appears that large TCP input records are being split at 16384 bytes (2^14); this is probably due to POE::Driver::SysRW, although it should split at 65536 (2^16).  To compensate, tcp_server_input checks to see if the record appears to be complete, and buffers it accordingly.  This works, but is kludgy.  Ideally, we need to write POE::Filter::AMQP, which spits out fully formed Net::AMQP records.  TODO / FIXME
Commits on Oct 9, 2009
  1. Channel create and close improvements

    AMQP->channel() now allows user opts.
    Waiting for synchronous method responses is now keyed on channel.
    Server input that is not channel 0 will now go to the Channel, regardless of other handling by the server_input() method.
    Added 'CascadeFailure' and 'CloseCallback' to Channel->create() opts to allow for a)
     the server connection to be closed if the channel closes and b) a user callback to
     trigger if the channel closes.  Better handling for channel close events, allowing a
      channel number to be reused.  Added explicit method close().
Commits on Sep 11, 2009
  1. @joodie

    .gitignore some files

    joodie authored
  2. @joodie

    added $channel->publish method

    joodie authored
    meaning we can now easily publish when we don't have a queue handy
Commits on Sep 9, 2009
  1. @joodie

    added Disconnected callback

    joodie authored
  2. @joodie
  3. @joodie

    updated README

    joodie authored
  4. @joodie

    added ack and reject methods

    joodie authored
Commits on Sep 8, 2009
  1. @joodie

    added error callbacks

    joodie authored
  2. @joodie
  3. @joodie
Commits on Aug 28, 2009
  1. @joodie

    pass delivery_tag to callbacks

    joodie authored
  2. @joodie

    fixed dist

    joodie authored
  3. @joodie

    use correct buffering

    joodie authored
Commits on Aug 26, 2009
  1. Added Keepalive feature

  2. oo-ifying the exchange declaration and bindings a little bit

    James A. Duncan authored
Something went wrong with that request. Please try again.