youzan / nsqJavaSDK

nsq client for java
37 stars 22 forks source link

extension header based message consumption filter #10

Closed DoraALin closed 6 years ago

DoraALin commented 6 years ago

extension key:value based message consume filter. sdk allows to specify extension $key and its expected $value. Before deliver one message to message handler, sdk check if extensionJson[$key]==$value in message's extension header. if target topic does not support extension message, filter does not apply.