1 files changed, 50 insertions, 0 deletions
diff --git a/tests/omamqp1-common.sh b/tests/omamqp1-common.sh
new file mode 100644
index 0000000..ec0a6ae
--- /dev/null
+++ b/tests/omamqp1-common.sh
@@ -0,0 +1,50 @@
+#!/bin/bash
+
+# version of qdrouterd to use for test
+QDROUTERD_VERSION=${QDROUTERD_VERSION:-1.7.0}
+# Use of containers isn't necessary for CI, and might not be
+# useful for devs, depending on platform availability.
+# If not using a container for the test, the
+# package will be installed using the platform
+# package manager.
+#USE_CONTAINER=${USE_CONTAINER:-false}
+#CONTAINER_URL=${CONTAINER_URL:-quay.io/interconnectedcloud/qdrouterd:$QDROUTERD_VERSION}
+
+if ! type -p qdrouterd ; then
+	echo no qdrouterd found in PATH $PATH - skipping test
+	exit 0
+fi
+
+ver=$( qdrouterd --version )
+if [ "$ver" = $QDROUTERD_VERSION ] ; then
+	echo found qdrouterd version $ver - continuing
+else
+	echo found qdrouterd version $ver but expected version $QDROUTERD_VERSION - skipping test
+	exit 0
+fi
+
+AMQP_SIMPLE_RECV=${AMQP_SIMPLE_RECV:-/usr/share/proton-0.28.0/examples/python/simple_recv.py}
+
+if [ -f $AMQP_SIMPLE_RECV ] ; then
+	echo found $AMQP_SIMPLE_RECV
+else
+	echo no amqp client $AMQP_SIMPLE_RECV - skipping test
+	exit 0
+fi
+
+AMQP_PYTHON=${AMQP_PYTHON:-python}
+if $AMQP_PYTHON $AMQP_SIMPLE_RECV --help > /dev/null 2>&1 ; then
+	: # good
+elif python3 $AMQP_SIMPLE_RECV --help > /dev/null 2>&1 ; then
+	AMQP_PYTHON=python3
+else
+	echo missing python modules for $AMQP_SIMPLE_RECV - skipping test
+	exit 0
+fi
+
+amqp_simple_recv() {
+	# $1 is host:port (or amqp url if applicable)
+	# $2 is target (e.g. amq.rsyslogtest)
+	# $3 is number of messages to read
+	stdbuf -o 0 $AMQP_PYTHON $AMQP_SIMPLE_RECV -a $1/$2 -m $3
+}