Scaling reactive APIs - www.razorcodes.com

code2_Savingtheevents1.java

@Repository
@RequiredArgsConstructor
public class CustomerRepository<E extends Identifiable> {
    
    private final RedisTemplate<String,E> staticTemplate;

    public void save(E event) {
      staticTemplate.opsForStream().add(ObjectRecord.create(customer.getStringId(), event));

    };
}