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
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions