blob: 957318d68dbfd4726368dc210fc60363380706b3 [file] [log] [blame]
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)
{
}
}