Examples of org.apache.activegroups.command.ElectionMessage

org.apache.activegroups.command.ElectionMessage
Used to pass information around

                                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

        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

    }


    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

Related Classes of org.apache.activegroups.command.ElectionMessage

org.apache.activegroups.Group

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.