import nats.client.Nats; //导入依赖的package包/类
@Bean
public EventRetriever eventRetriever(Nats nats) {
    EventRetriever retriever = new NatsEventRetriever(nats);
    ArgumentCaptor<MessageHandler> msgHandler = ArgumentCaptor.forClass(MessageHandler.class);
    verify(nats, times(1)).subscribe(eq("platform.>"), msgHandler.capture());
    messageHandler = msgHandler.getValue();
    return retriever;
}
 

import nats.client.Nats; //导入依赖的package包/类
public NatsGorouterAddressRetriever(Nats nats) {
    this.addresses = Collections.synchronizedList(new ArrayList<>());
    this.mapper = new ObjectMapper();

    nats.subscribe(NATS_ROUTER_REGISTER, this::onMessageArrived);
    nats.publish(NATS_ROUTER_GREET, "", NATS_ROUTER_REGISTER);
}
 

import nats.client.Nats; //导入依赖的package包/类
@Bean
public Nats nats(ApplicationEventPublisher applicationEventPublisher) {
    return new NatsBuilder(applicationEventPublisher)
        .addHost(natsUri)
        .connect();
}
 

import nats.client.Nats; //导入依赖的package包/类
@Bean
public EventRetriever eventRetriever(Nats nats) {
    return new NatsEventRetriever(nats);
}
 

import nats.client.Nats; //导入依赖的package包/类
public NatsEventRetriever(Nats nats) {
    this.mapper = new ObjectMapper();

    nats.subscribe(NATS_SUBJECT, this::onMessageArrived);
}
 

import nats.client.Nats; //导入依赖的package包/类
@Bean
public Nats nats() {
    return mock(Nats.class);
}
 

import nats.client.Nats; //导入依赖的package包/类
@Bean
public Nats nats(ApplicationEventPublisher applicationEventPublisher){
    return new NatsBuilder(applicationEventPublisher)
        .addHost(natsUri)
        .connect();
}
 

import nats.client.Nats; //导入依赖的package包/类
@Bean
public GorouterAddressRetriever gorouterAddresses(Nats nats){
    return new NatsGorouterAddressRetriever(nats);
}
 

import nats.client.Nats; //导入依赖的package包/类
@Bean
Nats nats() { return new NatsConnector().addHost("nats://nats:[email protected]").connect(); }
 

import nats.client.Nats; //导入依赖的package包/类
@Bean
Nats nats(ApplicationEventPublisher publisher, Environment environment) {
	return new NatsBuilder(publisher).addHost(environment.getProperty("nats.url", "nats://localhost")).connect();
}
 

import nats.client.Nats; //导入依赖的package包/类
@Bean
CfNats cfNats(Nats nats) {
	return new DefaultCfNats(nats);
}