多个短期TPL数据流与单个长期运行数据流的对比

我正在使用TPL数据流来处理Azure worker角色中队列中的项目。我应该有一个长时间运行的数据流，还是为我收到的每条消息生成一个新的数据流?

如果在块中抛出错误，该块将停止接受新消息。这意味着如果在一个块中有一个异常，整个数据流将停止处理。

我需要能够承受诸如无效队列输入的异常而不锁定我的数据流。我看到两个选项之一:

1. 我有一个启动单一的数据流，并发送消息给它，因为他们离开队列。每个块的内容都包装在一个记录异常的try-catch块中，然后继续处理。这看起来很笨拙，我想有更好的方法。
2. 对于每个消息，我启动一个新的数据流并处理队列消息。如果在任何块中抛出异常，则数据流将完成，并且我只恢复一条消息。我见过的大多数数据流示例发送多个消息，所以这感觉也不对。

我看过很多关于如何在异常后完成数据流的文档，但是很少有关于如何从异常中恢复的文档。