Test to check that session.close() does not call OnError

TestCleanClose.java (text/plain), 2.96 KB, created by Barry Coughlan on 2015-12-02 16:50:59 UTC

(hide)

Description: Test to check that session.close() does not call OnError

Filename:

MIME Type:

Creator: Barry Coughlan

Created: 2015-12-02 16:50:59 UTC

Size: 2.96 KB

patch

obsolete

>package org.apache.tomcat.websocket.server; > >import java.net.URI; > >import javax.servlet.ServletContextEvent; >import javax.websocket.ClientEndpoint; >import javax.websocket.CloseReason; >import javax.websocket.ContainerProvider; >import javax.websocket.DeploymentException; >import javax.websocket.OnClose; >import javax.websocket.OnError; >import javax.websocket.OnMessage; >import javax.websocket.OnOpen; >import javax.websocket.Session; >import javax.websocket.WebSocketContainer; >import javax.websocket.server.ServerContainer; >import javax.websocket.server.ServerEndpointConfig; > >import org.apache.catalina.Context; >import org.apache.catalina.servlets.DefaultServlet; >import org.apache.catalina.startup.Tomcat; >import org.apache.catalina.startup.TomcatBaseTest; >import org.junit.Test; > >public class TestCleanClose extends TomcatBaseTest { > > @Test > public void testOnErrorNotCalledWhenClosingConnection() throws Throwable { > Tomcat tomcat = getTomcatInstance(); > // No file system docBase required > Context ctx = tomcat.addContext("", null); > ctx.addApplicationListener(Bug58624ServerConfig.class.getName()); > Tomcat.addServlet(ctx, "default", new DefaultServlet()); > ctx.addServletMapping("/", "default"); > > WebSocketContainer wsContainer = ContainerProvider > .getWebSocketContainer(); > > tomcat.start(); > > Bug58624ClientEndpoint client = new Bug58624ClientEndpoint(); > URI uri = new URI("ws://localhost:" + getPort() > + Bug58624ServerConfig.PATH); > > Session session = wsContainer.connectToServer(client, uri); > session.close(); > > if (client.getError() != null) { > throw client.getError(); > } > } > > @ClientEndpoint > public class Bug58624ClientEndpoint { > private volatile Throwable t; > > @OnError > public void onError(Throwable t) { > this.t = t; > } > > public Throwable getError() { > return this.t; > } > } > > public static class Bug58624ServerConfig extends WsContextListener { > > public static String PATH = "/bug58624"; > > @Override > public void contextInitialized(ServletContextEvent sce) { > super.contextInitialized(sce); > > ServerContainer sc = (ServerContainer) sce > .getServletContext() > .getAttribute( > Constants.SERVER_CONTAINER_SERVLET_CONTEXT_ATTRIBUTE); > > ServerEndpointConfig sec = ServerEndpointConfig.Builder.create( > Bug58624ServerEndpoint.class, PATH).build(); > > try { > sc.addEndpoint(sec); > } catch (DeploymentException e) { > throw new RuntimeException(e); > } > } > } > > public static class Bug58624ServerEndpoint { > > @OnOpen > public void onOpen() { > System.out.println("Session opened"); > } > > @OnMessage > public void onMessage(Session session, String message) { > System.out.println("Received message " + message); > } > > @OnError > public void onError(Throwable t) { > System.out.println("HERE"); > t.printStackTrace(); > } > > @OnClose > public void onClose(CloseReason cr) { > System.out.println("Session closed: " + cr); > } > } >} View Attachment As Raw

This is ASF Bugzilla: the Apache Software Foundation bug system. In case of problems with the functioning of ASF Bugzilla, please contact bugzilla-admin@apache.org. Please Note: this e-mail address is only for reporting problems with ASF Bugzilla. Mail about any other subject will be silently ignored.

• • Home
  • | New
  • | Browse
  • | Search
  • |
    [?]
  • | Reports
  • | Help
  • | New Account
  • | Log In
    Remember [x]
  • | Forgot Password
    Login: [x]