dinislage/perl-anyevent-nsq
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Commit Graph

  • f3fb375d10 Fix memory leak, circular reference on publish() master Pedro Melo 2015-02-28 07:49:45 +00:00
  • 1c5a3526fd Tidy Pedro Melo 2015-01-02 12:46:29 +00:00
  • f56271c965 Refactor _find_and_delete_message_connection as _find_message_connection: Pedro Melo 2015-01-02 12:46:23 +00:00
  • 681939809d Rename touch_message to touch_msg, for consistency: Pedro Melo 2015-01-02 12:45:22 +00:00
  • dca911fee8 Tidy Pedro Melo 2014-10-23 07:08:45 +01:00
  • a08049ee0f Add ready() to ::Client Pedro Melo 2014-10-23 07:08:41 +01:00
  • 54c2964390 Prepare Client.pm to use Lookupd nsqlookupd Pedro Melo 2014-09-19 13:53:47 +01:00
  • bb2aa6e247 Added initial Lookupd client code Pedro Melo 2014-09-19 13:53:34 +01:00
  • a9e3803889 Merge pull request #4 from tavaresb/master Bruno Tavares 2014-09-10 17:23:14 +01:00
  • f2cf93d8e5 no need to allocate a variable that has no use Bruno Tavares 2014-09-10 17:17:06 +01:00
  • 05bea0dcb8 Lost debugging lines. Bruno Tavares 2014-09-09 11:59:43 +01:00
  • 24b1335000 Better routing clean up. Now requires explicit message handling Bruno Tavares 2014-09-09 11:52:56 +01:00
  • 3d57b5247b Merge pull request #3 from tavaresb/master Pedro Melo 2014-09-09 09:06:03 +01:00
  • 78c4ca959f Make the connection references weak references. Bruno Tavares 2014-09-03 18:22:22 +01:00
  • 73801c8488 interface methods to message commands on the connection Bruno Tavares 2014-09-03 11:03:14 +01:00
  • ee0b61582a allow to issue commands with message id ( and message structs ) Bruno Tavares 2014-09-03 11:02:54 +01:00
  • 7edb6bbfa0 Connection routing registry Bruno Tavares 2014-09-03 10:19:11 +01:00
  • e8ca613154 Keep te original 'identified' callback Bruno Tavares 2014-09-03 09:59:46 +01:00
  • ad113aed07 Merge pull request #2 from tavaresb/master Pedro Melo 2014-09-03 05:12:10 +01:00
  • 7b89af5b97 Identation Bruno Tavares 2014-09-02 18:23:07 +01:00
  • 1f0042b10b FIX: Save the connection state callbacks Bruno Tavares 2014-09-02 18:19:20 +01:00
  • e6cbc372cc On disconnect() send CLS only if this connection is a subscriber Pedro Melo 2014-07-21 05:52:34 +01:00
  • d807d361f3 Add --stats support for consumer: Pedro Melo 2014-07-21 05:47:33 +01:00
  • b69bd4a19b Make consumer.pl trap SIGINT and SIGTERM, disconnect cleanly Pedro Melo 2014-07-21 05:20:45 +01:00
  • cfa7a7b4a5 Move publish() public API to Client, even Readers get to publish sometimes Pedro Melo 2014-07-21 05:16:17 +01:00
  • 0d8f13b950 Update publish() on both Connection and Writer to use MPUB if need be: Pedro Melo 2014-07-21 05:13:36 +01:00
  • 1ff696d616 Add support for the factors parameter in publisher.pl: Pedro Melo 2014-07-21 05:11:43 +01:00
  • 5bd01740ee Improve consumer.pl: Pedro Melo 2014-07-21 05:10:39 +01:00
  • 71c97d864c Simple TCP publisher, reads STDIN, publishes one message per line Pedro Melo 2014-07-20 22:14:20 +01:00
  • a9d7134082 Add publish() to Write Pedro Melo 2014-07-20 22:13:50 +01:00
  • d19a76677a Add publish() to Connection, mapped to PUB command Pedro Melo 2014-07-20 22:13:40 +01:00
  • 3c1a9a3083 Add private _random_connected_conn() to return one of the connect conns Pedro Melo 2014-07-20 22:13:21 +01:00
  • 5142b3a15a Add disconnect() to Client, closes all connected conns Pedro Melo 2014-07-20 22:12:38 +01:00
  • 1b536cf011 Add disconnect() to Connection, using the CLS protocol command Pedro Melo 2014-07-20 22:12:14 +01:00
  • cbc2429862 Update _process_success_frame: Pedro Melo 2014-07-20 22:11:46 +01:00
  • d3fe82af45 Added skel for our Writer class: Pedro Melo 2014-07-20 19:52:48 +01:00
  • 3e54c101f4 Tidy Pedro Melo 2014-07-20 19:50:14 +01:00
  • 35e310fd07 Tweak consumer to use the new disconnect_cb Pedro Melo 2014-07-20 19:49:17 +01:00
  • 6e6265053e Fix: Connection disconnect_cb/error_cb were being called in the wrong order Pedro Melo 2014-07-20 19:48:57 +01:00
  • e57cf0cab0 Add support for disconnect_cb on ::Connection Pedro Melo 2014-07-20 19:48:15 +01:00
  • d3df376503 Tweak ::Connection handling of *_cb parameters, more consistent errors Pedro Melo 2014-07-20 19:41:38 +01:00
  • be0643be48 Make ::Reader use the new ::Client base class Pedro Melo 2014-07-20 19:41:06 +01:00
  • ac565116a7 Create ::Client, extract common parts from Reader Pedro Melo 2014-07-20 19:40:50 +01:00
  • 903fe1cbe9 Add some comments Pedro Melo 2014-07-20 17:45:48 +01:00
  • 88b263f0d5 Tidy identify, single write with all the data Pedro Melo 2014-07-20 17:45:30 +01:00
  • 28c97bd0a4 Remove old debug information Pedro Melo 2014-07-20 17:45:06 +01:00
  • 4b5d7faf04 No need to destroy the handle on _force_disconnect, _disconnected does it Pedro Melo 2014-07-20 17:44:52 +01:00
  • 0796b36244 Fix: on disconnect, make sure we cleanup the correct attributes Pedro Melo 2014-07-20 17:44:26 +01:00
  • d7a830f0f8 Refactor _start_recv_frames into smaller methods: Pedro Melo 2014-07-20 17:43:47 +01:00
  • 36c67c9586 Add touch_msg() API Pedro Melo 2014-07-20 17:40:13 +01:00
  • c7c6038397 Fix: wrong requeue_msg() impl fixed, with support for requeue_delay Pedro Melo 2014-07-20 17:39:56 +01:00
  • 522f4e1670 Hide the call to error_cb in a new method _log_error, API changes: Pedro Melo 2014-07-20 17:38:11 +01:00
  • bfa5a905d7 Add support for connect_timeout on both Reader and Connection constructors Pedro Melo 2014-07-20 17:36:31 +01:00
  • 011c7a4b82 Default error_cb now carps, doesn't croak Pedro Melo 2014-07-20 17:35:13 +01:00
  • be7b2c03d6 Add support for requeue_delay on constructors, used on REQ responses Pedro Melo 2014-07-20 17:34:31 +01:00
  • dcca4aea33 Change API for the message callback return code: Pedro Melo 2014-07-20 17:32:50 +01:00
  • 3579cc1a48 The message already has most of the important stuff Pedro Melo 2014-07-20 17:29:39 +01:00
  • 87a8a18014 Catch and warn of errors, exit the script if one shows up Pedro Melo 2014-07-20 16:49:17 +01:00
  • 7092c3b208 Fix: make sure consumer.pl can find the AnyEvent::NSQ::Reader lib Pedro Melo 2014-07-20 16:48:44 +01:00
  • 306f8e4864 A simple consumer and a HTTP-based publisher, useful for simple benchmarks Pedro Melo 2014-07-20 13:48:16 +01:00
  • 3271c74a0b Tidy Pedro Melo 2014-07-20 13:45:26 +01:00
  • 6b86255149 Refactor Connection creation in Reader: Pedro Melo 2014-07-20 13:45:22 +01:00
  • d48cfc068f Add client_id and hostname parameters to Reader new() Pedro Melo 2014-07-20 13:43:40 +01:00
  • 15eef5072c Accept error_cb parameter on Connection new() Pedro Melo 2014-07-20 13:43:00 +01:00
  • 9521132b8b Added rough subscriber code that works, lots of open issues Pedro Melo 2014-07-20 10:27:43 +01:00
  • ceb8146410 Tweak AnyEvent::NSQ abstract and fix package name Pedro Melo 2014-07-19 21:57:52 +01:00
  • 4dbb22b847 initial commit Pedro Melo 2014-07-19 21:46:05 +01:00