blob: 316836838777c6dac80259a2daf6b07231d15d30 [file] [log] [blame]
Madan Jampani2206e012014-10-06 21:04:20 -07001package org.onlab.onos.store.device.impl;
2
3import org.onlab.onos.store.cluster.messaging.MessageSubject;
4
Yuta HIGUCHI9ee60f62014-10-09 10:00:01 -07005// TODO: add prefix to assure uniqueness.
Madan Jampani2206e012014-10-06 21:04:20 -07006/**
Madan Jampani25322532014-10-08 11:20:38 -07007 * MessageSubjects used by GossipDeviceStore peer-peer communication.
Madan Jampani2206e012014-10-06 21:04:20 -07008 */
9public final class GossipDeviceStoreMessageSubjects {
10
11 private GossipDeviceStoreMessageSubjects() {}
12
13 public static final MessageSubject DEVICE_UPDATE = new MessageSubject("peer-device-update");
Madan Jampani25322532014-10-08 11:20:38 -070014 public static final MessageSubject DEVICE_OFFLINE = new MessageSubject("peer-device-offline");
Madan Jampani3fc72ed2014-10-08 12:50:27 -070015 public static final MessageSubject DEVICE_REMOVED = new MessageSubject("peer-device-removed");
Madan Jampani2206e012014-10-06 21:04:20 -070016 public static final MessageSubject PORT_UPDATE = new MessageSubject("peer-port-update");
17 public static final MessageSubject PORT_STATUS_UPDATE = new MessageSubject("peer-port-status-update");
Yuta HIGUCHI9ee60f62014-10-09 10:00:01 -070018
19 public static final MessageSubject DEVICE_ADVERTISE = new MessageSubject("peer-device-advertisements");
20 // to be used with 3-way anti-entropy process
21 public static final MessageSubject DEVICE_REQUEST = new MessageSubject("peer-device-request");
Madan Jampani2206e012014-10-06 21:04:20 -070022}