Index: sync/tools/sync_listen_notifications.cc |
diff --git a/sync/tools/sync_listen_notifications.cc b/sync/tools/sync_listen_notifications.cc |
index 25ebcbdae1b9ae9bbbbf2eec3b8e573330cb4f9a..22b22d6d6d2025c819e913b8c4c6fa63621335da 100644 |
--- a/sync/tools/sync_listen_notifications.cc |
+++ b/sync/tools/sync_listen_notifications.cc |
@@ -63,8 +63,10 @@ class NotificationPrinter : public SyncNotifierObserver { |
} |
virtual void OnIncomingNotification( |
- const ModelTypePayloadMap& type_payloads, |
+ const ObjectIdPayloadMap& id_payloads, |
IncomingNotificationSource source) OVERRIDE { |
+ const ModelTypePayloadMap& type_payloads = |
+ ObjectIdPayloadMapToModelTypePayloadMap(id_payloads); |
for (ModelTypePayloadMap::const_iterator it = |
type_payloads.begin(); it != type_payloads.end(); ++it) { |
LOG(INFO) << (source == REMOTE_NOTIFICATION ? "Remote" : "Local") |
@@ -233,17 +235,17 @@ int SyncListenNotificationsMain(int argc, char* argv[]) { |
scoped_ptr<SyncNotifier> sync_notifier( |
sync_notifier_factory.CreateSyncNotifier()); |
NotificationPrinter notification_printer; |
- sync_notifier->AddObserver(¬ification_printer); |
const char kUniqueId[] = "fake_unique_id"; |
sync_notifier->SetUniqueId(kUniqueId); |
sync_notifier->UpdateCredentials(email, token); |
// Listen for notifications for all known types. |
- sync_notifier->UpdateEnabledTypes(ModelTypeSet::All()); |
+ sync_notifier->UpdateRegisteredIds( |
+ ¬ification_printer, ModelTypeSetToObjectIdSet(ModelTypeSet::All())); |
ui_loop.Run(); |
- sync_notifier->RemoveObserver(¬ification_printer); |
+ sync_notifier->UpdateRegisteredIds(¬ification_printer, ObjectIdSet()); |
io_thread.Stop(); |
return 0; |
} |