Permalink
Commits on Sep 29, 2011
  1. link to Storm

    samstokes committed Sep 29, 2011
  2. Readme and bump to 0.0.1

    samstokes committed Sep 29, 2011
  3. Javadoc; document limitations

    samstokes committed Sep 29, 2011
  4. bump storm dependency to 0.5.3

    samstokes committed Sep 29, 2011
Commits on Sep 26, 2011
  1. Remove test stuff

    samstokes committed Sep 26, 2011
Commits on Sep 25, 2011
  1. More comments about queues

    samstokes committed Sep 25, 2011
  2. Auto-ack AMQP messages for now

    samstokes committed Sep 25, 2011
  3. Cancel our consumer on close

    samstokes committed Sep 25, 2011
  4. Add a main to test the spout.

    samstokes committed Sep 25, 2011
  5. Basic working AMQP spout.

    Give it a broker address, the name of an exchange to bind to, and a
    routing key to select messages, and it'll emit a tuple for each message
    published to the exchange.
    
    Currently the tuples it emits just contain one element, which is the
    string obtained by decoding the bytes of the message in the default
    encoding (probably UTF-8).
    samstokes committed Sep 25, 2011
  6. gitignore target/

    samstokes committed Sep 25, 2011