sendMessage(Member[], ChannelMessage, InterceptorPayload) | | 0% | | 0% | 8 | 8 | 15 | 15 | 1 | 1 |
sendAsyncData(ChannelMessage, Member[], InterceptorPayload) | | 0% | | 0% | 6 | 6 | 23 | 23 | 1 | 1 |
getPoolSize() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
getActiveCount() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
getTaskCount() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
getCompletedTaskCount() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
addToQueue(ChannelMessage, Member[], InterceptorPayload) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$addToQueue$0(ChannelMessage, Member[], InterceptorPayload) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setOptionFlag(int) | | 58% | | 50% | 1 | 2 | 1 | 4 | 0 | 1 |
addAndGetCurrentSize(long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setMaxQueueSize(long) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setUseDeepClone(boolean) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getCurrentSize() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setKeepAliveTime(long) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setMaxSpareThreads(int) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setMaxThreads(int) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setAlwaysSend(boolean) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
startQueue() | | 97% | | 75% | 1 | 3 | 1 | 8 | 0 | 1 |
MessageDispatchInterceptor() | | 100% | | n/a | 0 | 1 | 0 | 12 | 0 | 1 |
start(int) | | 100% | | 83% | 1 | 4 | 0 | 7 | 0 | 1 |
stop(int) | | 100% | | 66% | 2 | 4 | 0 | 7 | 0 | 1 |
stopQueue() | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
static {...} | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
setAndGetCurrentSize(long) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
getMaxQueueSize() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getUseDeepClone() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getKeepAliveTime() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getMaxSpareThreads() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getMaxThreads() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
isAlwaysSend() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |