java.lang.ObjectSE

org.springframework.integration.redis.store.RedisChannelMessageStore

実装されているすべてのインターフェース:: Aware、BeanClassLoaderAware、BeanNameAware、InitializingBean、BasicMessageGroupStore、ChannelMessageStore

既知の直属サブクラス: RedisChannelPriorityMessageStore

public class RedisChannelMessageStore
extends ObjectSE
implements ChannelMessageStore, BeanNameAware, InitializingBean, BeanClassLoaderAware

リストを使用して QueueChannel をバックアップする特殊な Redis ChannelMessageStore。

キーの一部として使用される setBeanName(String) が必要です。

導入:: 4.0
作成者:: Gary Russell, Artem Bilan

コンストラクターの概要

コンストラクター
コンストラクター	説明
`RedisChannelMessageStore(RedisConnectionFactory connectionFactory)`	メッセージに Java 直列化を使用するメッセージストアを構築します。

メソッドのサマリー

修飾子と型	メソッド	説明
`MessageGroup`	`addMessageToGroup(ObjectSE groupId, Message<?> message)`	グループ ID に関連付けてメッセージを保存します。
`void`	`afterPropertiesSet()`
`protected StringSE`	`getBeanName()`
`int`	`getMessageCountForAllMessageGroups()`
`MessageGroup`	`getMessageGroup(ObjectSE groupId)`	このグループ ID で `BasicMessageGroupStore.addMessageToGroup(Object, Message)` を使用して保存された、現在 MessageStore にあるすべてのメッセージを返します。
`int`	`getMessageGroupCount()`
`protected MessageGroupFactory`	`getMessageGroupFactory()`
`protected RedisTemplate<ObjectSE,Message<?>>`	`getRedisTemplate()`
`int`	`messageGroupSize(ObjectSE groupId)`	この MessageGroup のサイズを返します。
`Message<?>`	`pollMessageFromGroup(ObjectSE groupId)`	この `MessageGroup` からのメッセージのポーリング（実装でサポートされている場合は FIFO スタイル）と同時に、ポーリングされた `Message` も削除します。
`void`	`removeMessageGroup(ObjectSE groupId)`	この ID のメッセージグループを削除します。
`void`	`setBeanClassLoader(ClassLoaderSE classLoader)`
`void`	`setBeanName(StringSE name)`
`void`	`setMessageGroupFactory(MessageGroupFactory messageGroupFactory)`	`MessageGroupFactory` を指定して、必要な場所に `MessageGroup` オブジェクトを作成します。
`void`	`setValueSerializer(RedisSerializer<?> valueSerializer)`	別のシリアライザーを使用します（`Message` のデフォルトは `JdkSerializationRedisSerializer` です。

クラス java.lang.ObjectSE から継承されたメソッド

clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

コンストラクターの詳細
- RedisChannelMessageStore
  public RedisChannelMessageStore(RedisConnectionFactory connectionFactory)
  メッセージに Java 直列化を使用するメッセージストアを構築します。
  パラメーター:
  connectionFactory - redis 接続ファクトリ。
メソッドの詳細
- setBeanClassLoader
  public void setBeanClassLoader(ClassLoaderSE classLoader)
  次で指定:
  インターフェース BeanClassLoaderAware の setBeanClassLoader
- setValueSerializer
  public void setValueSerializer(RedisSerializer<?> valueSerializer)
  別のシリアライザーを使用します（Message のデフォルトは JdkSerializationRedisSerializer です。
  パラメーター:
  valueSerializer - 値シリアライザー。
- setMessageGroupFactory
  public void setMessageGroupFactory(MessageGroupFactory messageGroupFactory)
  MessageGroupFactory を指定して、必要な場所に MessageGroup オブジェクトを作成します。デフォルトは SimpleMessageGroupFactory です。
  パラメーター:
  messageGroupFactory - 使用する MessageGroupFactory。
  導入:
  4.3
- getMessageGroupFactory
  protected MessageGroupFactory getMessageGroupFactory()
- setBeanName
  public void setBeanName(StringSE name)
  次で指定:
  インターフェース BeanNameAware の setBeanName
- getBeanName
  protected StringSE getBeanName()
- getRedisTemplate
  protected RedisTemplate<ObjectSE,Message<?>> getRedisTemplate()
- afterPropertiesSet
  public void afterPropertiesSet()
  次で指定:
  インターフェース InitializingBean の afterPropertiesSet
- messageGroupSize
  @ManagedAttribute public int messageGroupSize(ObjectSE groupId)
  インターフェースからコピーされた説明: BasicMessageGroupStore
  この MessageGroup のサイズを返します。
  次で指定:
  インターフェース BasicMessageGroupStore の messageGroupSize
  パラメーター:
  groupId - グループ識別子。
  戻り値:
  サイズ。
- getMessageGroup
  public MessageGroup getMessageGroup(ObjectSE groupId)
  インターフェースからコピーされた説明: BasicMessageGroupStore
  このグループ ID で BasicMessageGroupStore.addMessageToGroup(Object, Message) を使用して保存された、現在 MessageStore にあるすべてのメッセージを返します。
  次で指定:
  インターフェース BasicMessageGroupStore の getMessageGroup
  パラメーター:
  groupId - グループ識別子。
  戻り値:
  メッセージのグループ。このキーにメッセージが存在しない場合は空です。
- addMessageToGroup
  public MessageGroup addMessageToGroup(ObjectSE groupId, Message<?> message)
  インターフェースからコピーされた説明: BasicMessageGroupStore
  グループ ID に関連付けてメッセージを保存します。これは、メッセージをグループ化するために使用できます。
  次で指定:
  インターフェース BasicMessageGroupStore の addMessageToGroup
  パラメーター:
  groupId - メッセージを保存するグループ ID。
  message - メッセージ。
  戻り値:
  メッセージグループ。
- removeMessageGroup
  public void removeMessageGroup(ObjectSE groupId)
  インターフェースからコピーされた説明: BasicMessageGroupStore
  この ID のメッセージグループを削除します。
  次で指定:
  インターフェース BasicMessageGroupStore の removeMessageGroup
  パラメーター:
  groupId - 削除するグループの ID。
- pollMessageFromGroup
  public Message<?> pollMessageFromGroup(ObjectSE groupId)
  インターフェースからコピーされた説明: BasicMessageGroupStore
  この MessageGroup からのメッセージのポーリング（実装でサポートされている場合は FIFO スタイル）と同時に、ポーリングされた Message も削除します。
  次で指定:
  インターフェース BasicMessageGroupStore の pollMessageFromGroup
  パラメーター:
  groupId - グループ識別子。
  戻り値:
  メッセージ。
- getMessageCountForAllMessageGroups
  @ManagedAttribute public int getMessageCountForAllMessageGroups()
- getMessageGroupCount
  @ManagedAttribute public int getMessageGroupCount()

クラス RedisChannelMessageStore

コンストラクターの概要

メソッドのサマリー

クラス java.lang.ObjectSE から継承されたメソッド

コンストラクターの詳細

メソッドの詳細