List of addPeer() Examples

Examples of addPeer()

com.addthis.meshy.service.host.HostSource.addPeer()
com.sun.enterprise.config.serverbeans.Peers.addPeer()
cu.ftpd.user.userbases.changetracking.AsynchronousMessageQueueChangeTracker.addPeer()
org.apache.hadoop.hbase.client.replication.ReplicationAdmin.addPeer()
Add a new peer cluster to replicate to. @param id a short that identifies the cluster @param clusterKey the concatenation of the slave cluster'shbase.zookeeper.quorum:hbase.zookeeper.property.clientPort:zookeeper.znode.parent @throws IllegalStateException if there's already one slave sincemulti-slave isn't supported yet.
org.cipango.diameter.node.Node.addPeer()
org.gudy.azureus2.core3.peer.PEPeerManager.addPeer()
org.gudy.azureus2.plugins.peers.PeerManager.addPeer()

Examples of com.addthis.meshy.service.host.HostSource.addPeer()

                        }
                        source.waitComplete();
                    } else if (cmd.equals("peer")) {
                        HostSource hostSource = new HostSource(more);
                        for (int i = 4; i < args.length; i++) {
                            hostSource.addPeer(args[i]);
                        }
                        hostSource.sendRequest();
                        hostSource.waitComplete();
                        for (HostNode node : hostSource.getHostList()) {
                            System.out.println(node.uuid + " \t " + node.address);

View Full Code Here

Examples of com.sun.enterprise.config.serverbeans.Peers.addPeer()

            newPeer.setHost(host);
            newPeer.setPort(port);
            newPeer.setRealm(realm);
            newPeer.setDiameterApplicationRef(diameterAppRef);
            Peers peers = peerConfig.getPeers();
            peers.addPeer(newPeer);
        } catch (ConfigException e) {
            throw new MBeanException(e);
        }
    }

View Full Code Here

Examples of cu.ftpd.user.userbases.changetracking.AsynchronousMessageQueueChangeTracker.addPeer()

                        peerUri = settings.get("/user/authentication/asynchronous/peers/peer[" + i + "]/uri");
                        i++;
                        if (!peerUri.startsWith("failover:")) {
                            peerUri = "failover:" + peerUri;
                        }
                        changeTracker.addPeer(peerName, URI.create(peerUri), changeApplicator);
                        // todo: log each peer we connect to


                    }
                    initializeCuftpdUserbaseActions();
                    break;

View Full Code Here

Examples of org.apache.hadoop.hbase.client.replication.ReplicationAdmin.addPeer()

      int slaveClusterNumber) throws Exception {
    ReplicationAdmin replicationAdmin = null;
    try {
      replicationAdmin = new ReplicationAdmin(
          configurations[masterClusterNumber]);
      replicationAdmin.addPeer(id,
          utilities[slaveClusterNumber].getClusterKey());
    } finally {
      close(replicationAdmin);
    }
  }

View Full Code Here

Examples of org.apache.hadoop.hbase.client.replication.ReplicationAdmin.addPeer()

    HTable htable2 = new HTable(conf2, tableName);
    htable2.setWriteBufferSize(1024);
    HTable htable3 = new HTable(conf3, tableName);
    htable3.setWriteBufferSize(1024);
    
    admin1.addPeer("1", utility2.getClusterKey());


    // put "row" and wait 'til it got around, then delete
    putAndWait(row, famName, htable1, htable2);
    deleteAndWait(row, htable1, htable2);
    // check it wasn't replication to cluster 3

View Full Code Here

Examples of org.apache.hadoop.hbase.client.replication.ReplicationAdmin.addPeer()

    // now roll the region server's logs
    new HBaseAdmin(conf1).rollHLogWriter(master.getRegionServer(0).getServerName().toString());
    // after the log was rolled put a new row
    putAndWait(row3, famName, htable1, htable2);


    admin1.addPeer("2", utility3.getClusterKey());


    // put a row, check it was replicated to all clusters
    putAndWait(row1, famName, htable1, htable2, htable3);
    // delete and verify
    deleteAndWait(row1, htable1, htable2, htable3);

View Full Code Here

Examples of org.apache.hadoop.hbase.client.replication.ReplicationAdmin.addPeer()

    HTable htable3 = new HTable(conf3, tableName);
    htable3.setWriteBufferSize(1024);
    
    admin1.addPeer("1", utility2.getClusterKey());
    admin2.addPeer("1", utility3.getClusterKey());
    admin3.addPeer("1", utility1.getClusterKey());


    // put "row" and wait 'til it got around
    putAndWait(row, famName, htable1, htable3);
    // it should have passed through table2
    check(row,famName,htable2);

View Full Code Here

Examples of org.apache.hadoop.hbase.client.replication.ReplicationAdmin.addPeer()

    HTable htable2 = new HTable(conf2, tableName);
    htable2.setWriteBufferSize(1024);


    // set M-M
    admin1.addPeer("1", utility2.getClusterKey());
    admin2.addPeer("1", utility1.getClusterKey());


    // add rows to both clusters,
    // make sure they are both replication
    putAndWait(row, famName, htable1, htable2);
    putAndWait(row1, famName, htable2, htable1);

View Full Code Here

Examples of org.apache.hadoop.hbase.client.replication.ReplicationAdmin.addPeer()

    HTable htable2 = new HTable(conf2, tableName);
    htable2.setWriteBufferSize(1024);
    HTable htable3 = new HTable(conf3, tableName);
    htable3.setWriteBufferSize(1024);
    
    admin1.addPeer("1", utility2.getClusterKey());


    // put "row" and wait 'til it got around, then delete
    putAndWait(row, famName, htable1, htable2);
    deleteAndWait(row, htable1, htable2);
    // check it wasn't replication to cluster 3

View Full Code Here

Examples of org.apache.hadoop.hbase.client.replication.ReplicationAdmin.addPeer()

    // now roll the region server's logs
    new HBaseAdmin(conf1).rollHLogWriter(master.getRegionServer(0).getServerName().toString());
    // after the log was rolled put a new row
    putAndWait(row3, famName, htable1, htable2);


    admin1.addPeer("2", utility3.getClusterKey());


    // put a row, check it was replicated to all clusters
    putAndWait(row1, famName, htable1, htable2, htable3);
    // delete and verify
    deleteAndWait(row1, htable1, htable2, htable3);

View Full Code Here

0 1 2 3 4 5

TOP

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.