public class StandardRotationPolicy extends ObjectSE implements RotationPolicy
onRotation(MessageSource<?> source) を実装して、各ローテーションで MessageSource を構成します。RotationPolicy.KeyDirectory| コンストラクターと説明 |
|---|
StandardRotationPolicy(DelegatingSessionFactory<?> factory, ListSE<RotationPolicy.KeyDirectory> keyDirectories, boolean fair) |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | afterReceive(boolean messageReceived, MessageSource<?> source) メッセージソース receive() メソッドの後に呼び出されます。 |
void | beforeReceive(MessageSource<?> source) メッセージソース receive() メソッドの前に呼び出されます。 |
protected void | configureSource(MessageSource<?> source) |
RotationPolicy.KeyDirectory | getCurrent() 現在の RotationPolicy.KeyDirectory を返します。 |
protected DelegatingSessionFactory<?> | getFactory() |
protected IteratorSE<RotationPolicy.KeyDirectory> | getIterator() |
protected ListSE<RotationPolicy.KeyDirectory> | getKeyDirectories() |
protected boolean | isFair() |
protected boolean | isInitialized() |
protected void | onRotation(MessageSource<?> source) 必要に応じて、サーバーのローテーション後に MessageSource の状態を更新します。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEprotected final Log logger
public StandardRotationPolicy(DelegatingSessionFactory<?> factory, ListSE<RotationPolicy.KeyDirectory> keyDirectories, boolean fair)
public void beforeReceive(MessageSource<?> source)
RotationPolicyRotationPolicy の beforeReceive source - メッセージソース。public void afterReceive(boolean messageReceived,
MessageSource<?> source)RotationPolicyRotationPolicy の afterReceive messageReceived - メッセージが受信された場合は true。source - メッセージソース。public RotationPolicy.KeyDirectory getCurrent()
RotationPolicyRotationPolicy.KeyDirectory を返します。RotationPolicy の getCurrent RotationPolicy.KeyDirectoryprotected DelegatingSessionFactory<?> getFactory()
protected ListSE<RotationPolicy.KeyDirectory> getKeyDirectories()
protected boolean isFair()
protected IteratorSE<RotationPolicy.KeyDirectory> getIterator()
protected boolean isInitialized()
protected void configureSource(MessageSource<?> source)
protected void onRotation(MessageSource<?> source)
MessageSource の状態を更新します。デフォルトの実装は、リモートディレクトリを必要とする既知の MessageSource 実装、具体的には AbstractRemoteFileStreamingMessageSource および AbstractInboundFileSynchronizingMessageSource のインスタンス用に更新し、それ以外は何もしません。サブクラスは、他の MessageSource 型をサポートするために、このメソッドをオーバーライドできます。source - MessageSource。