Set ClientCacheFactoryBean.readyForEvents property to true.

geode-spring-boot/src/main/java/org/springframework/geode/config/annotation/DurableClientConfiguration.java

@@ -56,10 +56,12 @@ import org.springframework.util.StringUtils;
 public class DurableClientConfiguration extends AbstractAnnotationConfigSupport implements ImportAware {
 
 	public static final boolean DEFAULT_KEEP_ALIVE = true;
+	public static final boolean DEFAULT_READY_FOR_EVENTS = true;
 
 	public static final int DEFAULT_DURABLE_CLIENT_TIMEOUT = 300;
 
 	private Boolean keepAlive = DEFAULT_KEEP_ALIVE;
+	private Boolean readyForEvents = DEFAULT_READY_FOR_EVENTS;
 
 	private Integer durableClientTimeout = DEFAULT_DURABLE_CLIENT_TIMEOUT;
 
@@ -91,6 +93,10 @@ public class DurableClientConfiguration extends AbstractAnnotationConfigSupport
 			this.keepAlive = enableDurableClientAttributes.containsKey("keepAlive")
 				? enableDurableClientAttributes.getBoolean("keepAlive")
 				: DEFAULT_KEEP_ALIVE;
+
+			this.readyForEvents = enableDurableClientAttributes.containsKey("readyForEvents")
+				? enableDurableClientAttributes.getBoolean("readyForEvents")
+				: DEFAULT_READY_FOR_EVENTS;
 		}
 	}
 
@@ -106,12 +112,18 @@ public class DurableClientConfiguration extends AbstractAnnotationConfigSupport
 			.orElse(DEFAULT_DURABLE_CLIENT_TIMEOUT);
 	}
 
-	public Boolean getKeepAlive() {
+	protected Boolean getKeepAlive() {
 
 		return Optional.ofNullable(this.keepAlive)
 			.orElse(DEFAULT_KEEP_ALIVE);
 	}
 
+	protected Boolean getReadyForEvents() {
+
+		return Optional.ofNullable(this.readyForEvents)
+			.orElse(DEFAULT_READY_FOR_EVENTS);
+	}
+
 	protected Logger getLogger() {
 		return this.logger;
 	}
@@ -120,9 +132,11 @@ public class DurableClientConfiguration extends AbstractAnnotationConfigSupport
 	ClientCacheConfigurer clientCacheDurableClientConfigurer() {
 
 		return (beanName, clientCacheFactoryBean) -> getDurableClientId().ifPresent(durableClientId -> {
+
 			clientCacheFactoryBean.setDurableClientId(durableClientId);
 			clientCacheFactoryBean.setDurableClientTimeout(getDurableClientTimeout());
 			clientCacheFactoryBean.setKeepAlive(getKeepAlive());
+			clientCacheFactoryBean.setReadyForEvents(getReadyForEvents());
 		});
 	}
 

geode-spring-boot/src/main/java/org/springframework/geode/config/annotation/EnableDurableClient.java

@@ -61,6 +61,13 @@ public @interface EnableDurableClient {
 	 */
 	boolean keepAlive() default DurableClientConfiguration.DEFAULT_KEEP_ALIVE;
 
+	/**
+	 * Configures whether the {@link ClientCache} is ready to recieve events on startup.
+	 *
+	 * Defaults to {@literal true}.
+	 */
+	boolean readyForEvents() default DurableClientConfiguration.DEFAULT_READY_FOR_EVENTS;
+
 	/**
 	 * Used only for clients in a client/server installation. Number of seconds this client can remain disconnected
 	 * from its server and have the server continue to accumulate durable events for it.

geode-spring-boot/src/test/java/org/springframework/geode/config/annotation/DurableClientIdConfigurationIntegrationTests.java

@@ -111,6 +111,13 @@ public class DurableClientIdConfigurationIntegrationTests extends IntegrationTes
 		assertThat(this.clientCacheFactoryBean.isKeepAlive()).isTrue();
 	}
 
+	@Test
+	public void setClientCacheFactoryBeanSetsReadyForEventOnContextRefreshedEvent() {
+
+		assertThat(this.clientCacheFactoryBean).isNotNull();
+		assertThat(this.clientCacheFactoryBean.isReadyForEvents()).isTrue();
+	}
+
 	@ClientCacheApplication
 	@EnableGemFireMockObjects
 	@EnableDurableClient(id = "abc123", timeout = 600)