subprojects/s4-comm/src/main/java/org/apache/s4/comm/topology/RemoteStreamsManagerImpl.java

package org.apache.s4.comm.topology;

import java.util.Set;

public class RemoteStreamsManagerImpl implements RemoteStreamsManager {

    @Override
    public Set<StreamConsumer> getConsumers(String streamName) {
        return null;
    }

    @Override
    public void addOutputStream(String appId, String clusterName, String streamName) {

    }

    @Override
    public void addInputStream(int appId, String clusterName, String streamName) {

    }

}