34 Commits

Author SHA1 Message Date
d79c491578 Tests with nsqd and utilities 2022-09-12 17:59:08 +03:00
350f08c2c1 Fix and suppress static analyze errors 2022-09-11 23:07:46 +03:00
3bf8444e06 tests: add testNegotiationPayload 2022-09-11 22:03:37 +03:00
a913fb0907 Add rdyCount to ClientConfig 2021-07-08 17:41:59 +03:00
a08bccac45 phpstan: ignore Return type of call to method PHPUnit\Framework\TestCase::createMock() contains unresolvable type. 2021-06-17 16:28:24 +03:00
411fabb1f5 Fix: get default settings from real object 2021-06-09 18:20:46 +03:00
6e50fa2258 Refactoring configs. Use connections settings on establishing connection. Create ClientConfig from array. 2021-06-09 18:15:45 +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
e670cb161c amphp (#11) 2021-02-26 00:59:52 +03:00
b2b444d1ef cs: don't import globals 2021-02-01 02:49:53 +03:00
3d8f5be2d0 Snappy 2021-02-01 00:39:07 +03:00
72dca5c73b Wrap Socket 2021-01-31 17:26:07 +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
f74b82a400 Explode Response to Frames 2021-01-30 17:40:17 +03:00
ec2363c064 ClientConfigTest 2021-01-25 10:16:29 +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
ebf82cf478 Reconnect 2021-01-24 23:15:07 +03:00
caa1bab9b5 Add more specific exceptions 2021-01-24 23:15:07 +03:00
cc26255f6f Extract ProducerTest from NsqTest 2021-01-23 03:43:00 +03:00
d0594c601c Add MessageTest 2021-01-23 03:39:35 +03:00
5d407480db Add SubscriberTest 2021-01-23 02:59:41 +03:00
9f95dff2ec Allow configure heartbeat_interval 2021-01-23 02:16:29 +03:00
b6995c8f3d cs: actualize variable names 2021-01-23 01:42:20 +03:00
8725c654b2 Tests: call touch 2021-01-23 01:40:39 +03:00
6eeb2939c8 Rename Reader to Consumer and Writer to Producer 2021-01-23 01:35:09 +03:00
bf738254b1 cs: php_unit_test_case_static_method_calls with call_type self 2021-01-23 01:31:42 +03:00
18ecca3c40 Merge Envelope with Message 2021-01-23 01:30:29 +03:00
7873a9f010 Receive Reader as dependency in Subscriber instead of extending it 2021-01-23 01:24:35 +03:00
deb4ce686b Refactoring: Remove Connection::consume, add NsqException, add tests, allow dynamic change timeout in subscriber 2021-01-21 23:18:14 +03:00
0a926ce607 Refactoring: Extend Reader and Writer from Connection 2021-01-20 16:46:29 +03:00
7c6284efcb Initial commit 2021-01-19 20:33:35 +03:00