> Hi, how about your `@Configuration` class.
`@Configuration
public class DubboProviderConfig {
@Bean
public ApplicationConfig applicationConfig() {
ApplicationConfig applicationConfig = new ApplicationConfig();
applicationConfig.setName("money-application");
return applicationConfig;
}
@Bean
public RegistryConfig
registryConfig(@Value("${zoo_hosts:zookeeper://127.0.0.1:2181}") String hosts) {
RegistryConfig config = new RegistryConfig();
config.setCheck(false);
config.setAddress(hosts);
config.setClient("curator");
Map<String, String> parameters = new HashMap<>();
parameters.put("qos.enable", "false");
config.setParameters(parameters);
return config;
}
@Bean
public ProtocolConfig protocolConfig(@Value("${provider_port:10300}")
int port,
@Value("${provider_host:0.0.0.0}") String host) {
ProtocolConfig config = new ProtocolConfig();
config.setName("dubbo");
config.setServer("netty4");
config.setPort(port);
config.setHost(host);
config.setSerialization("hessian2");
config.setThreads(500);
return config;
}
@Bean
public ProviderConfig providerConfig() {
ProviderConfig config = new ProviderConfig();
config.setVersion(Constants.SERVICE_VERSION);
config.setLoadbalance("idBalance");
config.setDispatcher("all");
return config;
}
@Bean
public ConsumerConfig consumerConfig() {
ConsumerConfig config = new ConsumerConfig();
config.setCheck(false);
config.setMock(false);
config.setLoadbalance("idBalance");
config.setClient("netty4");
config.setTimeout(Constants.DUBBO_RPC_TIMEOUT);
config.setVersion(Constants.SERVICE_VERSION);
return config;
}
}
`
[ Full content available at:
https://github.com/apache/incubator-dubbo/issues/3529 ]
This message was relayed via gitbox.apache.org for
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
