nsq/nsqphp
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
76 Commits 5 Branches 0 Tags
f6ef057e40714b827b85c65a5a29862a27e90c9c
Commit Graph
76 Commits
This Branch
This Branch
All Branches
Author SHA1 Message Date
grachevko f6ef057e40 Snappy throw exception if extension not installed 2021-02-01 02:40:00 +03:00
grachevko db988a0914 Fix receiving partial message from nsq 2021-02-01 02:38:19 +03:00
grachevko 3c0ec5574d add ru.grachevko.dhu labels 2021-02-01 02:33:38 +03:00
grachevko b395e1e3ee Fix receiving double heartbeat messages 2021-02-01 01:20:13 +03:00
grachevko 801fdfe547 Snappy fix receiving partial message 2021-02-01 01:17:39 +03:00
grachevko 3d8f5be2d0 Snappy 2021-02-01 00:39:07 +03:00
grachevko 070b980003 Use Buffer in Producer::mpub 2021-01-31 18:11:37 +03:00
grachevko a66f622cf6 Expect heartbeat in checkIsOk 2021-01-31 18:11:24 +03:00
grachevko 72dca5c73b Wrap Socket 2021-01-31 17:26:07 +03:00
grachevko e3485416a5 Move try/catch from readFrame to read 2021-01-30 18:40:34 +03:00
grachevko 930314f1ac Convert comments to phpdoc 2021-01-30 18:26:31 +03:00
grachevko e1cca2d3eb Remove Subscriber 2021-01-30 18:22:34 +03:00
grachevko 1a24efacfb NSQ Connection can subscribe only for one topic 2021-01-30 18:13:50 +03:00
grachevko a7b847146a Prevent recreate ByteBuffer objects 2021-01-30 18:05:36 +03:00
grachevko f74b82a400 Explode Response to Frames 2021-01-30 17:40:17 +03:00
grachevko fc6b67cc92 Add Dockerfile 2021-01-28 01:11:32 +03:00
grachevko d92f3911d5 Drop connection config on disconnect 2021-01-27 00:24:18 +03:00
grachevko c94f2df32e Fix snappy in ClientConfig serialize 2021-01-27 00:05:02 +03:00
grachevko ad4517d4ae Log reconnect attempt as warning 2021-01-27 00:03:45 +03:00
grachevko d4d64df087 Size must be greater then max output buffer 2021-01-26 17:03:21 +03:00
grachevko ec2363c064 ClientConfigTest 2021-01-25 10:16:29 +03:00
grachevko ccb4200110 readme: cleanup 2021-01-25 03:29:30 +03:00
grachevko 0ba02103ef Restrict disable Feature Negotiation 2021-01-25 03:27:53 +03:00
grachevko da4331127b Refactoring: Move delay parameter as last in Producer::dpub 2021-01-25 03:27:04 +03:00
grachevko d9bf2a4437 Add ClientConfig and ConnectionConfig, Feature Negotiation and Authentication 2021-01-25 03:19:54 +03:00
grachevko 551bcfb10b Refactoring: Add typed Connection::command method if favor of send 2021-01-25 01:56:58 +03:00
grachevko 66b5b77bef Refactoring: remove Connection::sendWithResponse 2021-01-25 01:26:00 +03:00
grachevko 33ef674e58 cs: add blank_line_before_statement 2021-01-24 23:15:51 +03:00
grachevko ebf82cf478 Reconnect 2021-01-24 23:15:07 +03:00
grachevko f0b8ad1373 Ignore Coverage in ConnectionFail 2021-01-24 23:15:07 +03:00
grachevko caa1bab9b5 Add more specific exceptions 2021-01-24 23:15:07 +03:00
grachevko 92e8ca0812 Use LoggerAwareTrait 2021-01-24 23:15:07 +03:00
grachevko 23c8681376 Require php:^8.0.1 2021-01-24 01:22:53 +03:00
grachevko b6ce107ed1 Heartbeat can receive Producer too 2021-01-24 01:21:35 +03:00
grachevko 658949519d Sampling 2021-01-24 01:21:35 +03:00
grachevko 8d03980177 update php path version 2021-01-24 01:14:16 +03:00
grachevko 4cdc42e2fa psalm --output-format=github 2021-01-24 01:14:16 +03:00
grachevko 6124d9360b Cache Composer Dependencies 2021-01-24 01:14:16 +03:00
grachevko d475ad8765 Infection (#4) 2021-01-23 23:34:18 +03:00
grachevko cc26255f6f Extract ProducerTest from NsqTest 2021-01-23 03:43:00 +03:00
grachevko d0594c601c Add MessageTest 2021-01-23 03:39:35 +03:00
grachevko 33b1ee129b Mark consumer as final 2021-01-23 03:24:39 +03:00
grachevko 54d9374478 sendWithResponse 2021-01-23 03:21:09 +03:00
grachevko 5d407480db Add SubscriberTest 2021-01-23 02:59:41 +03:00
grachevko 6e37bbd1ae Prevent send RDY every iteration 2021-01-23 02:29:36 +03:00
grachevko bc276c7c57 Readme: update requirements 2021-01-23 02:29:36 +03:00
grachevko 9f95dff2ec Allow configure heartbeat_interval 2021-01-23 02:16:29 +03:00
grachevko e821f04ebe Try to resolve hostname if no configured 2021-01-23 02:16:05 +03:00
grachevko df89322fe0 Drop php 7.4 2021-01-23 02:15:12 +03:00
grachevko 33e96e6bdc Escape newline chars 2021-01-23 02:12:41 +03:00
grachevko b6995c8f3d cs: actualize variable names 2021-01-23 01:42:20 +03:00
grachevko 8725c654b2 Tests: call touch 2021-01-23 01:40:39 +03:00
grachevko 6eeb2939c8 Rename Reader to Consumer and Writer to Producer 2021-01-23 01:35:09 +03:00
grachevko bf738254b1 cs: php_unit_test_case_static_method_calls with call_type self 2021-01-23 01:31:42 +03:00
grachevko 18ecca3c40 Merge Envelope with Message 2021-01-23 01:30:29 +03:00
grachevko 7873a9f010 Receive Reader as dependency in Subscriber instead of extending it 2021-01-23 01:24:35 +03:00
grachevko 6509753bd9 publish api port for tests 2021-01-23 01:16:34 +03:00
grachevko 98642e9f6c Composer: fix test script 2021-01-23 01:15:14 +03:00
grachevko fbe24eb6c4 Add Response object 2021-01-23 01:14:57 +03:00
grachevko 8046eae846 Remove Config class 2021-01-23 00:37:48 +03:00
grachevko c7617cbf6e Add logger 2021-01-23 00:36:45 +03:00
grachevko eaab94286d Send client_id, hostname and user_agent to NSQ on connect 2021-01-23 00:34:15 +03:00
grachevko fb7857291e Composer: rename phpcs to cs-check, csfix to cs 2021-01-23 00:32:39 +03:00
grachevko b87c691eb3 Readme: update Subscriber example 2021-01-21 23:47:54 +03:00
grachevko 914d2690f1 Readme: add change_timeout example 2021-01-21 23:41:16 +03:00
grachevko 9358746a8a Readme: change description 2021-01-21 23:33:43 +03:00
grachevko deb4ce686b Refactoring: Remove Connection::consume, add NsqException, add tests, allow dynamic change timeout in subscriber 2021-01-21 23:18:14 +03:00
grachevko 33bcb99c86 Readme: add semver 2021-01-20 18:56:44 +03:00
grachevko c7970f9902 Use constant for gracefully shutdown value 2021-01-20 18:38:48 +03:00
grachevko 46f0e8bea5 Add isFinished to Envelope 2021-01-20 17:53:24 +03:00
grachevko 6a7fac12cb Readme: add usage 2021-01-20 17:13:43 +03:00
grachevko 0a926ce607 Refactoring: Extend Reader and Writer from Connection 2021-01-20 16:46:29 +03:00
grachevko fdd65cb547 Composer: add scripts for dev 2021-01-20 14:43:46 +03:00
grachevko c5b0d3b986 Readme: flip pub/sub 2021-01-20 13:34:21 +03:00
grachevko c57490359a Initial commit 2021-01-19 20:39:03 +03:00
grachevko 7c6284efcb Initial commit 2021-01-19 20:33:35 +03:00