Search code examples
spring-bootspring-data-gemfiregeode

java.lang.NullPointerException: When saving jpa data using Gemfire cachewriter

Jpa Repository save is working in all classes. But when trying to save in CacheWriter it is throwing NullPointerException(personRepository.save(entryEvent.getNewValue())). Any idea on this? Configured mysql database in application properties.

java.lang.NullPointerException
    at com.javasampleapproach.gemfirerestapi.GemfireWriter.beforeCreate(GemfireWriter.java:28)
    at com.gemstone.gemfire.internal.cache.LocalRegion.cacheWriteBeforePut(LocalRegion.java:3131)
    at com.gemstone.gemfire.internal.cache.AbstractRegionMap.invokeCacheWriter(AbstractRegionMap.java:3145)
    at com.gemstone.gemfire.internal.cache.AbstractRegionMap.basicPut(AbstractRegionMap.java:2909)
    at com.gemstone.gemfire.internal.cache.LocalRegion.virtualPut(LocalRegion.java:5821)
    at com.gemstone.gemfire.internal.cache.LocalRegionDataView.putEntry(LocalRegionDataView.java:118)
    at com.gemstone.gemfire.internal.cache.LocalRegion.basicPut(LocalRegion.java:5211)
    at com.gemstone.gemfire.internal.cache.LocalRegion.validatedPut(LocalRegion.java:1597)
    at com.gemstone.gemfire.internal.cache.LocalRegion.put(LocalRegion.java:1580)
    at com.gemstone.gemfire.internal.cache.AbstractRegion.put(AbstractRegion.java:327)

Controller:

@GetMapping(value = "/getPerson")
    public Iterable<Person> getPerson(@RequestParam("id") long personId,@RequestParam("age") int age, @RequestParam("name") String name) {
        try{
            Person bob = new Person();
            bob.setPersonId(personId);
            bob.setAge(age);
            bob.setName(name);
            Region<Long,Person> region=gemfireCache.getRegion("person");
            region.put(personId, bob);

        }catch(Exception e){
            e.printStackTrace();
        }
        return personRepository.findAll();
    }

Cachewriter:

public class GemfireCacheWriter implements CacheWriter<Long, Person>{
    @Autowired
    PersonRepository personRepository;

   @Override
    public void beforeCreate(EntryEvent<Long, Person> entryEvent) throws CacheWriterException {
        // TODO Auto-generated method stub
        personRepository.save(entryEvent.getNewValue());
    }

    }

CacheWriter Config:

@Bean
    LocalRegionFactoryBean<Long, Person> personRegion(final GemFireCache cache) {
        LocalRegionFactoryBean<Long, Person> personRegion = new LocalRegionFactoryBean<>();
        personRegion.setCache(cache);
        personRegion.setName("person");
        personRegion.setPersistent(false);
        personRegion.setCacheWriter(new GemfireWriter());
        personRegion.setCacheLoader(new GemfireLoader());
        return personRegion;
    }
Solution

  • Looking at the source code for LocalRegion, I don't think the entryEvent received by your CacheWriter could be null, so the actual null reference is probably personRepository. Have you correctly configured spring-data-gemfire to autowire the PersonRepository?, is the CacheWriter configured as a Spring bean (using the @Component as an example)?.

    You can use the Write Through Example as a good starting point for implementing this use case.

    Hope this helps. Cheers.