Skip to content

dq 的 consumerCluster 需要提供 Close 方法 #81

@marsmay

Description

@marsmay

目前 beanstalkd 的消费者 dq.consumerCluster 没有 Close 方法,无法在程序退出时调用实现安全关闭。
kafka 的 kq.kafkaQueue 是用 Stop 方法的,并设计了数据清理和安全关闭的方法。
希望能使用类似的设计,使 dq.consumerCluster 实现 service.Service 接口,从而将多个消费者包装成 service.ServiceGroup,这样可以利用 service.ServiceGroup 在程序处理时自动调用每个 service.Service 的 Stop 方法并等待结束的机制,实现安全退出。

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions