Package org.yamcs.yarch.management
Class StreamControlImpl
- java.lang.Object
-
- javax.management.StandardMBean
-
- org.yamcs.yarch.management.StreamControlImpl
-
- All Implemented Interfaces:
DynamicMBean
,MBeanRegistration
,StreamControl
public class StreamControlImpl extends StandardMBean implements StreamControl
-
-
Constructor Summary
Constructors Constructor Description StreamControlImpl(Stream stream)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getName()
Returns the stream namelong
getNumEmittedTuples()
Returns the number of tuples that have transited through the streamString
getSchema()
Returns the tuple definitionint
getSubscriberCount()
List<String>
getSubscribers()
Returns a list of subscriber.toString()String
getType()
Returns the class name of the stream object-
Methods inherited from class javax.management.StandardMBean
cacheMBeanInfo, getAttribute, getAttributes, getCachedMBeanInfo, getClassName, getConstructors, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getImpact, getImplementation, getImplementationClass, getMBeanInfo, getMBeanInterface, getParameterName, getParameterName, invoke, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementation
-
-
-
-
Constructor Detail
-
StreamControlImpl
public StreamControlImpl(Stream stream) throws NotCompliantMBeanException
- Throws:
NotCompliantMBeanException
-
-
Method Detail
-
getName
public String getName()
Description copied from interface:StreamControl
Returns the stream name- Specified by:
getName
in interfaceStreamControl
-
getNumEmittedTuples
public long getNumEmittedTuples()
Description copied from interface:StreamControl
Returns the number of tuples that have transited through the stream- Specified by:
getNumEmittedTuples
in interfaceStreamControl
-
getType
public String getType()
Description copied from interface:StreamControl
Returns the class name of the stream object- Specified by:
getType
in interfaceStreamControl
-
getSchema
public String getSchema()
Description copied from interface:StreamControl
Returns the tuple definition- Specified by:
getSchema
in interfaceStreamControl
-
getSubscriberCount
public int getSubscriberCount()
- Specified by:
getSubscriberCount
in interfaceStreamControl
-
getSubscribers
public List<String> getSubscribers()
Description copied from interface:StreamControl
Returns a list of subscriber.toString()- Specified by:
getSubscribers
in interfaceStreamControl
-
-