aboutsummaryrefslogtreecommitdiffstats
path: root/src/ParserConfigfile.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/ParserConfigfile.cpp')
-rw-r--r--src/ParserConfigfile.cpp18
1 files changed, 17 insertions, 1 deletions
diff --git a/src/ParserConfigfile.cpp b/src/ParserConfigfile.cpp
index 860b9b1..dcf6733 100644
--- a/src/ParserConfigfile.cpp
+++ b/src/ParserConfigfile.cpp
@@ -61,6 +61,7 @@
#include "dabInputRawFifo.h"
#include "dabInputDmbFile.h"
#include "dabInputDmbUdp.h"
+#include "dabInputZmq.h"
#include "DabMux.h"
@@ -475,9 +476,24 @@ void setup_subchannel_from_ptree(dabSubchannel* subchan,
} else if (strcmp(subchan->inputProto, "file") == 0) {
subchan->operations = dabInputDabplusFileOperations;
#endif // defined(HAVE_INPUT_FILE)
+#if defined(HAVE_INPUT_ZEROMQ)
+ }
+ else if (strcmp(subchan->inputProto, "tcp") == 0) {
+ subchan->operations = dabInputZmqOperations;
+ }
+ else if (strcmp(subchan->inputProto, "epmg") == 0) {
+ etiLog.printHeader(TcpLog::WARNING,
+ "Using untested epmg:// zeromq input\n");
+ subchan->operations = dabInputZmqOperations;
+ }
+ else if (strcmp(subchan->inputProto, "ipc") == 0) {
+ etiLog.printHeader(TcpLog::WARNING,
+ "Using untested ipc:// zeromq input\n");
+ subchan->operations = dabInputZmqOperations;
+#endif // defined(HAVE_INPUT_ZEROMQ)
} else {
stringstream ss;
- ss << "Subchannel with uid " << subchanuid <<
+ ss << "Subchannel with uid " << subchanuid <<
": Invalid protocol for DAB+ input (" <<
subchan->inputProto << ")" << endl;
throw runtime_error(ss.str());