rishiramraj / amtk Goto Github PK

Support and test python 3.

Specifically need to test that play can actually play something that is recorded and vice versa.

It should support logging and should parametrise options to queue_declare.

The original timing when used during playback is based on the create timestamp, which is only accurate to the second. In order to get sub-second accuracy, amtk needs to record the time when the message was received.

Specifically convert a recording into a sqlite database so that the user can easily query values.

Add options on record and play to check for message acknowledgements.

The 'headers' key is missing.

That way the can easily be changed in the recording.

Add headers to the recordings/playback.

A simple example:
Let's say you've got a vanilla rabbit install on your localhost. You log into the web management interface and create a topic exchange called "test". You can then run the following command to record any messages targeted against your new exchange:

$ amtk.record test '#'

If you do not specify a queue name, the record tool lets the server decide on a name. This command will start logging the messages directly onto the console (stdout). You can then redirect the messages into a file:

$ amtk.record test '#' > recording

Once you've gathered the messages you're interested in, you can play them back into the exchange using the play tool:

$ amtk.play recording test

To get detailed help on any of the commands, use the --help flag:

$ amtk.record --help
$ amtk.play --help

It may be possible to use the message id to merge separate recordings. This feature would be useful if you're using multiple recorders to backup messages from the exchange.

Should be added to all tools.

amtk.play should be able to accept data from stdin. amtk.record should support an output to file option.

All of the option arguments in the options module need to ultimately accept a parser as an argument, so that it can be applied simultaneously using parse.

Recorded messages can be played back with the time deltas between the messages preserved.