increased verbosity in case of errors

Dockerfile

-FROM python:3.9 as build-stage
-
-RUN mkdir /home/doc
-
-WORKDIR /home
-
-RUN mkdir /home/src
-
-COPY ./requirements.txt .
-COPY ./src /home/src
-
-RUN pip3 install -r requirements.txt
-
-WORKDIR /home/doc
-
-COPY ./doc .
-
-RUN make html
-
-FROM nginx
-
-COPY --from=build-stage /home/doc/build/html /usr/share/nginx/html

README.md

 # WZL-MQTT
 [![pipeline status](https://git-ce.rwth-aachen.de/wzl-mq-ms/forschung-lehre/digital-mars/mqtt/badges/master/pipeline.svg)](https://git-ce.rwth-aachen.de/wzl-mq-ms/forschung-lehre/digital-mars/mqtt/badges/master)
 
-Current stable version: 2.5.0
+Current stable version: 2.5.1
 
 ## Documentation
 
@@ -84,6 +84,9 @@ Slightly more detailled examples can be found in the *sample* directory.
 If there are any questions contact [Matthias Bodenbenner](mailto:m.bodenbenner@wzl-mq.rwth-aachen.de).
 
 ## Changelog
+2.5.1
+  - increased verbosity in case of errors by including the full stack trace
+
 2.5.0
   - changed signature of connect method
     - specifying the port is optional now, if not specified the port automatically is derived from the "websocket" and "ssl" flags

default.conf

-server {
-    listen       80;
-    listen  [::]:80;
-    server_name  iot.wzl-mq.rwth-aachen.de;
-
-    location /documentation/libs/mqtt {
-        alias   /usr/share/nginx/html;
-        index  index.html index.htm;
-    }
-
-}
\ No newline at end of file

doc/Dockerfile

-FROM python:3.9 as build-stage
-
-RUN mkdir /home/doc
-
-COPY ../requirements.txt /home/doc
-
-WORKDIR /home/doc
-
-RUN pip install -r requirements.txt
-
-COPY . /home/doc
-
-RUN make html
-
-FROM nginx
-
-COPY --from=build-stage /home/app/doc/build/html /usr/share/nginx/html

doc/default.conf

-server {
-    listen       80;
-    listen  [::]:80;
-    server_name  iot.wzl-mq.rwth-aachen.de;
-
-    location /documentation/libs/mqtt {
-        alias   /usr/share/nginx/html;
-        index  index.html index.htm;
-    }
-
-}
\ No newline at end of file

doc/docker-compose.yml

-version: '3'
-services:
-
-  mqtt-documenation:
-    build: .
-    container_name: documentation-mqtt
-    networks:
-      - documentation-network
-    volumes:
-        - ./default.conf:/etc/nginx/conf.d/default.conf
-    ports:
-      - 9010:80
-    restart: unless-stopped
-
-networks:
-  documentation-network:
-    external: true
\ No newline at end of file

docker-compose.yml

-version: '3'
-services:
-
-  mqtt-documenation:
-    image: registry.git-ce.rwth-aachen.de/wzl-mq-ms/forschung-lehre/digital-mars/mqtt:latest
-    container_name: documentation-mqtt
-    networks:
-      - documentation-network
-    volumes:
-        - ./default.conf:/etc/nginx/conf.d/default.conf
-    ports:
-      - 9010:80
-    restart: unless-stopped
-
-networks:
-  documentation-network:
-    external: true
\ No newline at end of file

setup.py

 from setuptools import setup, find_packages
 
 setup(name='wzl-mqtt',
-      version='2.5.0',
+      version='2.5.1',
       url='',
       author='Matthias Bodenbenner, Benjamin Montavon',
       author_email='m.bodenbenner@wzl-mq.rwth-aachen.de',

src/mqtt/client.py

 import inspect
+import sys
+import traceback
 import uuid
 import warnings
 from typing import Callable, Union
 
 import paho.mqtt.client as mqtt
 
-from .logger import Logger
 from .exceptions import ConnectionError
 from .exceptions import PublishError
 from .exceptions import SubscriptionError
+from .logger import Logger
 
 
 class MQTTClient:
@@ -126,7 +128,8 @@ class MQTTClient:
             self._logger.error(
                 "MQTT Client {} could not connect to {}:{} : {}".format(
                     self.name, broker, port, str(exception)))
-            raise ConnectionError(str(exception))
+            tb = sys.exc_info()[2]
+            raise ConnectionError(str(exception)).with_traceback(tb)
 
     def disconnect(self):
         """Disconnects the client and closes the connection to the broker.
@@ -138,7 +141,8 @@ class MQTTClient:
             self._logger.error(
                 "MQTT Client {} could not disconnect: {}".format(self.name,
                                                                  str(exception)))
-            raise ConnectionError(str(exception))
+            tb = sys.exc_info()[2]
+            raise ConnectionError(str(exception)).with_traceback(tb)
 
     def _on_connect(self, client, userdata, flags, rc):
         if rc == 0:
@@ -218,7 +222,8 @@ class MQTTPublisher(MQTTClient):
                 "MQTT Client {} could not publish to {}: {}".format(self.name,
                                                                     topic,
                                                                     str(exception)))
-            raise PublishError(str(exception))
+            tb = sys.exc_info()[2]
+            raise PublishError(str(exception)).with_traceback(tb)
 
     def _on_publish(self, client, userdata, mid):
         self._logger.debug(
@@ -280,7 +285,8 @@ class MQTTSubscriber(MQTTClient):
                 "MQTT Client {} could not subscribe to {}: {}".format(self.name,
                                                                       topic,
                                                                       str(exception)))
-            raise SubscriptionError(str(exception))
+            tb = sys.exc_info()[2]
+            raise SubscriptionError(str(exception)).with_traceback(tb)
 
     def unsubscribe(self, topic: str):
         """Unsubscribes to updates of the given topic.
@@ -306,7 +312,8 @@ class MQTTSubscriber(MQTTClient):
             self._logger.error(
                 "MQTT Client {} could not unsubscribe from {}: {}".format(
                     self.name, topic, str(exception)))
-            raise SubscriptionError(str(exception))
+            tb = sys.exc_info()[2]
+            raise SubscriptionError(str(exception)).with_traceback(tb)
 
     def set_callback(self, key: str, function: Callable):
         """Add a callback called at each received message.
@@ -370,6 +377,7 @@ class MQTTSubscriber(MQTTClient):
             try:
                 self._on_message_callbacks[key](message.topic, message.payload)
             except Exception as exception:
+                self._logger.error(traceback.format_exc())
                 self._logger.error(
                     "Exception while processing callback for topic {}: {}".format(
                         message.topic, str(exception)))