Java 类org.apache.catalina.tribes.transport.AbstractRxTask 实例源码

@Override
public AbstractRxTask createRxTask() {
    NioReplicationTask thread = new NioReplicationTask(this,this);
    thread.setUseBufferPool(this.getUseBufferPool());
    thread.setRxBufSize(getRxBufSize());
    thread.setOptions(getWorkerThreadOptions());
    return thread;
}

@Override
public AbstractRxTask createRxTask() {
    NioReplicationTask thread = new NioReplicationTask(this,this);
    thread.setUseBufferPool(this.getUseBufferPool());
    thread.setRxBufSize(getRxBufSize());
    thread.setOptions(getWorkerThreadOptions());
    return thread;
}

@Override
public AbstractRxTask createRxTask() {
    NioReplicationTask thread = new NioReplicationTask(this, this);
    thread.setUseBufferPool(this.getUseBufferPool());
    thread.setRxBufSize(getRxBufSize());
    thread.setOptions(getWorkerThreadOptions());
    return thread;
}

@Override
public AbstractRxTask createRxTask() {
    NioReplicationTask thread = new NioReplicationTask(this,this);
    thread.setUseBufferPool(this.getUseBufferPool());
    thread.setRxBufSize(getRxBufSize());
    thread.setOptions(getWorkerThreadOptions());
    return thread;
}

@Override
public AbstractRxTask createRxTask() {
    NioReplicationTask thread = new NioReplicationTask(this,this);
    thread.setUseBufferPool(this.getUseBufferPool());
    thread.setRxBufSize(getRxBufSize());
    thread.setOptions(getWorkerThreadOptions());
    return thread;
}

@Override
public AbstractRxTask createRxTask() {
    NioReplicationTask thread = new NioReplicationTask(this,this);
    thread.setUseBufferPool(this.getUseBufferPool());
    thread.setRxBufSize(getRxBufSize());
    thread.setOptions(getWorkerThreadOptions());
    return thread;
}

@Override
public AbstractRxTask createRxTask() {
    NioReplicationTask thread = new NioReplicationTask(this,this);
    thread.setUseBufferPool(this.getUseBufferPool());
    thread.setRxBufSize(getRxBufSize());
    thread.setOptions(getWorkerThreadOptions());
    return thread;
}

@Override
public AbstractRxTask createRxTask() {
    return getReplicationThread();
}

@Override
public AbstractRxTask createRxTask() {
    return getReplicationThread();
}

@Override
public AbstractRxTask createRxTask() {
    return getReplicationThread();
}

@Override
public AbstractRxTask createRxTask() {
    return getReplicationThread();
}

@Override
public AbstractRxTask createRxTask() {
    return getReplicationThread();
}

@Override
public AbstractRxTask createRxTask() {
    return getReplicationThread();
}

@Override
public AbstractRxTask createRxTask() {
    return getReplicationThread();
}