TCP Server and Client example refreshed

nsiatras · nsiatras · commit 40f432e6cdb2 · 2022-07-24T13:40:16.000+03:00
diff --git a/Extasys for Java Examples/Extasys.Examples.TCPClient/src/Extasys/Examples/TCPClient/TCPClient.java b/Extasys for Java Examples/Extasys.Examples.TCPClient/src/Extasys/Examples/TCPClient/TCPClient.java
@@ -34,7 +34,7 @@ public class TCPClient extends Extasys.Network.TCP.Client.ExtasysTCPClient
 {
 
     private boolean fKeepSendingMessages = false;
-    private final String fMessageToExchange = "Test Message";
+    private final String fMessageToExchange = "128CharMessage111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111";
     private final String fMessageSplitter = "#SPLITTER#";
 
     private final Charset fCharset = Charset.forName("UTF-8"); // This is the default character set to be used for all TCPConnectors
@@ -57,7 +57,7 @@ public void OnDataReceive(TCPConnector connector, DataFrame data)
     {
         try
         {
-            final String dataReceivedFromServer = new String(data.getBytes(), fCharset);
+            //final String dataReceivedFromServer = new String(data.getBytes(), fCharset);
 
             // Every time I receive data from the server I send the
             // fMessageToExchange string back
diff --git a/Extasys for Java Examples/Extasys.Examples.TCPClient/src/Extasys/Examples/TCPClient/frmMain.java b/Extasys for Java Examples/Extasys.Examples.TCPClient/src/Extasys/Examples/TCPClient/frmMain.java
@@ -32,6 +32,8 @@ public class frmMain extends javax.swing.JFrame
     private Thread fUpdateStatusThread;
     private boolean fUpdateStatusActive = true;
 
+    private long fOldBytesIn = 0, fOldBytesOut = 0;
+
     public frmMain()
     {
         initComponents();
@@ -241,6 +243,7 @@ private void jButton3ActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FIRS
         fUpdateStatusThread = new Thread(new Runnable()
         {
 
+            @Override
             public void run()
             {
                 try
@@ -249,10 +252,16 @@ public void run()
                     {
                         if (fTCPClient != null)
                         {
-                            jLabelBytesIn.setText(String.valueOf(fTCPClient.getBytesIn()));
-                            jLabelBytesOut.setText(String.valueOf(fTCPClient.getBytesOut()));
+                            Long newBytesIn = fTCPClient.getBytesIn();
+                            Long newBytesOut = fTCPClient.getBytesOut();
+
+                            jLabelBytesIn.setText(String.valueOf(newBytesIn) + " (" + String.valueOf((newBytesIn - fOldBytesIn) / 1000) + "kb/sec)");
+                            jLabelBytesOut.setText(String.valueOf(newBytesOut) + " (" + String.valueOf((newBytesOut - fOldBytesOut) / 1000) + "kb/sec)");
+
+                            fOldBytesIn = newBytesIn;
+                            fOldBytesOut = newBytesOut;
                         }
-                        Thread.sleep(500);
+                        Thread.sleep(1000);
                     }
                 }
                 catch (Exception ex)
diff --git a/Extasys for Java Examples/Extasys.Examples.TCPServer/src/Extasys/Examples/TCPServer/TCPServer.java b/Extasys for Java Examples/Extasys.Examples.TCPServer/src/Extasys/Examples/TCPServer/TCPServer.java
@@ -58,7 +58,7 @@ public void OnDataReceive(TCPClientConnection sender, DataFrame data)
         try
         {
             // I received data from a client
-            String incomingDataStr = new String(data.getBytes(), fCharset);
+            final String incomingDataStr = new String(data.getBytes(), fCharset);
             //System.out.println("Data received: " + incomingDataStr);
 
             // Send the incoming data back to the client
diff --git a/Extasys for Java Examples/Extasys.Examples.TCPServer/src/Extasys/Examples/TCPServer/frmTCPServer.java b/Extasys for Java Examples/Extasys.Examples.TCPServer/src/Extasys/Examples/TCPServer/frmTCPServer.java
@@ -282,8 +282,8 @@ public void run()
                                 Long newBytesIn = fTCPServer.getBytesIn();
                                 Long newBytesOut = fTCPServer.getBytesOut();
 
-                                jLabelBytesIn.setText(String.valueOf(newBytesIn) + " (" + String.valueOf(newBytesIn - fOldBytesIn) + "/sec)");
-                                jLabelBytesOut.setText(String.valueOf(newBytesOut) + " (" + String.valueOf(newBytesOut - fOldBytesOut) + "/sec)");
+                                jLabelBytesIn.setText(String.valueOf(newBytesIn) + " (" + String.valueOf((newBytesIn - fOldBytesIn)/1000) + "kb/sec)");
+                                jLabelBytesOut.setText(String.valueOf(newBytesOut) + " (" + String.valueOf((newBytesOut - fOldBytesOut)/1000) + "kb/sec)");
                                 jLabelClientsConnected.setText(String.valueOf(fTCPServer.getCurrentConnectionsNumber()));
 
                                 fOldBytesIn = newBytesIn;
diff --git a/Extasys for Java/nbproject/project.properties b/Extasys for Java/nbproject/project.properties
@@ -4,7 +4,7 @@ annotation.processing.processors.list=
 annotation.processing.run.all.processors=true
 application.desc=TCP/UDP Socket for Java
 application.homepage=
-application.title=Extasys 3.2
+application.title=Extasys v3.3
 application.vendor=Nikos Siatras
 auxiliary.org-netbeans-spi-editor-hints-projects.perProjectHintSettingsFile=nbproject/cfg_hints.xml
 build.classes.dir=${build.dir}/classes
diff --git a/Extasys for Java/src/Extasys/ByteArrayBuilder.java b/Extasys for Java/src/Extasys/ByteArrayBuilder.java
@@ -57,11 +57,10 @@ public int IndexOf(byte[] subArray)
     {
         synchronized (fLock)
         {
-            int i = 0;
             int subArrayLength = subArray.length;
 
             // Find subArray in fBytes
-            for (i = 0; i < fBytes.length; i++)
+            for (int i = 0; i < fBytes.length; i++)
             {
                 byte[] arrayToCompare = Arrays.copyOfRange(fBytes, i, i + subArrayLength);
 
diff --git a/Extasys for Java/src/Extasys/ExtasysThreadPool.java b/Extasys for Java/src/Extasys/ExtasysThreadPool.java
@@ -32,7 +32,7 @@ public class ExtasysThreadPool extends ThreadPoolExecutor
 
     public ExtasysThreadPool(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit)
     {
-        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, new ArrayBlockingQueue(500000, true));
+        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, new ArrayBlockingQueue(250000, true));
         this.prestartAllCoreThreads();
     }
 
diff --git a/Extasys for Java/src/Extasys/Network/TCP/Client/Connectors/Packets/IncomingTCPClientPacket.java b/Extasys for Java/src/Extasys/Network/TCP/Client/Connectors/Packets/IncomingTCPClientPacket.java
@@ -31,7 +31,7 @@ of this software and associated documentation files (the "Software"), to deal
 public final class IncomingTCPClientPacket implements Runnable
 {
 
-    public ManualResetEvent fDone = new ManualResetEvent(false);
+    public final ManualResetEvent fDone = new ManualResetEvent(false);
     private final TCPConnector fConnector;
     private final DataFrame fData;
     private IncomingTCPClientPacket fPreviousPacket;
@@ -130,9 +130,9 @@ public DataFrame getData()
     }
 
     /**
-     * Returns the previous incoming packet received by the client. If the packet
-     * is null means that the packet has been received and parsed from the
-     * client.
+     * Returns the previous incoming packet received by the client. If the
+     * packet is null means that the packet has been received and parsed from
+     * the client.
      *
      * @return the previous incoming packet received by the client.
      */
diff --git a/Extasys for Java/src/Extasys/Network/TCP/Client/Connectors/Packets/MessageCollectorTCPClientPacket.java b/Extasys for Java/src/Extasys/Network/TCP/Client/Connectors/Packets/MessageCollectorTCPClientPacket.java
@@ -30,7 +30,7 @@ of this software and associated documentation files (the "Software"), to deal
 public final class MessageCollectorTCPClientPacket implements Runnable
 {
 
-    public ManualResetEvent fDone = new ManualResetEvent(false);
+    public final ManualResetEvent fDone = new ManualResetEvent(false);
     private final TCPConnector fConnector;
     private final byte[] fData;
     private MessageCollectorTCPClientPacket fPreviousPacket;
diff --git a/Extasys for Java/src/Extasys/Network/TCP/Client/Connectors/Packets/OutgoingTCPClientPacket.java b/Extasys for Java/src/Extasys/Network/TCP/Client/Connectors/Packets/OutgoingTCPClientPacket.java
@@ -32,7 +32,7 @@ of this software and associated documentation files (the "Software"), to deal
 public final class OutgoingTCPClientPacket implements Runnable
 {
 
-    public ManualResetEvent fDone = new ManualResetEvent(false);
+    public final ManualResetEvent fDone = new ManualResetEvent(false);
     private final TCPConnector fConnector;
     private final byte[] fBytes;
     private final int fOffset;
diff --git a/Extasys for Java/src/Extasys/Network/TCP/Client/Connectors/Tools/TCPClientMessageCollector.java b/Extasys for Java/src/Extasys/Network/TCP/Client/Connectors/Tools/TCPClientMessageCollector.java
@@ -30,7 +30,7 @@ of this software and associated documentation files (the "Software"), to deal
 public class TCPClientMessageCollector
 {
 
-    private TCPConnector fMyConnector;
+    private final TCPConnector fMyConnector;
     private final byte[] fETXStr;
     private final ByteArrayBuilder fIncomingDataBuffer = new ByteArrayBuilder();
     private final int fETXLength;
@@ -50,15 +50,15 @@ public TCPClientMessageCollector(TCPConnector connector, String splitter)
         fETXLength = fETXStr.length;
     }
 
-    public void AppendData(byte[] bytes)
+    public void AppendData(final byte[] bytes)
     {
         try
         {
             fIncomingDataBuffer.Append(bytes);
             fIndexOfETX = fIncomingDataBuffer.IndexOf(fETXStr);
             while (fIndexOfETX > -1)
             {
-                fMyConnector.getMyExtasysTCPClient().OnDataReceive(fMyConnector, new DataFrame(fIncomingDataBuffer.SubList(0, fIndexOfETX)));
+                fMyConnector.fMyTCPClient.OnDataReceive(fMyConnector, new DataFrame(fIncomingDataBuffer.SubList(0, fIndexOfETX)));
                 fIncomingDataBuffer.Delete(0, fIndexOfETX + fETXLength);
                 fIndexOfETX = fIncomingDataBuffer.IndexOf(fETXStr);
             }
@@ -73,7 +73,7 @@ public void Dispose()
     {
         try
         {
-            fMyConnector = null;
+            //fMyConnector = null;
         }
         catch (Exception ex)
         {
diff --git a/Extasys for Java/src/Extasys/Network/TCP/Server/Listener/Packets/MessageCollectorTCPClientConnectionPacket.java b/Extasys for Java/src/Extasys/Network/TCP/Server/Listener/Packets/MessageCollectorTCPClientConnectionPacket.java
@@ -48,7 +48,7 @@ public final class MessageCollectorTCPClientConnectionPacket implements Runnable
      * @param previousPacket is the previous message collector packet of the
      * TCPClientConnection.
      */
-    public MessageCollectorTCPClientConnectionPacket(TCPClientConnection client, byte[] data, MessageCollectorTCPClientConnectionPacket previousPacket)
+    public MessageCollectorTCPClientConnectionPacket(final TCPClientConnection client, final byte[] data, final MessageCollectorTCPClientConnectionPacket previousPacket)
     {
         fClient = client;
         fData = data;
diff --git a/Extasys for Java/src/Extasys/Network/TCP/Server/Listener/TCPClientConnection.java b/Extasys for Java/src/Extasys/Network/TCP/Server/Listener/TCPClientConnection.java
@@ -42,6 +42,7 @@ of this software and associated documentation files (the "Software"), to deal
  */
 public final class TCPClientConnection
 {
+
     // Connection properties
     protected Socket fConnection;
     protected boolean fActive = false;
@@ -135,9 +136,9 @@ private void StartReceivingData()
      * @throws
      * Extasys.Network.TCP.Server.Listener.Exceptions.OutgoingPacketFailedException
      */
-    public void SendData(String data) throws ClientIsDisconnectedException, OutgoingPacketFailedException
+    public void SendData(final String data) throws ClientIsDisconnectedException, OutgoingPacketFailedException
     {
-        byte[] bytes = data.getBytes(fMyListener.getCharset());
+        final byte[] bytes = data.getBytes(fMyListener.getCharset());
         SendData(bytes, 0, bytes.length);
     }
 
@@ -171,9 +172,9 @@ public void SendData(byte[] bytes, int offset, int length) throws ClientIsDiscon
      * @param data is the string to send.
      * @throws ClientIsDisconnectedException
      */
-    public void SendDataSynchronous(String data) throws ClientIsDisconnectedException
+    public void SendDataSynchronous(final String data) throws ClientIsDisconnectedException
     {
-        byte[] bytes = data.getBytes(fMyListener.getCharset());
+        final byte[] bytes = data.getBytes(fMyListener.getCharset());
         SendDataSynchronous(bytes, 0, bytes.length);
     }
 
diff --git a/Extasys for Java/src/Extasys/Network/TCP/Server/Listener/Tools/TCPClientConnectionMessageCollector.java b/Extasys for Java/src/Extasys/Network/TCP/Server/Listener/Tools/TCPClientConnectionMessageCollector.java
@@ -30,7 +30,7 @@ of this software and associated documentation files (the "Software"), to deal
 public class TCPClientConnectionMessageCollector
 {
 
-    private TCPClientConnection fMyClient;
+    private final TCPClientConnection fMyClient;
     private final byte[] fETXStr;
     private final ByteArrayBuilder fIncomingDataBuffer;
     private int fIndexOfETX;
@@ -52,15 +52,15 @@ public TCPClientConnectionMessageCollector(TCPClientConnection myClient, String
         fIncomingDataBuffer = new ByteArrayBuilder();
     }
 
-    public void AppendData(byte[] bytes)
+    public void AppendData(final byte[] bytes)
     {
         try
         {
             fIncomingDataBuffer.Append(bytes);
             fIndexOfETX = fIncomingDataBuffer.IndexOf(fETXStr);
             while (fIndexOfETX > -1)
             {
-                fMyClient.getMyTCPListener().getMyExtasysTCPServer().OnDataReceive(fMyClient, new DataFrame(fIncomingDataBuffer.SubList(0, fIndexOfETX)));
+                fMyClient.fMyExtasysServer.OnDataReceive(fMyClient, new DataFrame(fIncomingDataBuffer.SubList(0, fIndexOfETX)));
                 fIncomingDataBuffer.Delete(0, fIndexOfETX + fETXLength);
                 fIndexOfETX = fIncomingDataBuffer.IndexOf(fETXStr);
             }
@@ -75,7 +75,7 @@ public void Dispose()
     {
         try
         {
-            fMyClient = null;
+
         }
         catch (Exception ex)
         {

Original file line number	Diff line number	Diff line change
`@@ -34,7 +34,7 @@ public class TCPClient extends Extasys.Network.TCP.Client.ExtasysTCPClient`
`34`	`34`	`{`
`35`	`35`
`36`	`36`	`private boolean fKeepSendingMessages = false;`
`37`		`- private final String fMessageToExchange = "Test Message";`
	`37`	`+ private final String fMessageToExchange = "128CharMessage111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111";`
`38`	`38`	`private final String fMessageSplitter = "#SPLITTER#";`
`39`	`39`
`40`	`40`	`private final Charset fCharset = Charset.forName("UTF-8"); // This is the default character set to be used for all TCPConnectors`
`@@ -57,7 +57,7 @@ public void OnDataReceive(TCPConnector connector, DataFrame data)`
`57`	`57`	`{`
`58`	`58`	`try`
`59`	`59`	`{`
`60`		`- final String dataReceivedFromServer = new String(data.getBytes(), fCharset);`
	`60`	`+ //final String dataReceivedFromServer = new String(data.getBytes(), fCharset);`
`61`	`61`
`62`	`62`	`// Every time I receive data from the server I send the`
`63`	`63`	`// fMessageToExchange string back`
Original file line number	Diff line number	Diff line change
`@@ -32,6 +32,8 @@ public class frmMain extends javax.swing.JFrame`
`32`	`32`	`private Thread fUpdateStatusThread;`
`33`	`33`	`private boolean fUpdateStatusActive = true;`
`34`	`34`
	`35`	`+ private long fOldBytesIn = 0, fOldBytesOut = 0;`
	`36`	`+`
`35`	`37`	`public frmMain()`
`36`	`38`	`{`
`37`	`39`	`initComponents();`
`@@ -241,6 +243,7 @@ private void jButton3ActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FIRS`
`241`	`243`	`fUpdateStatusThread = new Thread(new Runnable()`
`242`	`244`	`{`
`243`	`245`
	`246`	`+ @Override`
`244`	`247`	`public void run()`
`245`	`248`	`{`
`246`	`249`	`try`
`@@ -249,10 +252,16 @@ public void run()`
`249`	`252`	`{`
`250`	`253`	`if (fTCPClient != null)`
`251`	`254`	`{`
`252`		`- jLabelBytesIn.setText(String.valueOf(fTCPClient.getBytesIn()));`
`253`		`- jLabelBytesOut.setText(String.valueOf(fTCPClient.getBytesOut()));`
	`255`	`+ Long newBytesIn = fTCPClient.getBytesIn();`
	`256`	`+ Long newBytesOut = fTCPClient.getBytesOut();`
	`257`	`+`
	`258`	`+ jLabelBytesIn.setText(String.valueOf(newBytesIn) + " (" + String.valueOf((newBytesIn - fOldBytesIn) / 1000) + "kb/sec)");`
	`259`	`+ jLabelBytesOut.setText(String.valueOf(newBytesOut) + " (" + String.valueOf((newBytesOut - fOldBytesOut) / 1000) + "kb/sec)");`
	`260`	`+`
	`261`	`+ fOldBytesIn = newBytesIn;`
	`262`	`+ fOldBytesOut = newBytesOut;`
`254`	`263`	`}`
`255`		`- Thread.sleep(500);`
	`264`	`+ Thread.sleep(1000);`
`256`	`265`	`}`
`257`	`266`	`}`
`258`	`267`	`catch (Exception ex)`
Original file line number	Diff line number	Diff line change
`@@ -58,7 +58,7 @@ public void OnDataReceive(TCPClientConnection sender, DataFrame data)`
`58`	`58`	`try`
`59`	`59`	`{`
`60`	`60`	`// I received data from a client`
`61`		`- String incomingDataStr = new String(data.getBytes(), fCharset);`
	`61`	`+ final String incomingDataStr = new String(data.getBytes(), fCharset);`
`62`	`62`	`//System.out.println("Data received: " + incomingDataStr);`
`63`	`63`
`64`	`64`	`// Send the incoming data back to the client`
Original file line number	Diff line number	Diff line change
`@@ -57,11 +57,10 @@ public int IndexOf(byte[] subArray)`
`57`	`57`	`{`
`58`	`58`	`synchronized (fLock)`
`59`	`59`	`{`
`60`		`- int i = 0;`
`61`	`60`	`int subArrayLength = subArray.length;`
`62`	`61`
`63`	`62`	`// Find subArray in fBytes`
`64`		`- for (i = 0; i < fBytes.length; i++)`
	`63`	`+ for (int i = 0; i < fBytes.length; i++)`
`65`	`64`	`{`
`66`	`65`	`byte[] arrayToCompare = Arrays.copyOfRange(fBytes, i, i + subArrayLength);`
`67`	`66`
Original file line number	Diff line number	Diff line change
`@@ -32,7 +32,7 @@ public class ExtasysThreadPool extends ThreadPoolExecutor`
`32`	`32`
`33`	`33`	`public ExtasysThreadPool(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit)`
`34`	`34`	`{`
`35`		`- super(corePoolSize, maximumPoolSize, keepAliveTime, unit, new ArrayBlockingQueue(500000, true));`
	`35`	`+ super(corePoolSize, maximumPoolSize, keepAliveTime, unit, new ArrayBlockingQueue(250000, true));`
`36`	`36`	`this.prestartAllCoreThreads();`
`37`	`37`	`}`
`38`	`38`
Original file line number	Diff line number	Diff line change
`@@ -31,7 +31,7 @@ of this software and associated documentation files (the "Software"), to deal`
`31`	`31`	`public final class IncomingTCPClientPacket implements Runnable`
`32`	`32`	`{`
`33`	`33`
`34`		`- public ManualResetEvent fDone = new ManualResetEvent(false);`
	`34`	`+ public final ManualResetEvent fDone = new ManualResetEvent(false);`
`35`	`35`	`private final TCPConnector fConnector;`
`36`	`36`	`private final DataFrame fData;`
`37`	`37`	`private IncomingTCPClientPacket fPreviousPacket;`
`@@ -130,9 +130,9 @@ public DataFrame getData()`
`130`	`130`	`}`
`131`	`131`
`132`	`132`	`/**`
`133`		`- * Returns the previous incoming packet received by the client. If the packet`
`134`		`- * is null means that the packet has been received and parsed from the`
`135`		`- * client.`
	`133`	`+ * Returns the previous incoming packet received by the client. If the`
	`134`	`+ * packet is null means that the packet has been received and parsed from`
	`135`	`+ * the client.`
`136`	`136`	`*`
`137`	`137`	`* @return the previous incoming packet received by the client.`
`138`	`138`	`*/`
Original file line number	Diff line number	Diff line change
`@@ -30,7 +30,7 @@ of this software and associated documentation files (the "Software"), to deal`
`30`	`30`	`public final class MessageCollectorTCPClientPacket implements Runnable`
`31`	`31`	`{`
`32`	`32`
`33`		`- public ManualResetEvent fDone = new ManualResetEvent(false);`
	`33`	`+ public final ManualResetEvent fDone = new ManualResetEvent(false);`
`34`	`34`	`private final TCPConnector fConnector;`
`35`	`35`	`private final byte[] fData;`
`36`	`36`	`private MessageCollectorTCPClientPacket fPreviousPacket;`
Original file line number	Diff line number	Diff line change
`@@ -32,7 +32,7 @@ of this software and associated documentation files (the "Software"), to deal`
`32`	`32`	`public final class OutgoingTCPClientPacket implements Runnable`
`33`	`33`	`{`
`34`	`34`
`35`		`- public ManualResetEvent fDone = new ManualResetEvent(false);`
	`35`	`+ public final ManualResetEvent fDone = new ManualResetEvent(false);`
`36`	`36`	`private final TCPConnector fConnector;`
`37`	`37`	`private final byte[] fBytes;`
`38`	`38`	`private final int fOffset;`
Original file line number	Diff line number	Diff line change
`@@ -48,7 +48,7 @@ public final class MessageCollectorTCPClientConnectionPacket implements Runnable`
`48`	`48`	`* @param previousPacket is the previous message collector packet of the`
`49`	`49`	`* TCPClientConnection.`
`50`	`50`	`*/`
`51`		`- public MessageCollectorTCPClientConnectionPacket(TCPClientConnection client, byte[] data, MessageCollectorTCPClientConnectionPacket previousPacket)`
	`51`	`+ public MessageCollectorTCPClientConnectionPacket(final TCPClientConnection client, final byte[] data, final MessageCollectorTCPClientConnectionPacket previousPacket)`
`52`	`52`	`{`
`53`	`53`	`fClient = client;`
`54`	`54`	`fData = data;`
Original file line number	Diff line number	Diff line change
`@@ -42,6 +42,7 @@ of this software and associated documentation files (the "Software"), to deal`
`42`	`42`	`*/`
`43`	`43`	`public final class TCPClientConnection`
`44`	`44`	`{`
	`45`	`+`
`45`	`46`	`// Connection properties`
`46`	`47`	`protected Socket fConnection;`
`47`	`48`	`protected boolean fActive = false;`
`@@ -135,9 +136,9 @@ private void StartReceivingData()`
`135`	`136`	`* @throws`
`136`	`137`	`* Extasys.Network.TCP.Server.Listener.Exceptions.OutgoingPacketFailedException`
`137`	`138`	`*/`
`138`		`- public void SendData(String data) throws ClientIsDisconnectedException, OutgoingPacketFailedException`
	`139`	`+ public void SendData(final String data) throws ClientIsDisconnectedException, OutgoingPacketFailedException`
`139`	`140`	`{`
`140`		`- byte[] bytes = data.getBytes(fMyListener.getCharset());`
	`141`	`+ final byte[] bytes = data.getBytes(fMyListener.getCharset());`
`141`	`142`	`SendData(bytes, 0, bytes.length);`
`142`	`143`	`}`
`143`	`144`
`@@ -171,9 +172,9 @@ public void SendData(byte[] bytes, int offset, int length) throws ClientIsDiscon`
`171`	`172`	`* @param data is the string to send.`
`172`	`173`	`* @throws ClientIsDisconnectedException`
`173`	`174`	`*/`
`174`		`- public void SendDataSynchronous(String data) throws ClientIsDisconnectedException`
	`175`	`+ public void SendDataSynchronous(final String data) throws ClientIsDisconnectedException`
`175`	`176`	`{`
`176`		`- byte[] bytes = data.getBytes(fMyListener.getCharset());`
	`177`	`+ final byte[] bytes = data.getBytes(fMyListener.getCharset());`
`177`	`178`	`SendDataSynchronous(bytes, 0, bytes.length);`
`178`	`179`	`}`
`179`	`180`