Spring/spring-data-cassandra
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DATACASS-618 - Polishing.

Browse Source 
Expose maybeEmitEvent(…) so it can be overridden in subclasses.
This commit is contained in:
Mark Paluch
2019-06-07 16:07:36 +02:00
parent 86c47e80f8
commit 8f6d070707
3 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/AsyncCassandraTemplate.java
View File

@@ -24,7 +24,6 @@ import java.util.function.Function;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.context.ApplicationEvent;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
import org.springframework.dao.DataAccessException;
@@ -55,6 +54,7 @@ import org.springframework.data.cassandra.core.mapping.event.BeforeConvertCallba
import org.springframework.data.cassandra.core.mapping.event.BeforeDeleteEvent;
import org.springframework.data.cassandra.core.mapping.event.BeforeSaveCallback;
import org.springframework.data.cassandra.core.mapping.event.BeforeSaveEvent;
import org.springframework.data.cassandra.core.mapping.event.CassandraMappingEvent;
import org.springframework.data.cassandra.core.query.Query;
import org.springframework.data.domain.Slice;
import org.springframework.data.mapping.callback.EntityCallbacks;
@@ -859,7 +859,7 @@ public class AsyncCassandraTemplate
return converter;
}
private void maybeEmitEvent(ApplicationEvent event) {
protected <E extends CassandraMappingEvent<T>, T> void maybeEmitEvent(E event) {
if (this.eventPublisher != null) {
this.eventPublisher.publishEvent(event);

4
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/CassandraTemplate.java
View File

@@ -26,7 +26,6 @@ import java.util.stream.StreamSupport;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.context.ApplicationEvent;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
import org.springframework.dao.DataAccessException;
@@ -56,6 +55,7 @@ import org.springframework.data.cassandra.core.mapping.event.BeforeConvertCallba
import org.springframework.data.cassandra.core.mapping.event.BeforeDeleteEvent;
import org.springframework.data.cassandra.core.mapping.event.BeforeSaveCallback;
import org.springframework.data.cassandra.core.mapping.event.BeforeSaveEvent;
import org.springframework.data.cassandra.core.mapping.event.CassandraMappingEvent;
import org.springframework.data.cassandra.core.query.Columns;
import org.springframework.data.cassandra.core.query.Query;
import org.springframework.data.domain.Slice;
@@ -932,7 +932,7 @@ public class CassandraTemplate implements CassandraOperations, ApplicationEventP
return converter;
}
private void maybeEmitEvent(ApplicationEvent event) {
protected <E extends CassandraMappingEvent<T>, T> void maybeEmitEvent(E event) {
if (this.eventPublisher != null) {
this.eventPublisher.publishEvent(event);

4
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/ReactiveCassandraTemplate.java
View File

@@ -29,7 +29,6 @@ import org.reactivestreams.Publisher;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.context.ApplicationEvent;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
import org.springframework.dao.DataAccessException;
@@ -59,6 +58,7 @@ import org.springframework.data.cassandra.core.mapping.event.AfterLoadEvent;
import org.springframework.data.cassandra.core.mapping.event.AfterSaveEvent;
import org.springframework.data.cassandra.core.mapping.event.BeforeDeleteEvent;
import org.springframework.data.cassandra.core.mapping.event.BeforeSaveEvent;
import org.springframework.data.cassandra.core.mapping.event.CassandraMappingEvent;
import org.springframework.data.cassandra.core.mapping.event.ReactiveBeforeConvertCallback;
import org.springframework.data.cassandra.core.mapping.event.ReactiveBeforeSaveCallback;
import org.springframework.data.cassandra.core.query.Columns;
@@ -879,7 +879,7 @@ public class ReactiveCassandraTemplate
return converter;
}
private void maybeEmitEvent(ApplicationEvent event) {
protected <E extends CassandraMappingEvent<T>, T> void maybeEmitEvent(E event) {
if (this.eventPublisher != null) {
this.eventPublisher.publishEvent(event);