Index: google_apis/gcm/engine/mcs_client.h |
diff --git a/google_apis/gcm/engine/mcs_client.h b/google_apis/gcm/engine/mcs_client.h |
index adfb0a4259dabf6b264c0105ece935131f937d41..906b97ae1bdf52410de73b7402a55e49cffa79b6 100644 |
--- a/google_apis/gcm/engine/mcs_client.h |
+++ b/google_apis/gcm/engine/mcs_client.h |
@@ -16,8 +16,8 @@ |
#include "google_apis/gcm/base/gcm_export.h" |
#include "google_apis/gcm/base/mcs_message.h" |
#include "google_apis/gcm/engine/connection_handler.h" |
+#include "google_apis/gcm/engine/gcm_store.h" |
#include "google_apis/gcm/engine/heartbeat_manager.h" |
-#include "google_apis/gcm/engine/rmq_store.h" |
namespace base { |
class Clock; |
@@ -45,10 +45,10 @@ struct ReliablePacketInfo; |
class GCM_EXPORT MCSClient { |
public: |
enum State { |
- UNINITIALIZED, // Uninitialized. |
- LOADED, // RMQ Load finished, waiting to connect. |
- CONNECTING, // Connection in progress. |
- CONNECTED, // Connected and running. |
+ UNINITIALIZED, // Uninitialized. |
+ LOADED, // GCM Load finished, waiting to connect. |
+ CONNECTING, // Connection in progress. |
+ CONNECTED, // Connected and running. |
}; |
// Callback for informing MCSClient status. It is valid for this to be |
@@ -70,22 +70,22 @@ class GCM_EXPORT MCSClient { |
MCSClient(base::Clock* clock, |
ConnectionFactory* connection_factory, |
- RMQStore* rmq_store); |
+ GCMStore* gcm_store); |
virtual ~MCSClient(); |
// Initialize the client. Will load any previous id/token information as well |
- // as unacknowledged message information from the RMQ storage, if it exists, |
+ // as unacknowledged message information from the GCM storage, if it exists, |
// passing the id/token information back via |initialization_callback| along |
- // with a |success == true| result. If no RMQ information is present (and |
- // this is therefore a fresh client), a clean RMQ store will be created and |
+ // with a |success == true| result. If no GCM information is present (and |
+ // this is therefore a fresh client), a clean GCM store will be created and |
// values of 0 will be returned via |initialization_callback| with |
// |success == true|. |
- /// If an error loading the RMQ store is encountered, |
+ /// If an error loading the GCM store is encountered, |
// |initialization_callback| will be invoked with |success == false|. |
void Initialize(const InitializationCompleteCallback& initialization_callback, |
const OnMessageReceivedCallback& message_received_callback, |
const OnMessageSentCallback& message_sent_callback, |
- const RMQStore::LoadResult& load_result); |
+ const GCMStore::LoadResult& load_result); |
// Logs the client into the server. Client must be initialized. |
// |android_id| and |security_token| are optional if this is not a new |
@@ -105,7 +105,7 @@ class GCM_EXPORT MCSClient { |
// |message_sent_callback_| is invoked with a TTL expiration error. |
void SendMessage(const MCSMessage& message); |
- // Disconnects the client and permanently destroys the persistent RMQ store. |
+ // Disconnects the client and permanently destroys the persistent GCM store. |
// WARNING: This is permanent, and the client must be recreated with new |
// credentials afterwards. |
void Destroy(); |
@@ -130,8 +130,8 @@ class GCM_EXPORT MCSClient { |
// Send a heartbeat to the MCS server. |
void SendHeartbeat(); |
- // RMQ Store callback. |
- void OnRMQUpdateFinished(bool success); |
+ // GCM Store callback. |
+ void OnGCMUpdateFinished(bool success); |
// Attempt to send a message. |
void MaybeSendMessage(); |
@@ -222,8 +222,8 @@ class GCM_EXPORT MCSClient { |
// acknowledged on the next login attempt. |
PersistentIdList restored_unackeds_server_ids_; |
- // The reliable message queue persistent store. Owned by the caller. |
- RMQStore* rmq_store_; |
+ // The GCM persistent store. Not owned. |
+ GCMStore* gcm_store_; |
// Manager to handle triggering/detecting heartbeats. |
HeartbeatManager heartbeat_manager_; |