You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

WebSocketHandler.java 2.6KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172
  1. /*
  2. * Copyright (c) 2006-2015 DMDirc Developers
  3. *
  4. * Permission is hereby granted, free of charge, to any person obtaining a copy
  5. * of this software and associated documentation files (the "Software"), to deal
  6. * in the Software without restriction, including without limitation the rights
  7. * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
  8. * copies of the Software, and to permit persons to whom the Software is
  9. * furnished to do so, subject to the following conditions:
  10. *
  11. * The above copyright notice and this permission notice shall be included in
  12. * all copies or substantial portions of the Software.
  13. *
  14. * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  15. * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  16. * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  17. * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  18. * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
  19. * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  20. * SOFTWARE.
  21. */
  22. package com.dmdirc.addons.ui_web2;
  23. import java.io.IOException;
  24. import org.eclipse.jetty.websocket.api.Session;
  25. import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose;
  26. import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect;
  27. import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage;
  28. import org.eclipse.jetty.websocket.api.annotations.WebSocket;
  29. /**
  30. * Handles websocket connections.
  31. */
  32. @WebSocket
  33. public class WebSocketHandler {
  34. /** Controller to use. */
  35. @SuppressWarnings("StaticNonFinalField")
  36. private static WebSocketController controller;
  37. /**
  38. * Sets the controller that manages ALL instances of {@link WebSocketHandler}.
  39. *
  40. * @param controller Controller to use.
  41. */
  42. @SuppressWarnings("StaticMethodOnlyUsedInOneClass")
  43. public static void setController(final WebSocketController controller) {
  44. WebSocketHandler.controller = controller;
  45. }
  46. @OnWebSocketConnect
  47. public void connected(final Session session) {
  48. controller.sessionConnected(session);
  49. }
  50. @OnWebSocketClose
  51. public void closed(final Session session, final int statusCode, final String reason) {
  52. controller.sessionClosed(session, statusCode, reason);
  53. }
  54. @OnWebSocketMessage
  55. public void message(final Session session, final String message) {
  56. controller.messageReceived(session, message);
  57. }
  58. public static void sendMessage(final Session session, final String message) throws IOException {
  59. session.getRemote().sendString(message);
  60. }
  61. }