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

Change assertion error message in AsyncEventError class constructor.

Browse Source 
Rename class member reference to the default AsyncEventError handler from DEFAULT_EVENT_ERROR_HANDLER to DEFAULT_ASYNC_EVENT_ERROR_HANDLER.
This commit is contained in:
John Blum
2020-12-01 10:42:39 -08:00
parent ecedb4cd90
commit 27c907336a
2 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-geode/src/main/java/org/springframework/geode/cache/RepositoryAsyncEventListener.java vendored
View File

@@ -47,9 +47,9 @@ import org.springframework.util.Assert;
*/
public class RepositoryAsyncEventListener<T, ID> implements AsyncEventListener {
protected static final AsyncEventErrorHandler DEFAULT_EVENT_ERROR_HANDLER = eventError -> false;
protected static final AsyncEventErrorHandler DEFAULT_ASYNC_EVENT_ERROR_HANDLER = eventError -> false;
private AsyncEventErrorHandler asyncEventErrorHandler = DEFAULT_EVENT_ERROR_HANDLER;
private AsyncEventErrorHandler asyncEventErrorHandler = DEFAULT_ASYNC_EVENT_ERROR_HANDLER;
private final CrudRepository<T, ID> repository;
@@ -102,7 +102,7 @@ public class RepositoryAsyncEventListener<T, ID> implements AsyncEventListener {
* @see AsyncEventErrorHandler
*/
protected @NonNull AsyncEventErrorHandler getAsyncEventErrorHandler() {
return this.asyncEventErrorHandler != null ? this.asyncEventErrorHandler : DEFAULT_EVENT_ERROR_HANDLER;
return this.asyncEventErrorHandler != null ? this.asyncEventErrorHandler : DEFAULT_ASYNC_EVENT_ERROR_HANDLER;
}
/**
@@ -238,7 +238,7 @@ public class RepositoryAsyncEventListener<T, ID> implements AsyncEventListener {
public AsyncEventError(@NonNull AsyncEvent<?, ?> event, @NonNull Throwable cause) {
Assert.notNull(event, "AsyncEvent must not be null");
Assert.notNull(cause, "The cause must not be null");
Assert.notNull(cause, "Cause must not be null");
this.event = event;
this.cause = cause;

6
spring-geode/src/test/java/org/springframework/geode/cache/RepositoryAsyncEventListenerUnitTests.java vendored
View File

@@ -107,7 +107,7 @@ public class RepositoryAsyncEventListenerUnitTests {
RepositoryAsyncEventListener listener = new RepositoryAsyncEventListener<>(mockRepository);
assertThat(listener.getAsyncEventErrorHandler())
.isEqualTo(RepositoryAsyncEventListener.DEFAULT_EVENT_ERROR_HANDLER);
.isEqualTo(RepositoryAsyncEventListener.DEFAULT_ASYNC_EVENT_ERROR_HANDLER);
listener.setAsyncEventErrorHandler(mockAsyncEventErrorHandler);
@@ -116,7 +116,7 @@ public class RepositoryAsyncEventListenerUnitTests {
listener.setAsyncEventErrorHandler(null);
assertThat(listener.getAsyncEventErrorHandler())
.isEqualTo(RepositoryAsyncEventListener.DEFAULT_EVENT_ERROR_HANDLER);
.isEqualTo(RepositoryAsyncEventListener.DEFAULT_ASYNC_EVENT_ERROR_HANDLER);
verifyNoInteractions(mockAsyncEventErrorHandler, mockRepository);
}
@@ -412,7 +412,7 @@ public class RepositoryAsyncEventListenerUnitTests {
}
catch (IllegalArgumentException expected) {
assertThat(expected).hasMessage("The cause must not be null");
assertThat(expected).hasMessage("Cause must not be null");
assertThat(expected).hasNoCause();
throw expected;