Changeset 7 for src/main/java/geniusweb/runserver

Timestamp:

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

Author:

bart

Message:

Release 1.1.0

Location:

src/main/java/geniusweb/runserver

Files:

• PartyConnectionFactory.java (modified) (6 diffs)
• RunningNegotiationsRepo.java (modified) (3 diffs)
• WebSocketProtToPartyConn.java (added)

src/main/java/geniusweb/runserver/PartyConnectionFactory.java

@@ -12 +12 @@
 import java.util.logging.Level;
 
-import geniusweb.protocol.partyconnection.ConnectionWithParty;
-import geniusweb.protocol.partyconnection.ConnectionWithPartyFactory;
+import geniusweb.protocol.partyconnection.ProtocolToPartyConn;
+import geniusweb.protocol.partyconnection.ProtocolToPartyConnFactory;
 import geniusweb.references.PartyRef;
 import geniusweb.references.Reference;
@@ -23 +23 @@
  * following the partiesserver protocols.
  */
-class PartyConnectionFactory implements ConnectionWithPartyFactory {
+class PartyConnectionFactory implements ProtocolToPartyConnFactory {
         private final Reporter log;
 
@@ -35 +35 @@
 
         @Override
-        public PartyConnection connect(Reference reference)
+        public WebSocketProtToPartyConn connect(Reference reference)
                         throws IOException, NoResourcesNowException {
                 try {
-                        return new PartyConnection(reference, log).init();
+                        return new WebSocketProtToPartyConn(reference, log).init();
                 } catch (IOException e) {
                         Date date = getWaitingTime(e);
@@ -60 +60 @@
 
         @Override
-        public List<ConnectionWithParty> connect(List<Reference> references)
+        public List<ProtocolToPartyConn> connect(List<Reference> references)
                         throws IOException, NoResourcesNowException {
                 /*
@@ -70 +70 @@
                  */
                 log.log(Level.INFO, "attempting to connect " + references);
-                List<ConnectionWithParty> connections = new LinkedList<>();
+                List<ProtocolToPartyConn> connections = new LinkedList<>();
                 try {
                         for (Reference partyref : references) {
-                                ConnectionWithParty conn = null;
+                                ProtocolToPartyConn conn = null;
                                 while (conn == null) {
                                         try {
@@ -87 +87 @@
                 } catch (IOException | NoResourcesNowException e) {
                         // free all already created connections
-                        for (ConnectionWithParty conn : connections) {
+                        for (ProtocolToPartyConn conn : connections) {
                                 conn.close();
                         }

src/main/java/geniusweb/runserver/RunningNegotiationsRepo.java

@@ -55 +55 @@
                 }
                 negotiations.put(entity.getID(), entity);
-                notifyChange(entity.getID());
+                notifyListeners(entity.getID());
                 log.log(Level.FINEST, "started " + entity.getID());
         }
@@ -62 +62 @@
         public void remove(String id) {
                 negotiations.remove(id);
-                notifyChange(id);
+                notifyListeners(id);
                 log.log(Level.FINEST, "stopped negotiation " + id);
         }
@@ -73 +73 @@
                 }
                 negotiations.put(entity.getID(), entity);
-                notifyChange(entity.getID());
+                notifyListeners(entity.getID());
                 log.log(Level.FINEST, "replaced " + entity.getID());