1 package org.jgroups.jmx.protocols; 2 3 7 public class TCP_NIO extends TCP implements TCP_NIOMBean { 8 9 org.jgroups.protocols.TCP_NIO my_p; 10 public TCP_NIO() { 11 } 12 13 public TCP_NIO(org.jgroups.stack.Protocol p) { 14 super(p); 15 this.my_p=(org.jgroups.protocols.TCP_NIO)p; 16 } 17 18 public void attachProtocol(org.jgroups.stack.Protocol p) { 19 this.my_p=(org.jgroups.protocols.TCP_NIO)p; 20 } 21 22 public int getReaderThreads() { 23 return my_p.getReaderThreads(); 24 } 25 26 public int getWriterThreads() { 27 return my_p.getWriterThreads(); 28 } 29 30 public int getProcessorThreads() { 31 return my_p.getProcessorThreads(); 32 } 33 34 public int getProcessorMinThreads() { 35 return my_p.getProcessorMinThreads(); 36 } 37 38 public int getProcessorMaxThreads() { 39 return my_p.getProcessorMaxThreads(); 40 } 41 42 public int getProcessorQueueSize() { 43 return my_p.getProcessorQueueSize(); 44 } 45 46 public long getProcessorKeepAliveTime() { 47 return my_p.getProcessorKeepAliveTime(); 48 } 49 50 } 51 | Popular Tags |