Rename to WebSocketMessageQueue

CMakeLists.txt

@@ -28,7 +28,7 @@ set( IXWEBSOCKET_SOURCES
     ixwebsocket/IXCancellationRequest.cpp
     ixwebsocket/IXNetSystem.cpp
     ixwebsocket/IXWebSocket.cpp
-    ixwebsocket/IXWebSocketPoll.cpp
+    ixwebsocket/IXWebSocketMessageQueue.cpp
     ixwebsocket/IXWebSocketServer.cpp
     ixwebsocket/IXWebSocketTransport.cpp
     ixwebsocket/IXWebSocketHandshake.cpp
@@ -55,7 +55,7 @@ set( IXWEBSOCKET_HEADERS
     ixwebsocket/IXNetSystem.h
     ixwebsocket/IXProgressCallback.h
     ixwebsocket/IXWebSocket.h
-    ixwebsocket/IXWebSocketPoll.h
+    ixwebsocket/IXWebSocketMessageQueue.h
     ixwebsocket/IXWebSocketServer.h
     ixwebsocket/IXWebSocketTransport.h
     ixwebsocket/IXWebSocketHandshake.h

ixwebsocket/IXWebSocketMessageQueue.cpp

@@ -4,17 +4,17 @@
  *  Copyright (c) 2017-2018 Machine Zone, Inc. All rights reserved.
  */
 
-#include "IXWebSocketPoll.h"
+#include "IXWebSocketMessageQueue.h"
 
 namespace ix
 {
 
-    WebSocketPoll::WebSocketPoll(WebSocket* websocket)
+    WebSocketMessageQueue::WebSocketMessageQueue(WebSocket* websocket)
     {
         bindWebsocket(websocket);
     }
 
-    WebSocketPoll::~WebSocketPoll()
+    WebSocketMessageQueue::~WebSocketMessageQueue()
     {
         if (!_messages.empty())
         {
@@ -24,7 +24,7 @@ namespace ix
         bindWebsocket(nullptr);
     }
 
-    void WebSocketPoll::bindWebsocket(WebSocket * websocket)
+    void WebSocketMessageQueue::bindWebsocket(WebSocket * websocket)
     {
         if (_websocket != websocket)
         {
@@ -64,12 +64,12 @@ namespace ix
         }
     }
 
-    void WebSocketPoll::setOnMessageCallback(const OnMessageCallback& callback)
+    void WebSocketMessageQueue::setOnMessageCallback(const OnMessageCallback& callback)
     {
         _onMessageUserCallback = callback;
     }
     
-    WebSocketPoll::MessageDataPtr WebSocketPoll::popMessage()
+    WebSocketMessageQueue::MessageDataPtr WebSocketMessageQueue::popMessage()
     {
         MessageDataPtr message;
 
@@ -84,7 +84,7 @@ namespace ix
         return message;
     }
 
-    void WebSocketPoll::poll(int count)
+    void WebSocketMessageQueue::poll(int count)
     {
         if (!_onMessageUserCallback)
             return;

ixwebsocket/IXWebSocketMessageQueue.h

@@ -16,11 +16,11 @@ namespace ix
     /**
      * A helper class to dispatch websocket message callbacks in your thread.
      */
-    class WebSocketPoll
+    class WebSocketMessageQueue
     {
     public:
-        WebSocketPoll(WebSocket* websocket = nullptr);
-        ~WebSocketPoll();
+        WebSocketMessageQueue(WebSocket* websocket = nullptr);
+        ~WebSocketMessageQueue();
 
         void bindWebsocket(WebSocket* websocket);