Skip to content


Subversion checkout URL

You can clone with
Download ZIP
Commits on May 18, 2014
Commits on May 6, 2014
  1. add user-id delegation from basic to the respective channel in order …

    …to permit publish operations with the basic instance on an authenticated connection; update example to reflect the required delivery mode argument
Commits on Jun 19, 2012
  1. ... change amqp:deliver to return verbatim the values of a an op pass…

    …ed to device-read-content
Commits on Feb 9, 2012
Commits on Nov 19, 2011
  1. add user-id default to amqp:publish to use the connection uri user in…

    … order to support rabbitmq 2.6
Commits on Aug 11, 2011
  1. add a method to the default channel command processing to map an unha…

    …ndled close message to an end-of-file
Commits on Jul 12, 2011
  1. changes to streamed framing to eliminate extra messages

    amqp-device.lisp :
     amqp-j-read-chars : add missing end test
    commands.lisp :
     change get and deliver to return the headers as well as the content.
     change publish to defer sending the method and header frames until
      the flush operation
    device-level.lisp :
     device-flush : send the method and header frames as per the configured
      channel basic instance; do not send any extra termination or
      padding frames
     #+/-zero-frame-eoc-marker the implementation versions for the moment
     device-initialize-content-header : factored out from the writing
      process to be available for the publish command.
     device-write-content : initialize the basic's header properties, but do not write.
    frame.lisp :
     unget-read-frame : added for use in device read to push back non-body frames
      and rheat them as an eof indicator.
    utilities.lisp :
     undequeue : for unget-read-frame
Commits on May 11, 2011
Commits on Apr 20, 2011
Commits on Mar 22, 2011
  1. correct deliver and consume to record no-ack setting and use it to ac…

    …knowledge after message is processed
Commits on Jan 21, 2011
Commits on Dec 2, 2010
  1. more changes to sbcl simple streams; support basic headers in publish

    amqp-device.lisp :
     currect return value from re-read unread character
     shared-initialize(basic) :
      elimintate the shadowing mime-type slot;
      clean up content-type/content-encoding handling to always validate by coercing
      to instances and then extracting the names for initializing the object
     basic-headers, basic-no-ack, class-mime-type etc :
      eliminate amqp.u property slots and accessors - use standard ones;
      add generic function definitions
     basic-headers (channel) :
      for convenience
     setf/basic-header :
       for convenience
    commands.lisp :
     response-function :
      macro -> function
     publish :
      support and isolate both property and method arguments
     device-read-content, device-read-content-header :
      rely on standard content-type basic slot rather than additional
      mime-type slot even though it is a string
     prepare the basic accessors
Commits on Nov 11, 2010
Commits on Nov 3, 2010
  1. continued corrections plus adjustments to rabbotmq for 0.9.1

    amqp-1-1-0-9-1/ :
     add rmq-specific data wire coded as default in order to support its 0.9.1
    classes :
     place-holder to suppress headers as option to continue with correct wire coding
    commands :
     improve default frame handler error message
     publish : add timestamp parameter
     tune : specify the frame-max in tunw-ok
    data-wire-cording :
     don't code zero-length values in message headers
    frames :
     parameterize frame content printing
    processing :
     select for processing loop rather than polling
Commits on Sep 10, 2010
  1. additions and corrections in connection with spocq sae development.

     - binary channel operations with support for stream-reader/writer
       (perchance, circumvents sbcl bug with read-byte, which does not properly
     - factored assertion macros into general utilities for use elsewhere
    amqp-device :
     amqp-j-write-chars : lexicographica
    classes :
     added printers for exchange and queue
    commands :
     extend publish with an exchange method
     add body key arg to deliver
    data-wire-coding :
     different unsigned/signed byte setters
     improve error message for missing version implementations
     correct error messages for condition assertions
     guard atttempt to close channel 0
     call-with-channel-output-stream : correct exchange reference
     call-with-open-channel-stream : clearer directionhandline
     with-open-connection: new
    */package : clean up documentation
    stream :
     stream-read/write-byte/char : factored into plain functions for use with reader/writer
     stream-reader, stream-writer : new, with binary/character distinction
    utilities :
     assert-condition, assert-argument-type -> de.setf.utilities
Commits on Jun 29, 2010
Commits on Feb 19, 2010
  1. correct get operator to handle function valued body; correct the erro…

    …r message in the defualt response operator; correct state constraints in channel request-close;
Commits on Feb 17, 2010
  1. rabbitmq interoperability: framing independent of protocol version, c…

    …onventional protocol headers, added frame operators and classes to amqp.u
Commits on Feb 14, 2010
  1. external build, take 1

Something went wrong with that request. Please try again.