Class MessageGroupStoreReaper
java.lang.Object
org.springframework.integration.store.MessageGroupStoreReaper
- All Implemented Interfaces:
Runnable,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle
public class MessageGroupStoreReaper
extends Object
implements Runnable, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.context.SmartLifecycle
Convenient configurable component to allow explicit timed expiry of
MessageGroup instances in a
MessageGroupStore. This component provides a no-args run() method that is useful for remote or timed
execution and a destroy() method that can optionally be called on shutdown.-
Field Summary
Fields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidvoiddestroy()intgetPhase()booleanfinal booleanvoidrun()Expire all message groups older than thetimeoutprovided.voidsetAutoStartup(boolean autoStartup) voidsetExpireOnDestroy(boolean expireOnDestroy) Flag to indicate that the stores should be expired when this component is destroyed (i.e.voidsetMessageGroupStore(MessageGroupStore messageGroupStore) A message group store to expire according the other configurations.voidsetPhase(int phase) voidsetTimeout(long timeout) Timeout in milliseconds (default -1).final voidstart()voidstop()Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.springframework.context.SmartLifecycle
stop
-
Constructor Details
-
MessageGroupStoreReaper
-
MessageGroupStoreReaper
public MessageGroupStoreReaper()
-
-
Method Details
-
setExpireOnDestroy
public void setExpireOnDestroy(boolean expireOnDestroy) Flag to indicate that the stores should be expired when this component is destroyed (i.e. usually when its enclosingApplicationContextis closed).- Parameters:
expireOnDestroy- the flag value to set
-
setTimeout
public void setTimeout(long timeout) Timeout in milliseconds (default -1). If negative then no groups ever time out. If greater than zero then all groups older than that value are expired when this component isrun().- Parameters:
timeout- the timeout to set
-
setMessageGroupStore
A message group store to expire according the other configurations.- Parameters:
messageGroupStore- theMessageGroupStoreto set
-
afterPropertiesSet
public void afterPropertiesSet()- Specified by:
afterPropertiesSetin interfaceorg.springframework.beans.factory.InitializingBean
-
destroy
public void destroy()- Specified by:
destroyin interfaceorg.springframework.beans.factory.DisposableBean
-
run
public void run()Expire all message groups older than thetimeoutprovided. Normally this method would be executed by a scheduled task. -
start
public final void start()- Specified by:
startin interfaceorg.springframework.context.Lifecycle
-
stop
public void stop()- Specified by:
stopin interfaceorg.springframework.context.Lifecycle
-
isRunning
public final boolean isRunning()- Specified by:
isRunningin interfaceorg.springframework.context.Lifecycle
-
getPhase
public int getPhase()- Specified by:
getPhasein interfaceorg.springframework.context.Phased- Specified by:
getPhasein interfaceorg.springframework.context.SmartLifecycle
-
setPhase
public void setPhase(int phase) -
isAutoStartup
public boolean isAutoStartup()- Specified by:
isAutoStartupin interfaceorg.springframework.context.SmartLifecycle
-
setAutoStartup
public void setAutoStartup(boolean autoStartup)
-