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) | |
{ | |
} | |
} |