|
|
57b7715c2e
|
simplify command
|
2021-02-04 23:09:47 +03:00 |
|
|
|
b126094e74
|
Close connection on __destruct
|
2021-02-04 23:07:41 +03:00 |
|
|
|
15296f4b61
|
amphp
|
2021-02-04 22:57:46 +03:00 |
|
|
|
b2b444d1ef
|
cs: don't import globals
|
2021-02-01 02:49:53 +03:00 |
|
|
|
b395e1e3ee
|
Fix receiving double heartbeat messages
|
2021-02-01 01:20:13 +03:00 |
|
|
|
3d8f5be2d0
|
Snappy
|
2021-02-01 00:39:07 +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 |
|
|
|
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 |
|
|
|
d92f3911d5
|
Drop connection config on disconnect
|
2021-01-27 00:24:18 +03:00 |
|
|
|
d4d64df087
|
Size must be greater then max output buffer
|
2021-01-26 17:03:21 +03:00 |
|
|
|
0ba02103ef
|
Restrict disable Feature Negotiation
|
2021-01-25 03:27:53 +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 |
|
|
|
ebf82cf478
|
Reconnect
|
2021-01-24 23:15:07 +03:00 |
|
|
|
caa1bab9b5
|
Add more specific exceptions
|
2021-01-24 23:15:07 +03:00 |
|
|
|
92e8ca0812
|
Use LoggerAwareTrait
|
2021-01-24 23:15:07 +03:00 |
|
|
|
b6ce107ed1
|
Heartbeat can receive Producer too
|
2021-01-24 01:21:35 +03:00 |
|
|
|
658949519d
|
Sampling
|
2021-01-24 01:21:35 +03:00 |
|
|
|
54d9374478
|
sendWithResponse
|
2021-01-23 03:21:09 +03:00 |
|
|
|
9f95dff2ec
|
Allow configure heartbeat_interval
|
2021-01-23 02:16:29 +03:00 |
|
|
|
e821f04ebe
|
Try to resolve hostname if no configured
|
2021-01-23 02:16:05 +03:00 |
|
|
|
df89322fe0
|
Drop php 7.4
|
2021-01-23 02:15:12 +03:00 |
|
|
|
33e96e6bdc
|
Escape newline chars
|
2021-01-23 02:12:41 +03:00 |
|
|
|
7873a9f010
|
Receive Reader as dependency in Subscriber instead of extending it
|
2021-01-23 01:24:35 +03:00 |
|
|
|
fbe24eb6c4
|
Add Response object
|
2021-01-23 01:14:57 +03:00 |
|
|
|
8046eae846
|
Remove Config class
|
2021-01-23 00:37:48 +03:00 |
|
|
|
c7617cbf6e
|
Add logger
|
2021-01-23 00:36:45 +03:00 |
|
|
|
eaab94286d
|
Send client_id, hostname and user_agent to NSQ on connect
|
2021-01-23 00:34:15 +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 |
|
