Feature/cleanup 1

src/main/java/de/csdev/ebus/client/EBusClient.java

@@ -82,6 +82,8 @@ public void addEBusDeviceTableListener(final @NonNull IEBusDeviceTableListener l
         Objects.requireNonNull(listener, LABEL_LISTENER);
         if (deviceTable != null) {
             deviceTable.addEBusDeviceTableListener(listener);
+        } else {
+            throw new IllegalStateException("Device Table is not initialized!");
         }
     }
 
@@ -95,6 +97,8 @@ public void addEBusEventListener(final @NonNull IEBusConnectorEventListener list
         Objects.requireNonNull(listener, LABEL_LISTENER);
         if (controller != null) {
             controller.addEBusEventListener(listener);
+        } else {
+            throw new IllegalStateException("Controller is not initialized!");
         }
     }
 
@@ -108,6 +112,8 @@ public void addEBusParserListener(final @NonNull IEBusParserListener listener) {
         Objects.requireNonNull(listener, LABEL_LISTENER);
         if (resolverService != null) {
             resolverService.addEBusParserListener(listener);
+        } else {
+            throw new IllegalStateException("Resolver Service is not initialized!");
         }
     }
 

src/main/java/de/csdev/ebus/core/EBusControllerBase.java

@@ -236,7 +236,7 @@ protected void fireOnEBusConnectionStatusChange(final @NonNull ConnectionStatus
     protected void initThreadPool() {
         // create new thread pool to send received telegrams
         // limit the number of threads to 30
-        threadPool = new ThreadPoolExecutor(0, 30, 60L, TimeUnit.SECONDS, new SynchronousQueue<>(),
+        threadPool = new ThreadPoolExecutor(5, 60, 60L, TimeUnit.SECONDS, new SynchronousQueue<>(),
                 new EBusWorkerThreadFactory("ebus-receiver", true));
 
         // create watch dog thread pool

src/main/java/de/csdev/ebus/core/EBusReceiveStateMachine.java

@@ -222,12 +222,12 @@ public String toDumpString() {
     /**
      * Update the state machine
      *
-     * @param data The next byte
+     * @param dataByte The next byte
      * @throws EBusDataException throws an exception on any telegram error
      */
-    public void update(final byte data0) throws EBusDataException {
+    public void update(final byte dataByte) throws EBusDataException {
 
-        byte data = data0;
+        byte data = dataByte;
 
         try {