org.jim.common.cluster.redis

Class RedisClusterConfig

java.lang.Object

org.jim.common.cluster.ImClusterConfig

org.jim.common.cluster.redis.RedisClusterConfig

public class RedisClusterConfig
extends ImClusterConfig

Author:

WChao

Field Summary

Fields

Modifier and Type	Field and Description
static String	IM_CLUSTER_TOPIC
static AtomicLong	RECEIVED_TOPIC_COUNT 收到了多少次topic
org.redisson.api.RTopic<ImClusterVo>	rtopic

Fields inherited from class org.jim.common.cluster.ImClusterConfig

groupContext

Method Summary

Modifier and Type	Method and Description
org.redisson.api.RedissonClient	getRedisson()
String	getTopic()
String	getTopicSuffix()
static RedisClusterConfig	newInstance(String topicSuffix, org.redisson.api.RedissonClient redisson, org.tio.core.GroupContext groupContext) J-IM内置的集群是用redis的topic来实现的，所以不同groupContext就要有一个不同的topicSuffix
void	publish(ImClusterVo imClusterVo)
void	publishAsyn(ImClusterVo imClusterVo)
void	send(ImClusterVo imClusterVo)
void	sendAsyn(ImClusterVo imClusterVo)
void	setRedisson(org.redisson.api.RedissonClient redisson)
void	setTopicSuffix(String topicSuffix)

Methods inherited from class org.jim.common.cluster.ImClusterConfig

isCluster4all, isCluster4channelId, isCluster4group, isCluster4ip, isCluster4user, setCluster4all, setCluster4channelId, setCluster4group, setCluster4ip, setCluster4user

Methods inherited from class java.lang.Object

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

Field Detail

IM_CLUSTER_TOPIC

public static final String IM_CLUSTER_TOPIC

See Also:

Constant Field Values

rtopic

public org.redisson.api.RTopic<ImClusterVo> rtopic

RECEIVED_TOPIC_COUNT

public static final AtomicLong RECEIVED_TOPIC_COUNT

收到了多少次topic

Method Detail

newInstance

public static RedisClusterConfig newInstance(String topicSuffix,
                                             org.redisson.api.RedissonClient redisson,
                                             org.tio.core.GroupContext groupContext)

J-IM内置的集群是用redis的topic来实现的，所以不同groupContext就要有一个不同的topicSuffix

Parameters:

topicSuffix - 不同类型的groupContext就要有一个不同的topicSuffix

redisson -

groupContext -

Returns:

getTopicSuffix

public String getTopicSuffix()

setTopicSuffix

public void setTopicSuffix(String topicSuffix)

getTopic

public String getTopic()

publishAsyn

public void publishAsyn(ImClusterVo imClusterVo)

publish

public void publish(ImClusterVo imClusterVo)

getRedisson

public org.redisson.api.RedissonClient getRedisson()

setRedisson

public void setRedisson(org.redisson.api.RedissonClient redisson)

send

public void send(ImClusterVo imClusterVo)

Specified by:

send in class ImClusterConfig

sendAsyn

public void sendAsyn(ImClusterVo imClusterVo)

Specified by:

sendAsyn in class ImClusterConfig