Micronaut GCP 全球发布订阅端点
Micronaut GCP global pubsub endpoint
我在 Micronaut 文档中搜索了如何在全局范围内定义 GCP 主题端点的解决方案,但没有成功。现在,我必须在每个发布者中执行以下配置。
任何建议将不胜感激。
环境:Micronaut 3.4.2
@PubSubClient
interface SnapshotPublisher {
@Topic(value = "${gcp.snapshot-topic}", endpoint = "${gcp.pubsub.endpoint}")
fun send(snapshotJson: String): Mono<String>
}
到目前为止,还没有办法指定哪些主题应该全局发布到端点。
参见 https://github.com/micronaut-projects/micronaut-gcp/blob/df60adbb8f4fd00fb6be2afc4d3146b71bf99425/gcp-pubsub/src/main/java/io/micronaut/gcp/pubsub/intercept/PubSubClientIntroductionAdvice.java#L106。
这个 PR 应该可以解决这个问题,如果它被合并:https://github.com/micronaut-projects/micronaut-gcp/pull/635
我在 Micronaut 文档中搜索了如何在全局范围内定义 GCP 主题端点的解决方案,但没有成功。现在,我必须在每个发布者中执行以下配置。
任何建议将不胜感激。
环境:Micronaut 3.4.2
@PubSubClient
interface SnapshotPublisher {
@Topic(value = "${gcp.snapshot-topic}", endpoint = "${gcp.pubsub.endpoint}")
fun send(snapshotJson: String): Mono<String>
}
到目前为止,还没有办法指定哪些主题应该全局发布到端点。 参见 https://github.com/micronaut-projects/micronaut-gcp/blob/df60adbb8f4fd00fb6be2afc4d3146b71bf99425/gcp-pubsub/src/main/java/io/micronaut/gcp/pubsub/intercept/PubSubClientIntroductionAdvice.java#L106。
这个 PR 应该可以解决这个问题,如果它被合并:https://github.com/micronaut-projects/micronaut-gcp/pull/635