Ignore:
Timestamp:
11/28/19 14:40:48 (5 years ago)
Author:
bart
Message:

Release 1.1.0

Location:
simplerunner/src/main/java/geniusweb/simplerunner
Files:
3 edited

Legend:

Unmodified
Added
Removed
  • simplerunner/src/main/java/geniusweb/simplerunner/BasicConnection.java

    r1 r9  
    44import java.net.URI;
    55
    6 import geniusweb.connection.Connection;
     6import geniusweb.connection.ConnectionEnd;
    77import geniusweb.references.Reference;
    88import tudelft.utilities.listener.DefaultListenable;
     
    1717 */
    1818public class BasicConnection<IN, OUT> extends DefaultListenable<IN>
    19                 implements Connection<IN, OUT> {
     19                implements ConnectionEnd<IN, OUT> {
    2020        private final Reference reference;
    2121        private final URI uri;
  • simplerunner/src/main/java/geniusweb/simplerunner/ClassPathConnectionFactory.java

    r1 r9  
    1313import geniusweb.party.Party;
    1414import geniusweb.party.inform.Inform;
    15 import geniusweb.protocol.partyconnection.ConnectionWithParty;
    16 import geniusweb.protocol.partyconnection.ConnectionWithPartyFactory;
     15import geniusweb.protocol.partyconnection.ProtocolToPartyConn;
     16import geniusweb.protocol.partyconnection.ProtocolToPartyConnFactory;
    1717import geniusweb.references.Reference;
    1818import tudelft.utilities.repository.NoResourcesNowException;
     
    2525 *
    2626 */
    27 public class ClassPathConnectionFactory implements ConnectionWithPartyFactory {
     27public class ClassPathConnectionFactory implements ProtocolToPartyConnFactory {
    2828        private static final String SCHEME = "classpath";
    2929        private static int serialcounter = 1;
     
    3131
    3232        @Override
    33         public ConnectionWithParty connect(Reference reference) {
     33        public ProtocolToPartyConn connect(Reference reference) {
    3434                // set up the whole other party including the connection to it.
    3535                String classpath = getClassPath(reference.getURI());
     
    4242                                uri("classpath:" + reference.getURI().getSchemeSpecificPart()
    4343                                                + "." + (serialcounter++)));
    44                 party2protocol.init(action -> protocol2party.notifyChange(action));
    45                 protocol2party.init(info -> party2protocol.notifyChange(info));
     44                party2protocol.init(action -> protocol2party.notifyListeners(action));
     45                protocol2party.init(info -> party2protocol.notifyListeners(info));
    4646
    4747                party.connect(party2protocol);
     
    102102
    103103        @Override
    104         public List<ConnectionWithParty> connect(List<Reference> references)
     104        public List<ProtocolToPartyConn> connect(List<Reference> references)
    105105                        throws IOException, NoResourcesNowException {
    106                 List<ConnectionWithParty> connections = new LinkedList<>();
     106                List<ProtocolToPartyConn> connections = new LinkedList<>();
    107107                for (Reference partyref : references) {
    108108                        connections.add(connect(partyref));
     
    114114
    115115class BasicConnectionWithParty extends BasicConnection<Action, Inform>
    116                 implements ConnectionWithParty {
     116                implements ProtocolToPartyConn {
    117117
    118118        private PartyId id;
  • simplerunner/src/main/java/geniusweb/simplerunner/NegoRunner.java

    r1 r9  
    1313import geniusweb.protocol.NegoProtocol;
    1414import geniusweb.protocol.NegoSettings;
    15 import geniusweb.protocol.partyconnection.ConnectionWithPartyFactory;
     15import geniusweb.protocol.partyconnection.ProtocolToPartyConnFactory;
    1616import geniusweb.protocol.session.SessionSettings;
    1717import tudelft.utilities.logging.ReportToLogger;
     
    2727        private final NegoSettings settings;
    2828        private final NegoProtocol protocol;
    29         private final ConnectionWithPartyFactory connectionfactory;
     29        private final ProtocolToPartyConnFactory connectionfactory;
    3030        private final Reporter log;
    3131        private final static ObjectMapper jackson = new ObjectMapper();
    3232
    3333        public NegoRunner(NegoSettings settings,
    34                         ConnectionWithPartyFactory connectionfactory, Reporter logger) {
     34                        ProtocolToPartyConnFactory connectionfactory, Reporter logger) {
    3535                if (settings == null || connectionfactory == null) {
    3636                        throw new NullPointerException("Arguments must be not null");
Note: See TracChangeset for help on using the changeset viewer.