Commit Graph

145 Commits

Author SHA1 Message Date
55480ab2c0 Bump friendsofphp/php-cs-fixer up to 3.0 2021-06-17 16:21:26 +03:00
4546c5085f Bump infection/infection up to 0.23 2021-06-17 16:18:55 +03:00
b6f4726002 Fix: ClientConfig::$connectionTimeout is a milliseconds 2021-06-17 15:46:51 +03:00
e3c64f6f09 tls 2021-06-09 20:08:15 +03:00
411fabb1f5 Fix: get default settings from real object 2021-06-09 18:20:46 +03:00
34847e2467 Mark ServerConfig as internal 2021-06-09 18:17:00 +03:00
6e50fa2258 Refactoring configs. Use connections settings on establishing connection. Create ClientConfig from array. 2021-06-09 18:15:45 +03:00
ca54c7ad80 Add symfony/var-dumper for dev 2021-06-09 18:13:17 +03:00
4c00fb0fd5 Message::requeue $timeout must be positive-int or zero 2021-06-09 17:08:46 +03:00
d3e1788d23 Refactoring: Simplify Message methods, add isProcessed method. 2021-06-09 16:33:18 +03:00
2fc7e37120 Producer::publish $delay must be positive-int or zero 2021-06-09 15:34:29 +03:00
92d8304a6a Remove Producer::defer 2021-03-10 22:12:09 +03:00
3e4e8c3802 Fix ErrorTypeTest::data() return phpdoc 2021-03-10 21:19:58 +03:00
2f638b9c75 Remove Reader and ConsumerInterface 2021-03-10 21:19:58 +03:00
9f004417fa Make connect methods idempotent 2021-02-28 20:26:08 +03:00
e670cb161c amphp (#11) 2021-02-26 00:59:52 +03:00
9cefa847a9 Add .gitattributes 2021-02-11 15:12:03 +03:00
875cb8b542 Mark message methods as internal 2021-02-01 03:08:14 +03:00
b2b444d1ef cs: don't import globals 2021-02-01 02:49:53 +03:00
f6ef057e40 Snappy throw exception if extension not installed 2021-02-01 02:40:00 +03:00
db988a0914 Fix receiving partial message from nsq 2021-02-01 02:38:19 +03:00
3c0ec5574d add ru.grachevko.dhu labels 2021-02-01 02:33:38 +03:00
b395e1e3ee Fix receiving double heartbeat messages 2021-02-01 01:20:13 +03:00
801fdfe547 Snappy fix receiving partial message 2021-02-01 01:17:39 +03:00
3d8f5be2d0 Snappy 2021-02-01 00:39:07 +03:00
070b980003 Use Buffer in Producer::mpub 2021-01-31 18:11:37 +03:00
a66f622cf6 Expect heartbeat in checkIsOk 2021-01-31 18:11:24 +03:00
72dca5c73b Wrap Socket 2021-01-31 17:26:07 +03:00
e3485416a5 Move try/catch from readFrame to read 2021-01-30 18:40:34 +03:00
930314f1ac Convert comments to phpdoc 2021-01-30 18:26:31 +03:00
e1cca2d3eb Remove Subscriber 2021-01-30 18:22:34 +03:00
1a24efacfb NSQ Connection can subscribe only for one topic 2021-01-30 18:13:50 +03:00
a7b847146a Prevent recreate ByteBuffer objects 2021-01-30 18:05:36 +03:00
f74b82a400 Explode Response to Frames 2021-01-30 17:40:17 +03:00
fc6b67cc92 Add Dockerfile 2021-01-28 01:11:32 +03:00
d92f3911d5 Drop connection config on disconnect 2021-01-27 00:24:18 +03:00
c94f2df32e Fix snappy in ClientConfig serialize 2021-01-27 00:05:02 +03:00
ad4517d4ae Log reconnect attempt as warning 2021-01-27 00:03:45 +03:00
d4d64df087 Size must be greater then max output buffer 2021-01-26 17:03:21 +03:00
ec2363c064 ClientConfigTest 2021-01-25 10:16:29 +03:00
ccb4200110 readme: cleanup 2021-01-25 03:29:30 +03:00
0ba02103ef Restrict disable Feature Negotiation 2021-01-25 03:27:53 +03:00
da4331127b Refactoring: Move delay parameter as last in Producer::dpub 2021-01-25 03:27:04 +03:00
d9bf2a4437 Add ClientConfig and ConnectionConfig, Feature Negotiation and Authentication 2021-01-25 03:19:54 +03:00
551bcfb10b Refactoring: Add typed Connection::command method if favor of send 2021-01-25 01:56:58 +03:00
66b5b77bef Refactoring: remove Connection::sendWithResponse 2021-01-25 01:26:00 +03:00
33ef674e58 cs: add blank_line_before_statement 2021-01-24 23:15:51 +03:00
ebf82cf478 Reconnect 2021-01-24 23:15:07 +03:00
f0b8ad1373 Ignore Coverage in ConnectionFail 2021-01-24 23:15:07 +03:00
caa1bab9b5 Add more specific exceptions 2021-01-24 23:15:07 +03:00