Examples of addFaultyMember()

Examples of org.apache.catalina.tribes.ChannelException.addFaultyMember()

45
46
47
48
49
50
51
52
53
54
55
        for ( int i=0; i<senders.length; i++ ) {
            try {
                senders[i].sendMessage(data,(msg.getOptions()&Channel.SEND_OPTIONS_USE_ACK)==Channel.SEND_OPTIONS_USE_ACK);
            } catch (Exception x) {
                if (cx == null) cx = new ChannelException(x);
                cx.addFaultyMember(destination[i],x);
            }
        }
        if (cx!=null ) throw cx;
    }
View Full Code Here

Examples of org.apache.catalina.tribes.ChannelException.addFaultyMember()

70
71
72
73
74
75
76
77
78
79
80
                result[i] = sender;
                if (!result[i].isConnected() ) result[i].connect();
                result[i].keepalive();
            }catch (Exception x ) {
                if ( cx== null ) cx = new ChannelException(x);
                cx.addFaultyMember(destination[i],x);
            }
        }
        if ( cx!=null ) throw cx;
        else return result;
    }
View Full Code Here

Examples of org.apache.catalina.tribes.ChannelException.addFaultyMember()

94
95
96
97
98
99
100
101
102
103
104
            try {
                BioSender sender = bioSenders.get(mbr);
                sender.disconnect();
            }catch ( Exception e ) {
                if ( x == null ) x = new ChannelException(e);
                x.addFaultyMember(mbr,e);
            }
            bioSenders.remove(mbr);
        }
        if ( x != null ) throw x;
    }
View Full Code Here

Examples of org.apache.catalina.tribes.ChannelException.addFaultyMember()

83
84
85
86
87
88
89
90
91
92
93
                    if ( cx == null ) {
                        if ( x instanceof ChannelException ) cx = (ChannelException)x;
                        else cx = new ChannelException("Parallel NIO send failed.", x);
                    } else {
                        if (x instanceof ChannelException) {
                            cx.addFaultyMember(((ChannelException) x).getFaultyMembers());
                        }
                    }
                    //count down the remaining on an error
                    if (faulty < cx.getFaultyMembers().length) {
                        remaining -= (cx.getFaultyMembers().length - faulty);
View Full Code Here

Examples of org.apache.catalina.tribes.ChannelException.addFaultyMember()

176
177
178
179
180
181
182
183
184
185
186
                if ( !isConnected() ) {
                    log.warn("Not retrying send for:" + sender.getDestination().getName() +
                            "; Sender is disconnected.");
                    ChannelException cx = new ChannelException(
                            "Send failed, and sender is disconnected. Not retrying.", x);
                    cx.addFaultyMember(sender.getDestination(),x);
                    throw cx;
                }

                byte[] data = sender.getMessage();
                if ( retry ) {
View Full Code Here

Examples of org.apache.catalina.tribes.ChannelException.addFaultyMember()

194
195
196
197
198
199
200
201
202
203
204
                    }
                } else {
                    ChannelException cx = new ChannelException(
                            "Send failed, attempt:" + sender.getAttempt() + " max:" + maxAttempts,
                            x);
                    cx.addFaultyMember(sender.getDestination(),x);
                    throw cx;
                }//end if
            }
        }
        return completed;
View Full Code Here

Examples of org.apache.catalina.tribes.ChannelException.addFaultyMember()

210
211
212
213
214
215
216
217
218
219
220
        for (int i=0; i<senders.length; i++ ) {
            try {
                senders[i].connect();
            }catch ( IOException io ) {
                if ( x==null ) x = new ChannelException(io);
                x.addFaultyMember(senders[i].getDestination(),io);
            }
        }
        if ( x != null ) throw x;
    }
View Full Code Here

Examples of org.apache.catalina.tribes.ChannelException.addFaultyMember()

223
224
225
226
227
228
229
230
231
232
233
        for (int i=0; i<senders.length; i++ ) {
            try {
                senders[i].setMessage(data);
            }catch ( IOException io ) {
                if ( x==null ) x = new ChannelException(io);
                x.addFaultyMember(senders[i].getDestination(),io);
            }
        }
        if ( x != null ) throw x;
    }
View Full Code Here

Examples of org.apache.catalina.tribes.ChannelException.addFaultyMember()

249
250
251
252
253
254
255
256
257
258
259
                sender.setSelector(selector);
                sender.setUdpBased(isUdpBased());
                result[i] = sender;
            }catch ( UnknownHostException x ) {
                if (cx == null) cx = new ChannelException("Unable to setup NioSender.", x);
                cx.addFaultyMember(destination[i], x);
            }
        }
        if ( cx != null ) throw cx;
        else return result;
    }
View Full Code Here

Examples of org.apache.catalina.tribes.ChannelException.addFaultyMember()

273
274
275
276
277
278
279
280
281
282
283
            try {
                NioSender sender = nioSenders.get(mbr);
                sender.disconnect();
            }catch ( Exception e ) {
                if ( x == null ) x = new ChannelException(e);
                x.addFaultyMember(mbr,e);
            }
            nioSenders.remove(mbr);
        }
        if ( x != null ) throw x;
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.