@Override
            public void  run(){
                byte[] byteTosend = new byte[1*1024];
                try {
                    for (int k = 0; k < 2/*200000*/; k++) {
                        nioClientMT.publish(null, byteTosend, "#testtag");
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

            }