Package org.jgroups.demo.tankwar.core

Examples of org.jgroups.demo.tankwar.core.Session

32
33
34
35
36
37
38
39
40
41
42
43
44
45
   
    if(logger.isDebugEnabled()) {
      logger.debug("handle message, " + msg.printHeaders() + " | " + msg.getSrc()  + " | "  + msg.getObject()) ;
    }
       
    Session session = (Session) msg.getObject();
   
    if(session.type().equals(Type.B) ) {
      bloods.get(0).updateBlood(session.bloodView());
    } else if(session.type().equals(Type.E)) {
      explodes.add(new Explode(session.explodeView()));
    }
   
  }
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
    logger.info("Start Running");
   
    while(true) {
     
      try {
        Session session = queue.take();
       
        if(logger.isDebugEnabled()){
          logger.debug("send message " + session + ", queue size =" + queue.size() );
        }
               
View Full Code Here
29
30
31
32
33
34
35
36
37
38
39
40
   
    if(logger.isDebugEnabled()) {
      logger.debug("handle message, " + msg.printHeaders() + " | " + msg.getSrc()  + " | "  + msg.getObject()) ;
    }
   
    Session session = (Session) msg.getObject();
    TankView view = session.tankView();
    if(view.isLive()){
      Tank tank = tankMap.get(view.getId());
      if(null == tank) {
        tankMap.put(view.getId(), new Tank(view));
      } else {
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
    logger.info("Start Running");
       
    while(true) {
     
      try {
        Session session = queue.take();
       
        if(logger.isDebugEnabled()){
          logger.debug("send message " + session + ", queue size =" + queue.size() + ", tankMap size = " + tankMap.size());
        }
       
View Full Code Here
28
29
30
31
32
33
34
35
36
37
38
39
   
    if(logger.isDebugEnabled()) {
      logger.debug("handle message, " + msg.printHeaders() + " | " + msg.getSrc()  + " | "  + msg.getObject()) ;
    }
   
    Session session = (Session) msg.getObject();
    MissileView view = session.missileView();
    if(view.isLive()) {
      Missile missile = missileMap.get(view.getId());
      if(null == missile) {
        missileMap.put(view.getId(), new Missile(view));
      } else {
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
    logger.info("Start Running");
   
    while(true) {
     
      try {
        Session session = queue.take();
       
        if(logger.isDebugEnabled()){
          logger.debug("send message " + session + ", queue size =" + queue.size() + ", missileMap size = " + missileMap.size());
        }
       
View Full Code Here
78
79
80
81
82
83
84
85
86
87
    return getTankMap().size();
  }
 
  public void replicateTank(TankView view) {
    try {
      tankQueue.put(new Session(view, Type.T));
    } catch (InterruptedException e) {
      throw new TankWarCommunicationException("replicate Tank Error", e);
    }
  }
View Full Code Here
86
87
88
89
90
91
92
93
94
95
    }
  }

  public void replicateBlood(BloodView view) {
    try {
      otherQueue.put(new Session(view, Type.B));
    } catch (InterruptedException e) {
      throw new TankWarCommunicationException("replicate Blood Error", e);
    }
  }
View Full Code Here
94
95
96
97
98
99
100
101
102
103
    }
  }

  public void replicateExplode(ExplodeView view) {
    try {
      otherQueue.put(new Session(view, Type.E));
    } catch (InterruptedException e) {
      throw new TankWarCommunicationException("replicate Explode Error", e);
    }
  }
View Full Code Here
102
103
104
105
106
107
108
109
110
111
    }
  }

  public void replicateMissile(MissileView view) {
    try {
      missileQueue.put(new Session(view, Type.M));
    } catch (InterruptedException e) {
      throw new TankWarCommunicationException("replicate Missile Error", e);
    }
  }
View Full Code Here
TOP

Related Classes of org.jgroups.demo.tankwar.core.Session

  • org.jgroups.demo.tankwar.jgroups.Communication
  • org.jgroups.demo.tankwar.jgroups.threads.AsychMissileThread
  • org.jgroups.demo.tankwar.jgroups.threads.AsychOtherThread
  • org.jgroups.demo.tankwar.jgroups.threads.AsychTankThread
    • Copyright © 2018 www.massapicom. 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.