クラス RedisChannelMessageStore

メソッドの詳細

• 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()