SMPPSession.close() waits for all extra threads to stop

jsmpp/src/main/java/org/jsmpp/session/SMPPSession.java

@@ -454,6 +454,20 @@ protected GenericMessageReceiverListener messageReceiverListener() {
 	    return messageReceiverListener;
 	}
 
+	@Override
+	public void close()
+	{
+		super.close();
+
+		if(Thread.currentThread() != pduReaderWorker) {
+			try {
+				pduReaderWorker.join();
+			} catch (InterruptedException e) {
+				logger.warn("Interrupted while waiting for pduReaderWorker thread to exit");
+			}
+		}
+	}
+
 	@Override
 	protected void finalize() throws Throwable {
 		close();
@@ -602,6 +616,7 @@ private void readPDU() {
 	        } catch (SocketTimeoutException e) {
 	            notifyNoActivity();
 	        } catch (IOException e) {
+	            logger.warn("IOException while reading: {}", e.getMessage());
 	            close();
 	        }
 	    }