View | Details | Raw Unified | Return to bug 48398
Collapse All | Expand All

(-)java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java (-2 / +2 lines)
Lines 61-68 Link Here
61
    private boolean forwardExpired = true;
61
    private boolean forwardExpired = true;
62
    private int maxQueue = Integer.MAX_VALUE;
62
    private int maxQueue = Integer.MAX_VALUE;
63
    
63
    
64
    ReentrantReadWriteLock inLock = new ReentrantReadWriteLock(true);
64
    final ReentrantReadWriteLock inLock = new ReentrantReadWriteLock(true);
65
    ReentrantReadWriteLock outLock= new ReentrantReadWriteLock(true);
65
    final ReentrantReadWriteLock outLock= new ReentrantReadWriteLock(true);
66
66
67
    public void sendMessage(Member[] destination, ChannelMessage msg, InterceptorPayload payload) throws ChannelException {
67
    public void sendMessage(Member[] destination, ChannelMessage msg, InterceptorPayload payload) throws ChannelException {
68
        if ( !okToProcess(msg.getOptions()) ) {
68
        if ( !okToProcess(msg.getOptions()) ) {

Return to bug 48398