_resourceEvents = Nil
}
+ def pingResourceEventStore(): Unit = {
+ // We are always live and kicking...
+ }
+
def insertResourceEvent(event: ResourceEventModel) = {
val localEvent = createResourceEventFromOther(event)
_resourceEvents ::= localEvent
StdIMEvent.fromOther(event)
}
+ def pingIMEventStore(): Unit = {
+ }
+
+
def insertIMEvent(event: IMEventModel) = {
val localEvent = createIMEventFromOther(event)
imEventById += (event.id -> localEvent)
MongoDBResourceEvent.fromOther(event, null)
}
+ def pingResourceEventStore(): Unit = {
+ MongoDBStore.ping(mongo)
+ }
+
def insertResourceEvent(event: ResourceEventModel) = {
val localEvent = MongoDBResourceEvent.fromOther(event, new ObjectId().toStringMongod)
MongoDBStore.insertObject(localEvent, resourceEvents, MongoDBStore.jsonSupportToDBObject)
MongoDBStore.createIMEventFromOther(event)
}
+ def pingIMEventStore(): Unit = {
+ MongoDBStore.ping(mongo)
+ }
+
def insertIMEvent(event: IMEventModel): IMEvent = {
val localEvent = MongoDBIMEvent.fromOther(event, new ObjectId().toStringMongod)
MongoDBStore.insertObject(localEvent, imEvents, MongoDBStore.jsonSupportToDBObject)
PolicyEntry.fromJson(JSON.serialize(dbObj))
}
+ def ping(mongo: Mongo): Unit = {
+ // This requires a network roundtrip
+ mongo.isLocked
+ }
+
def findBy[A >: Null <: AnyRef](name: String,
value: String,
collection: DBCollection,