public class RedisStoreMessageSource extends AbstractMessageSource<RedisStore>
collectionType
属性によって異なります。デフォルトは LIST です。このアダプターは、RedisCollectionFactoryBean.CollectionType
によって識別される 5 種類のコレクションをサポートします IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターと説明 |
---|
RedisStoreMessageSource(RedisConnectionFactory connectionFactory, Expression keyExpression) 使用するコレクションの「キー」名に解決する必要がある、提供された RedisConnectionFactory および SpEL 式を使用してインスタンスを作成します。 |
RedisStoreMessageSource(RedisTemplate<StringSE,?> redisTemplate, Expression keyExpression) 使用するコレクションの「キー」名に解決する必要がある、提供された RedisTemplate および SpEL 式を使用してインスタンスを作成します。 |
修飾子と型 | メソッドと説明 |
---|---|
void | afterCommit(ObjectSE object) |
void | afterRollback(ObjectSE object) |
protected RedisStore | doReceive() keyExpression で識別される RedisStore へのビューを持つメッセージを返します |
StringSE | getComponentType() |
RedisStore | getResource() |
protected void | onInit() |
void | setCollectionType(RedisCollectionFactoryBean.CollectionType collectionType) |
buildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionService
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
getIntegrationPatternType
getThisAs
public RedisStoreMessageSource(RedisTemplate<StringSE,?> redisTemplate, Expression keyExpression)
RedisTemplate
と SpEL 式を使用してインスタンスを作成します。このインスタンスは、使用するコレクションの「キー」名に解決されます。RedisTemplate
は完全に初期化され、使用できる状態であると想定しています。"keyExpression" は、AbstractMessageSource.receive()
メソッドを呼び出すたびに評価されます。redisTemplate
- Redis テンプレート。keyExpression
- キー式。public RedisStoreMessageSource(RedisConnectionFactory connectionFactory, Expression keyExpression)
RedisConnectionFactory
と SpEL 式を使用してインスタンスを作成します。このインスタンスは、使用するコレクションの「キー」名に解決されます。すべての直列化に StringRedisSerializer
を使用する StringRedisTemplate
のインスタンスを作成し、初期化します。"keyExpression" は、AbstractMessageSource.receive()
メソッドを呼び出すたびに評価されます。connectionFactory
- 接続ファクトリ。keyExpression
- キー式。public void setCollectionType(RedisCollectionFactoryBean.CollectionType collectionType)
protected void onInit()
AbstractExpressionEvaluator
の onInit
protected RedisStore doReceive()
keyExpression
で識別される RedisStore
へのビューを持つメッセージを返します AbstractMessageSource<RedisStore>
の doReceive
public StringSE getComponentType()
public RedisStore getResource()
public void afterCommit(ObjectSE object)
public void afterRollback(ObjectSE object)