realSub = new DatabusSubscription(
sub.getPhysicalSource(), sub.getPhysicalPartition(),
new LogicalSourceId(new LogicalSource(sourceEntry.getId().intValue(), ls.getName()),
sub.getLogicalPartition().getId()));
}
sb.append(realSub.toJsonString());
first = false;
}
sb.append("]");
return sb.toString();
}