删除DataSourceMessageListener类,功能已移到RefreshDataSourceMessageImpl类

fs-danaus

2022-12-22 2101288d9ac96f3029c75ec71a810da5f5029819

删除DataSourceMessageListener类,功能已移到RefreshDataSourceMessageImpl类

 src/com/yc/im/util/RedisSocket.java

@@ -9,7 +9,6 @@
public class RedisSocket {
    public static  RedisUtil redisUtil= (RedisUtil) FactoryBean.getBean("redisUtil");//存取
    protected static  String CHANNEL_KEFU="Onbus_WSMQ";//客服消息频道名称
    public static  String CHANNEL_DATASOURCE = "Onbus_DataSource" ;  //数据源频道名称
    public static  String REDISTKEY_CLIENTLISTS="WS_clientlists";//用户集合的key
    protected static  String REDISTKEY_GROUPLISTS="WS_grouplists";//群组集合的key
    protected static  String REDISTKEY_ONLINENUMBER="WS_onlines";//在线人数key

 src/com/yc/multiData/DataSourceMessageListener.java

File was deleted

 src/spring-redis.xml

@@ -79,9 +79,6 @@
    <bean id="listenerForWebSocket" class="com.yc.im.api.messagelistener.WebSocketMessageListener">
        <property name="redisTemplate" ref="redisTemplate"/>
    </bean>
    <bean id="listenerForDataSource" class="com.yc.multiData.DataSourceMessageListener">
        <property name="redisTemplate" ref="redisTemplate"/>
    </bean>
    <bean id="listenerForImageCache" class="com.yc.sdk.shopping.filter.ClearImageCacheMessageListener">
        <property name="redisTemplate" ref="redisTemplate"/>
    </bean>
@@ -108,11 +105,9 @@
    <redis:listener-container >
        <!-- the method attribute can be skipped as the default method name is "onMessage" -->
        <redis:listener  ref="listenerForWebSocket" serializer="jdkSerializer" topic="Onbus_WSMQ" />
        <redis:listener  ref="listenerForDataSource" serializer="jdkSerializer" topic="Onbus_DataSource" />
        <redis:listener  ref="listenerForImageCache" serializer="jdkSerializer" topic="Onbus_ClearImageCache" />
        <redis:listener  ref="listenerForMessages" serializer="jdkSerializer" topic="Onbus_Messages" />
        <redis:listener  ref="listenerForQrCodeSession" serializer="jdkSerializer" topic="Onbus_Qrcode" />
<!--        <redis:listener  ref="listenerForQrCodeInvalid" serializer="jdkSerializer" topic="__keyevent@*__:expired"/>-->
        <redis:listener  ref="listenerForMaintainPay" serializer="jdkSerializer" topic="Onbus_Maintain"/>
    </redis:listener-container>