public class MDPWSStreamingManager
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
ACTION_URI |
protected static java.lang.String |
MCAST_IP |
protected static java.lang.String |
MESSAGE_MODEL_NS |
protected static java.lang.String |
PROTOCOL_PREFIX |
static org.yads.java.types.QName |
STREAM_DESCRIPTIONS |
protected static java.lang.String |
STREAM_TYPE |
protected static java.lang.String |
STREAMING_NAMESPACE |
protected static java.lang.String |
TARGET_NAMESPACE |
| Constructor and Description |
|---|
MDPWSStreamingManager() |
| Modifier and Type | Method and Description |
|---|---|
void |
addNewStreamSenderEndpoint(java.lang.String handle,
org.yads.java.types.UnknownDataContainer udc,
OSCPProvider provider) |
void |
addStreamListeners(OSCPConsumer callback,
java.util.List<java.lang.String> addresses) |
static MDPWSStreamingManager |
getInstance() |
void |
init() |
void |
removeAllStreamListeners() |
void |
removeAllStreamSenders() |
void |
removeStreamListeners(OSCPConsumer callback) |
void |
removeStreamSenders(OSCPProvider provider) |
void |
sendStreamPacket(RealTimeSampleArrayMetricState newState) |
protected static final java.lang.String STREAMING_NAMESPACE
protected static final java.lang.String MESSAGE_MODEL_NS
protected static final java.lang.String TARGET_NAMESPACE
protected static final java.lang.String STREAM_TYPE
public static final java.lang.String ACTION_URI
protected static final java.lang.String MCAST_IP
protected static final java.lang.String PROTOCOL_PREFIX
public static final org.yads.java.types.QName STREAM_DESCRIPTIONS
public static MDPWSStreamingManager getInstance()
public void init()
public void addNewStreamSenderEndpoint(java.lang.String handle,
org.yads.java.types.UnknownDataContainer udc,
OSCPProvider provider)
public void sendStreamPacket(RealTimeSampleArrayMetricState newState)
public void addStreamListeners(OSCPConsumer callback, java.util.List<java.lang.String> addresses)
public void removeStreamListeners(OSCPConsumer callback)
public void removeAllStreamListeners()
public void removeStreamSenders(OSCPProvider provider)
public void removeAllStreamSenders()