org.apache.s4.comm.topology
Class StreamConsumer

java.lang.Object
  extended by org.apache.s4.comm.topology.StreamConsumer

public class StreamConsumer
extends java.lang.Object

A subscriber to a published stream. Identified through its cluster name (for dispatching to the remote cluster) and application ID (for dispatching within a node (NOTE: this parameter is ignored)).


Constructor Summary
StreamConsumer(int appId, java.lang.String clusterName)
           
 
Method Summary
 boolean equals(java.lang.Object obj)
           
 int getAppId()
           
 java.lang.String getClusterName()
           
 int hashCode()
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

StreamConsumer

public StreamConsumer(int appId,
                      java.lang.String clusterName)
Method Detail

getAppId

public int getAppId()

getClusterName

public java.lang.String getClusterName()

hashCode

public int hashCode()
Overrides:
hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)
Overrides:
equals in class java.lang.Object