org.orekit.gnss.metric.ntrip

Class StreamMonitor

java.lang.Object

org.orekit.gnss.metric.parser.AbstractEncodedMessage

org.orekit.gnss.metric.ntrip.StreamMonitor

All Implemented Interfaces:

Runnable, EncodedMessage

public class StreamMonitor
extends AbstractEncodedMessage
implements Runnable

从一个挂载点检索流数据的监视器。

Since:

11.0

Author:

Luc Maisonobe

Constructor Summary

Constructors

Constructor and Description
StreamMonitor(NtripClient client, String mountPoint, Type type, boolean requiresNMEA, boolean ignoreUnknownMessageTypes, double reconnectDelay, double reconnectDelayFactor, int maxRetries) 构建一个用于从挂载点流数据的监视器。

Method Summary

Modifier and Type	Method and Description
void	addObserver(int typeCode, MessageObserver observer) 为编码消息添加一个观察者。
protected int	fetchByte() 从消息中获取下一个字节。
OrekitException	getException() 检索在监视过程中捕获的异常。
void	run()
void	stopMonitoring() 停止监视。

Methods inherited from class org.orekit.gnss.metric.parser.AbstractEncodedMessage

extractBits, start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamMonitor

public StreamMonitor(NtripClient client,
                     String mountPoint,
                     Type type,
                     boolean requiresNMEA,
                     boolean ignoreUnknownMessageTypes,
                     double reconnectDelay,
                     double reconnectDelayFactor,
                     int maxRetries)

构建一个用于从挂载点流数据的监视器。

参数：

client - 相关的NTRIP客户端

mountPoint - 提供流的挂载点

type - 挂载点的消息类型

requiresNMEA - 如果为true，则挂载点在请求中需要一个NMEA GGA句

ignoreUnknownMessageTypes - 如果为true，则未知的消息类型将被静默忽略

reconnectDelay - 连接关闭后重新连接之前的延迟

reconnectDelayFactor - 每次尝试后重新连接延迟乘以的因子

maxRetries - 在没有读取任何数据的情况下重新连接的最大尝试次数

Method Detail

addObserver

public void addObserver(int typeCode,
                        MessageObserver observer)

为编码消息添加一个观察者。

如果已经从流中检索到指定类型的消息，则作为添加的副作用，观察者将立即收到最后一条消息的通知。

参数：

typeCode - 消息类型的代码（如果设置为0，则无论消息类型如何都会触发通知）

observer - 此消息类型的观察者

stopMonitoring

public void stopMonitoring()

停止监视。

getException

public OrekitException getException()

检索在监视过程中捕获的异常。

返回：

捕获的异常

run

public void run()

由以下指定：

run 在接口 Runnable

fetchByte

protected int fetchByte()

从消息中获取下一个字节。

由以下指定：

fetchByte 在类 AbstractEncodedMessage

返回：

从消息中获取下一个字节，作为原始整数，如果已到达数据末尾，则返回-1