#2108 - ebean-k8scache and ebean-cluster not invalidated when only remoteTableMod or remoteCacheEvent

This commit is contained in:
rob bygrave committed 2020-11-24 22:16:14 +13:00
1 parent 21f43dc395
commit f4ea674d60
2 files changed
+35 -1

No files matched your search

@@ -152,7 +152,9 @@ public class RemoteTransactionEvent implements Runnable, BinaryWritable {
public boolean isEmpty() {
return beanPersistList.isEmpty()
&& (tableList == null || tableList.isEmpty())
&& (deleteByIdMap == null || deleteByIdMap.isEmpty());
&& (deleteByIdMap == null || deleteByIdMap.isEmpty())
&& remoteTableMod == null
&& remoteCacheEvent == null;
}
public void addBeanPersistIds(BeanPersistIds beanPersist) {
@@ -0,0 +1,32 @@
package io.ebeaninternal.server.transaction;
import io.ebeaninternal.server.cache.RemoteCacheEvent;
import org.junit.Test;
import java.util.Collections;
import java.util.HashSet;
import static org.assertj.core.api.Assertions.assertThat;
public class RemoteTransactionEventTest {
@Test
public void isEmpty_when_remoteCacheEvent_expect_false() {
RemoteTransactionEvent event = new RemoteTransactionEvent("db");
RemoteCacheEvent remote = new RemoteCacheEvent(true);
event.addRemoteCacheEvent(remote);
assertThat(event.isEmpty()).isFalse();
}
@Test
public void isEmpty_when_remoteTableMod_expect_false() {
RemoteTransactionEvent event = new RemoteTransactionEvent("db");
RemoteTableMod remote = new RemoteTableMod(new HashSet<>(Collections.singletonList("junk")));
event.addRemoteTableMod(remote);
assertThat(event.isEmpty()).isFalse();
}
}