Added method onFragment to replace onWebsocketMessageFragment and let

the main examples overload it.

Author: Davidiusdadi

src/main/example/ChatServer.java

@@ -7,6 +7,7 @@
 
 importorg.java_websocket.WebSocket;
 importorg.java_websocket.WebSocketImpl;
+importorg.java_websocket.framing.Framedata;
 importorg.java_websocket.handshake.ClientHandshake;
 importorg.java_websocket.server.WebSocketServer;
 
@@ -41,6 +42,11 @@ public void onMessage( WebSocket conn, String message ){
 System.out.println( conn + ": " + message );
  }
 
+@Override
+publicvoidonFragment( WebSocketconn, Framedatafragment ){
+System.out.println( "received fragment: " + fragment );
+ }
+
 publicstaticvoidmain( String[] args ) throwsInterruptedException , IOException{
 WebSocketImpl.DEBUG = true;
 intport = 8887; // 843 flash policy port
@@ -56,9 +62,16 @@ public static void main( String[] args ) throws InterruptedException , IOExcepti
 while ( true ){
 Stringin = sysin.readLine();
 s.sendToAll( in );
+if( in.equals( "exit" ) ){
+s.stop();
+break;
+ } elseif( in.equals( "restart" ) ){
+s.stop();
+s.start();
+break;
+ }
  }
  }
-
 @Override
 publicvoidonError( WebSocketconn, Exceptionex ){
 ex.printStackTrace();

src/main/example/ExampleClient.java

@@ -4,6 +4,7 @@
 importorg.java_websocket.client.WebSocketClient;
 importorg.java_websocket.drafts.Draft;
 importorg.java_websocket.drafts.Draft_10;
+importorg.java_websocket.framing.Framedata;
 importorg.java_websocket.handshake.ServerHandshake;
 
 /** This example demonstrates how to create a websocket connection to a server. Only the most important callbacks are overloaded. */
@@ -20,13 +21,17 @@ public ExampleClient( URI serverURI ){
 @Override
 publicvoidonOpen( ServerHandshakehandshakedata ){
 System.out.println( "opened connection" );
-// if you pan to refuse connection based on ip or httpfields overload: onWebsocketHandshakeReceivedAsClient
+// if you plan to refuse connection based on ip or httpfields overload: onWebsocketHandshakeReceivedAsClient
  }
 
 @Override
 publicvoidonMessage( Stringmessage ){
 System.out.println( "received: " + message );
-// send( "you said: " + message );
+ }
+
+@Override
+publicvoidonFragment( Framedatafragment ){
+System.out.println( "received fragment: " + fragment );
  }
 
 @Override

src/main/java/org/java_websocket/server/WebSocketServer.java

@@ -36,6 +36,7 @@
 importorg.java_websocket.WrappedByteChannel;
 importorg.java_websocket.drafts.Draft;
 importorg.java_websocket.framing.CloseFrame;
+importorg.java_websocket.framing.Framedata;
 importorg.java_websocket.handshake.ClientHandshake;
 importorg.java_websocket.handshake.Handshakedata;
 
@@ -472,6 +473,12 @@ public final void onWebsocketMessage( WebSocket conn, String message ){
 onMessage( conn, message );
  }
 
+@Override
+@Deprecated
+public/*final*/voidonWebsocketMessageFragment( WebSocketconn, Framedataframe ){// onFragment should be overloaded instead
+onFragment( conn, frame );
+ }
+
 @Override
 publicfinalvoidonWebsocketMessage( WebSocketconn, ByteBufferblob ){
 onMessage( conn, blob );
@@ -626,7 +633,13 @@ public InetSocketAddress getRemoteSocketAddress( WebSocket conn ){
  * @see #onMessage(WebSocket, String)
  **/
 publicvoidonMessage( WebSocketconn, ByteBuffermessage ){
- };
+ }
+
+/**
+ * @see WebSocket#sendFragmentedFrame(org.java_websocket.framing.Framedata.Opcode, ByteBuffer, boolean)
+ */
+publicvoidonFragment( WebSocketconn, Framedatafragment ){
+ }
 
 publicclassWebSocketWorkerextendsThread{