walkor / channel

Interprocess communication component for workerman
137 stars 49 forks source link

Make Channel message queue ability. #7

Closed xpader closed 3 years ago

xpader commented 3 years ago

New method for Client: watch, unwatch, enqueue. Support for message queue ability. This is simple message queue implement: One message can be received by only one watcher(consumer), not all the watchers, and message can be queued in Server when watcher(consumer) is busy. There's no message confirmation, no persistent storage, no delay message. It's just another way for communication before processes.

walkor commented 3 years ago

Thanks. 👍