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

(-)transport/nio/ParallelNioSender.java (+5 lines)
Lines 81-87 Link Here
81
                    if ( cx == null ) {
81
                    if ( cx == null ) {
82
                        if ( x instanceof ChannelException ) cx = (ChannelException)x;
82
                        if ( x instanceof ChannelException ) cx = (ChannelException)x;
83
                        else cx = new ChannelException("Parallel NIO send failed.", x);
83
                        else cx = new ChannelException("Parallel NIO send failed.", x);
84
                        if (log.isTraceEnabled()) log.trace("Error sending message", x);
84
                    } else {
85
                    } else {
86
                    	if (log.isTraceEnabled()) log.trace("Error sending message", x);
85
                        if (x instanceof ChannelException) cx.addFaultyMember( ( (ChannelException) x).getFaultyMembers());
87
                        if (x instanceof ChannelException) cx.addFaultyMember( ( (ChannelException) x).getFaultyMembers());
86
                    }
88
                    }
87
                    //count down the remaining on an error
89
                    //count down the remaining on an error
Lines 136-141 Link Here
136
                    SenderState.getSenderState(sender.getDestination()).setReady();
138
                    SenderState.getSenderState(sender.getDestination()).setReady();
137
                }//end if
139
                }//end if
138
            } catch (Exception x) {
140
            } catch (Exception x) {
141
            	if (log.isTraceEnabled()) {
142
            		log.trace("Error while processing send to " + sender.getDestination().getName(), x);
143
            	}
139
                SenderState state = SenderState.getSenderState(sender.getDestination());
144
                SenderState state = SenderState.getSenderState(sender.getDestination());
140
                int attempt = sender.getAttempt()+1;
145
                int attempt = sender.getAttempt()+1;
141
                boolean retry = (sender.getAttempt() <= maxAttempts && maxAttempts>0);
146
                boolean retry = (sender.getAttempt() <= maxAttempts && maxAttempts>0);

Return to bug 50185