Examples of ElectionMessage

Examples of org.apache.activegroups.command.ElectionMessage

1197
1198
1199
1200
1201
1202
1203
1204
1205
1206
1207
1208
                                processMapUpdate(entryMsg);
                            } else {
                                processEntryMessage(entryMsg, replyTo, id);
                            }
                        } else if (payload instanceof ElectionMessage) {
                            ElectionMessage electionMsg = (ElectionMessage) payload;
                            electionMsg = electionMsg.copy();
                            processElectionMessage(electionMsg, replyTo, id);
                        }
                    } else if (messageType.equals(MESSAGE_TYPE)) {
                        processGroupMessage(memberId, id, replyTo, payload);
                    } else {
View Full Code Here

Examples of org.apache.activegroups.command.ElectionMessage

1711
1712
1713
1714
1715
1716
1717
1718
1719
1720
1721
1722
1723
        boolean doCall = false;
        for (Member member : sorted) {
            if (this.local.equals(member)) {
                doCall = true;
            } else if (doCall) {
                ElectionMessage msg = new ElectionMessage();
                msg.setMember(this.local);
                msg.setType(ElectionMessage.MessageType.ELECTION);
                sendAsyncStateRequest(request, member, msg);
            }
        }
        boolean result = request.isSuccess(getHeartBeatInterval());
        return result;
View Full Code Here

Examples of org.apache.activegroups.command.ElectionMessage

1740
1741
1742
1743
1744
1745
1746
1747
1748
1749
1750
1751
1752
    }

    void broadcastElectionType(ElectionMessage.MessageType type) {
        if (started.get()) {
            try {
                ElectionMessage msg = new ElectionMessage();
                msg.setMember(this.local);
                msg.setType(type);
                ObjectMessage objMsg = this.stateSession
                        .createObjectMessage(msg);
                objMsg.setJMSType(STATE_TYPE);
                this.stateProducer.send(this.stateTopic, objMsg);
            } catch (javax.jms.IllegalStateException e) {
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.