Pedro Melo
bfa5a905d7
Add support for connect_timeout on both Reader and Connection constructors
...
Signed-off-by: Pedro Melo <melo@simplicidade.org >
2014-07-20 17:36:31 +01:00
Pedro Melo
011c7a4b82
Default error_cb now carps, doesn't croak
...
Too aggresive, given that after an error we always disconnect.
Signed-off-by: Pedro Melo <melo@simplicidade.org >
2014-07-20 17:35:13 +01:00
Pedro Melo
be7b2c03d6
Add support for requeue_delay on constructors, used on REQ responses
...
Signed-off-by: Pedro Melo <melo@simplicidade.org >
2014-07-20 17:34:31 +01:00
Pedro Melo
dcca4aea33
Change API for the message callback return code:
...
* undef => mark as done (send FIN);
* -1 and above, send requeue, with value specifying
the delay:
* >= 0 => use value as delay, 0 is a special case, means immediatly;
* -1 => use number of attempts times the requeue_delay constructor
parameter.
Signed-off-by: Pedro Melo <melo@simplicidade.org >
2014-07-20 17:32:50 +01:00
Pedro Melo
3579cc1a48
The message already has most of the important stuff
...
Signed-off-by: Pedro Melo <melo@simplicidade.org >
2014-07-20 17:29:39 +01:00
Pedro Melo
87a8a18014
Catch and warn of errors, exit the script if one shows up
...
Signed-off-by: Pedro Melo <melo@simplicidade.org >
2014-07-20 16:49:17 +01:00
Pedro Melo
7092c3b208
Fix: make sure consumer.pl can find the AnyEvent::NSQ::Reader lib
...
Signed-off-by: Pedro Melo <melo@simplicidade.org >
2014-07-20 16:48:44 +01:00
Pedro Melo
306f8e4864
A simple consumer and a HTTP-based publisher, useful for simple benchmarks
...
Signed-off-by: Pedro Melo <melo@simplicidade.org >
2014-07-20 13:48:16 +01:00
Pedro Melo
3271c74a0b
Tidy
...
Signed-off-by: Pedro Melo <melo@simplicidade.org >
2014-07-20 13:45:26 +01:00
Pedro Melo
6b86255149
Refactor Connection creation in Reader:
...
* easier to understand;
* added support for client_id and hostname from Reader => Connection.
Signed-off-by: Pedro Melo <melo@simplicidade.org >
2014-07-20 13:45:22 +01:00
Pedro Melo
d48cfc068f
Add client_id and hostname parameters to Reader new()
...
Signed-off-by: Pedro Melo <melo@simplicidade.org >
2014-07-20 13:43:40 +01:00
Pedro Melo
15eef5072c
Accept error_cb parameter on Connection new()
...
Signed-off-by: Pedro Melo <melo@simplicidade.org >
2014-07-20 13:43:00 +01:00
Pedro Melo
9521132b8b
Added rough subscriber code that works, lots of open issues
...
Signed-off-by: Pedro Melo <melo@simplicidade.org >
2014-07-20 10:27:43 +01:00
Pedro Melo
ceb8146410
Tweak AnyEvent::NSQ abstract and fix package name
...
Signed-off-by: Pedro Melo <melo@simplicidade.org >
2014-07-19 21:57:52 +01:00
Pedro Melo
4dbb22b847
initial commit
2014-07-19 21:46:05 +01:00
