Watch1300.java 1.38 KB
package com.sincere.weigeng;

import com.sincere.weigeng.feign.SmFeign;
import com.sincere.weigeng.feign.XaFeign;
import com.sincere.weigeng.utils.WatchServer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;

/**
 * @author chen
 * @version 1.0
 * @date 2019/12/3 0003 11:42
 */
@Component
public class Watch1300 extends WatchServer implements ApplicationRunner {

    @Autowired
    SmFeign smFeign ;

    @Autowired
    XaFeign xaFeign;

    @Override
    public void run(ApplicationArguments args) throws Exception {
        watchPort(1300);
        Listen1300 listen1300 = new Listen1300(this);
        listen1300.start();
    }

    class Listen1300 extends Thread{

        private Watch1300 watch1300 ;

        public Watch1300 getWatch1300() {
            return watch1300;
        }

        public void setWatch1300(Watch1300 watch1300) {
            this.watch1300 = watch1300;
        }


        public Listen1300(Watch1300 watch1300) {
            this.watch1300 = watch1300;
        }

        @Override
        public synchronized void start() {
            super.start();
        }

        @Override
        public void run() {
            super.run();
            this.watch1300.listen(smFeign,xaFeign);
        }
    }

}