以 evt-imdb_produce_service-to_refresh--imdb_consumer_service.refresh
队列举例
投递音讯
dispatch( 'imdb_produce_service', 'to_refresh', message.json(ensure_ascii=False))
生产音讯
class ImdbRefreshService: name = 'imdb_consumer_service' @event_handler( source_service='imdb_produce_service', event_type='to_refresh', requeue_on_error=True) def refresh(self, payload: str) -> None: message = Message.parse_raw(payload)
所以,nameko 队列的命名规定是: evt-{source_service_name}-{event_type}--{dst_service_name}.{dst_class_func_name}