Adding the extra Endpoint Client and necessary configuration at the

cirix · cirix · commit c0ac3a450ff9 · 2013-11-02T00:31:35.000+01:00
test.
diff --git a/websocket/binary/src/main/java/org/javaee7/websocket/binary/MyEndpointClient.java b/websocket/binary/src/main/java/org/javaee7/websocket/binary/MyEndpointClient.java
@@ -0,0 +1,28 @@
+/**
+ * 
+ */
+package org.javaee7.websocket.binary;
+
+import java.io.IOException;
+import java.nio.ByteBuffer;
+
+import javax.websocket.ClientEndpoint;
+import javax.websocket.OnOpen;
+import javax.websocket.Session;
+
+/**
+ * @author Nikolaos Ballas
+ *
+ */
+@ClientEndpoint
+public class MyEndpointClient {
+	@OnOpen
+	public void onOpen(Session session){
+		System.out.println("[Action]->Invokint method onOpen of the class:"+this.getClass().getCanonicalName());
+		try{
+			session.getBasicRemote().sendBinary(ByteBuffer.wrap("Hello World!".getBytes()));
+		}catch(IOException ioe){
+			ioe.printStackTrace();
+		}
+	}
+}
diff --git a/websocket/binary/src/test/java/org/javaee7/websocket/binary/test/WebsocketBinaryEndpointTest.java b/websocket/binary/src/test/java/org/javaee7/websocket/binary/test/WebsocketBinaryEndpointTest.java
@@ -7,14 +7,13 @@
 import java.io.IOException;
 import java.net.URI;
 import java.net.URISyntaxException;
-import java.nio.ByteBuffer;
 
 import javax.websocket.ContainerProvider;
 import javax.websocket.DeploymentException;
-import javax.websocket.Session;
 import javax.websocket.WebSocketContainer;
 
 import org.javaee7.websocket.binary.MyEndpoint;
+import org.javaee7.websocket.binary.MyEndpointClient;
 import org.jboss.arquillian.container.test.api.Deployment;
 import org.jboss.arquillian.container.test.api.TargetsContainer;
 import org.jboss.arquillian.junit.Arquillian;
@@ -53,7 +52,6 @@ public static WebArchive createDeployment(){
 	@Test 
 	public void testEndPointBinary() throws URISyntaxException, DeploymentException,IOException{
 		WebSocketContainer socketContainer = ContainerProvider.getWebSocketContainer();
-		Session session = socketContainer.connectToServer(MyEndpoint.class, new URI("ws://localhost:8080/binary/websockeet"));
-		session.getBasicRemote().sendBinary(ByteBuffer.wrap("Hello World".getBytes()));
+		socketContainer.connectToServer(MyEndpointClient.class, new URI("ws://localhost:8080/binary/websockeet"));
 	}
 }
