Changeset 8 for src/main/java/geniusweb/partiesserver/repository

Timestamp:

11/28/19 14:41:10 (5 years ago)

Author:

bart

Message:

Release 1.1.0

Location:

src/main/java/geniusweb/partiesserver/repository

Files:

• AvailablePartiesRepo.java (modified) (3 diffs)
• RunningPartiesRepo.java (modified) (3 diffs)
• RunningParty.java (modified) (6 diffs)

src/main/java/geniusweb/partiesserver/repository/AvailablePartiesRepo.java

@@ -12 +12 @@
  * Stores all currently available parties that can be run.
  */
-public class AvailablePartiesRepo extends DefaultListenable<String> implements Repository<String, AvailableParty> {
+public class AvailablePartiesRepo extends DefaultListenable<String>
+                implements Repository<String, AvailableParty> {
         private static final AvailablePartiesRepo instance = new AvailablePartiesRepo();
 
@@ -37 +38 @@
         public void put(AvailableParty entity) {
                 availableParties.put(entity.getID(), entity);
-                notifyChange(entity.getID());
+                notifyListeners(entity.getID());
         }
 
@@ -43 +44 @@
         public void remove(String id) {
                 availableParties.remove(id);
-                notifyChange(id);
+                notifyListeners(id);
         }
 

src/main/java/geniusweb/partiesserver/repository/RunningPartiesRepo.java

@@ -74 +74 @@
                         runningParties.put(id, newParty);
                 }
-                notifyChange(id);
+                notifyListeners(id);
         }
 
@@ -87 +87 @@
                         runningParties.put(id, newParty);
                 }
-                notifyChange(id);
+                notifyListeners(id);
 
         }
@@ -125 +125 @@
                         }
                 }
-                notifyChange(id);
+                notifyListeners(id);
         }
 

src/main/java/geniusweb/partiesserver/repository/RunningParty.java

@@ -9 +9 @@
 import com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility;
 
-import geniusweb.actions.Action;
 import geniusweb.actions.PartyId;
 import geniusweb.connection.DefaultConnection;
 import geniusweb.partiesserver.RunningPartiesUpdater;
+import geniusweb.partiesserver.websocket.PartySocket;
 import geniusweb.party.Party;
 import geniusweb.party.inform.Inform;
@@ -40 +40 @@
          * set when someone contacts our socket. null if not set.
          */
-        private final transient DefaultConnection<Inform, Action> connection;
+        private final transient PartySocket connection;
 
         /**
@@ -58 +58 @@
          */
         protected RunningParty(Party party, PartyId id, String name, Date start,
-                        Date end, DefaultConnection conn) {
+                        Date end, PartySocket conn) {
                 if (party == null || id == null || name == null || start == null
                                 || end == null) {
@@ -101 +101 @@
          * @param name         The name, this should match the filename in the repo
          *                     (without the .jar).
-         * @param maxRunTimeMS the maximum runtime for this party (ms). The {@link RunningPartiesUpdater} 
-         * will keep an eye on the time and handle removal after time is up.
+         * @param maxRunTimeMS the maximum runtime for this party (ms). The
+         *                     {@link RunningPartiesUpdater} will keep an eye on the
+         *                     time and handle removal after time is up.
          * 
          */
@@ -212 +213 @@
          */
         public void inform(Inform info) {
-                connection.notifyChange(info);
+                connection.notifyListeners(info);
         }
 
@@ -223 +224 @@
          * @throws IllegalStateException if the party is already connected.
          */
-        public RunningParty withConnection(
-                        DefaultConnection<Inform, Action> newconn) {
+        public RunningParty withConnection(PartySocket newconn) {
                 if (newconn == null)
                         throw new NullPointerException("newconn must be not null");