- public void addVector( String fqtn, String source, String target ) {
- logger.info( "addVector: fqtn=" + fqtn + " source=" + source + " target=" + target );
- if ( ! sourceCluster.equals( source ) ){
- errorLogger.error( DmaapbcLogMessageEnum.MM_CIRCULAR_REF, source, sourceCluster );
- }
- vectors.add(new ReplicationVector( fqtn, source, target ));
- }
-
- public void delVector( String fqtn, String source, String target ) {
- vectors.remove(new ReplicationVector( fqtn, source, target));
- }
-
-
-
- public String toJSON() {
- StringBuilder str = new StringBuilder( "{ \"source\": " + sourceCluster + ",\"topics\": [" );
- int numTargets = 0;
- for (ReplicationVector rv: vectors) {
- if ( numTargets > 0 ) {
- str.append( ",");
- }
- str.append( " \"target\": " + rv.getTargetCluster() + ", \"topic\": " + rv.getFqtn());
- numTargets++;
- }
- str.append( "] }" );
-
- return str.toString();
- }
-
-