Thank you Ilya!
I did replace Ignite bean with IgniteSpringBean by using Java configuration
(and not the XML) as below,
@Slf4j
@Configuration
public class BeansConfig {
@Bean
public IgniteSpringBean igniteSpringBean() {
log.debug("igniteSpringBean service");
IgniteSpringBean igniteSpringBean = new IgniteSpringBean();
igniteSpringBean.setConfiguration(igniteConfiguration());
return igniteSpringBean;
}
private IgniteConfiguration igniteConfiguration() {
log.debug("igniteConfiguration service");
TcpDiscoverySpi spi = new TcpDiscoverySpi();
spi.setLocalPort(42500);
spi.setLocalPortRange(100);
TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
//
ipFinder.setAddresses(Arrays.asList("172.17.104.233:42500..42700"));
ipFinder.setAddresses(Arrays.asList("localhost:42500..42700"));
spi.setIpFinder(ipFinder);
IgniteConfiguration igniteConfiguration = new
IgniteConfiguration();
igniteConfiguration.setFailureDetectionTimeout(90000);
TcpCommunicationSpi commSpi = new TcpCommunicationSpi();
commSpi.setLocalPort(42100);
commSpi.setMessageQueueLimit(1024);
commSpi.setSocketWriteTimeout(10000L);
igniteConfiguration.setCommunicationSpi(commSpi);
// All properties should be in YAML
igniteConfiguration.setDiscoverySpi(spi);
igniteConfiguration.setIncludeEventTypes();
igniteConfiguration.setPeerClassLoadingEnabled(true);
igniteConfiguration.setGridLogger(new Slf4jLogger());
igniteConfiguration.setWorkDirectory("/var/tmp/ignite/work");
return igniteConfiguration;
}
}
Anyone looking to make use @SpringResource &
@SpringApplicationContextResource please refer the below code,
Compute client
<https://github.com/ashishb888/ignite-2.8-poc/tree/master/ignite-spring-resource-compute-client>
Compute server
<https://github.com/ashishb888/ignite-2.8-poc/tree/master/ignite-spring-resource>
BR,
Ashish
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/