| package org.apache.s4.comm.topology; |
| |
| import java.util.Set; |
| |
| /** |
| * <p> |
| * Monitors streams available in the S4 cluster. |
| * </p> |
| * <p> |
| * Maintains a data structure reflecting the currently published streams with their consumers and publishers. |
| * </p> |
| * <p> |
| * Provides methods to publish producers and consumers of streams |
| * </p> |
| * |
| */ |
| |
| public interface RemoteStreams { |
| |
| public abstract Set<StreamConsumer> getConsumers(String streamName); |
| |
| public abstract void addOutputStream(String appId, String clusterName, String streamName); |
| |
| /** |
| * Publishes interest in a stream from an application. |
| * |
| * @param appId |
| * @param clusterName |
| * @param streamName |
| */ |
| public abstract void addInputStream(int appId, String clusterName, String streamName); |
| |
| } |