org.springframework.integration.file.remote.aop

Class RotatingServerAdvice.StandardRotationPolicy

java.lang.Object

org.springframework.integration.file.remote.aop.RotatingServerAdvice.StandardRotationPolicy

All Implemented Interfaces:

RotatingServerAdvice.RotationPolicy

Enclosing class:

RotatingServerAdvice

public static class RotatingServerAdvice.StandardRotationPolicy
extends java.lang.Object
implements RotatingServerAdvice.RotationPolicy

Standard rotation policy; iterates over key/directory pairs; when the end is reached, starts again at the beginning. If the fair option is true the rotation occurs on every poll, regardless of result. Otherwise rotation occurs when the current pair returns no message.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.commons.logging.Log	logger

Constructor Summary

Constructors

Constructor and Description
StandardRotationPolicy(DelegatingSessionFactory<?> factory, java.util.List<RotatingServerAdvice.KeyDirectory> keyDirectories, boolean fair)

Method Summary

Modifier and Type	Method and Description
void	afterReceive(boolean messageReceived, MessageSource<?> source) Invoked after the message source receive() method.
void	beforeReceive(MessageSource<?> source) Invoked before the message source receive() method.
protected void	configureSource(MessageSource<?> source)
protected DelegatingSessionFactory<?>	getFactory()
protected java.util.Iterator<RotatingServerAdvice.KeyDirectory>	getIterator()
protected java.util.List<RotatingServerAdvice.KeyDirectory>	getKeyDirectories()
protected boolean	isFair()
protected boolean	isInitialized()
protected void	setInitialized(boolean initialized)
protected void	setIterator(java.util.Iterator<RotatingServerAdvice.KeyDirectory> iterator)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

protected final org.apache.commons.logging.Log logger

Constructor Detail

StandardRotationPolicy

public StandardRotationPolicy(DelegatingSessionFactory<?> factory,
                              java.util.List<RotatingServerAdvice.KeyDirectory> keyDirectories,
                              boolean fair)

Method Detail

getIterator

protected java.util.Iterator<RotatingServerAdvice.KeyDirectory> getIterator()

setIterator

protected void setIterator(java.util.Iterator<RotatingServerAdvice.KeyDirectory> iterator)

isInitialized

protected boolean isInitialized()

setInitialized

protected void setInitialized(boolean initialized)

getFactory

protected DelegatingSessionFactory<?> getFactory()

getKeyDirectories

protected java.util.List<RotatingServerAdvice.KeyDirectory> getKeyDirectories()

isFair

protected boolean isFair()

beforeReceive

public void beforeReceive(MessageSource<?> source)

Description copied from interface: RotatingServerAdvice.RotationPolicy

Invoked before the message source receive() method.

Specified by:

beforeReceive in interface RotatingServerAdvice.RotationPolicy

Parameters:

source - the message source.

afterReceive

public void afterReceive(boolean messageReceived,
                         MessageSource<?> source)

Description copied from interface: RotatingServerAdvice.RotationPolicy

Invoked after the message source receive() method.

Specified by:

afterReceive in interface RotatingServerAdvice.RotationPolicy

Parameters:

messageReceived - true if a message was received.

source - the message source.

configureSource

protected void configureSource(MessageSource<?> source)