First version of a RabbitMQ Firehose implementation.
adding an example dir to test the rabbitmq implementation
Making more things configurable through the realtime.spec file.
Implemented a better query.body for the test I'm using. Added a shutdown listener to the connection and channel to get a notification when they are closed. Question remains whether the connection should be re-established when that happens.
Minor sanity checks when checking for and processing a new message.
Fixed some errors in the realtime.spec and query.body files and cleaned up the format to make it more readable as an example.
Merge remote-tracking branch 'upstream/master' into rabbitmq
Code cleanup and formatting, documentation and moving all configuration into the consumerProps.
Adding a newline at the end of the file.
Changes according to Eric's comments on the pull request.

- moved the RabbitMQ ConnectionFactory configuration to a method of its own to clean up the FirehoseFactory.connect() method.
- using Throwables.propagate*() methods in exception handling.
- removed TODOs and instead using the "keyword" FUTURE as well as adding some context to the comments themselves.
- cleaned up the exception handling in hasMore() a little and made it more readable.
Adding a test producer application.
Another take on the configuration
Errr, needed to make the ConnectionFactory a JacksonifiedConnectionFactory
merging pull request from cheddar - jacksonifying the RabbitMQ connection and config.
Adding minor class-level JavaDoc.
Merge pull request #192 from activitystream/rabbitmq

Adding a RabbitMQFirehoseFactory implementation