Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

make MongoBridge#writeMessageCounts() access synced

  • Loading branch information...
commit 78e3ff432789ad3c79900c72534c32f57cafe818 1 parent d69c505
@lennartkoopmann lennartkoopmann authored
Showing with 1 addition and 1 deletion.
  1. +1 −1  src/main/java/org/graylog2/database/MongoBridge.java
View
2  src/main/java/org/graylog2/database/MongoBridge.java
@@ -106,7 +106,7 @@ public void setSimpleServerValue(String key, Object value) {
coll.update(query, update, true, false);
}
- public void writeMessageCounts(int total, Map<String, Integer> streams, Map<String, Integer> hosts) {
+ public synchronized void writeMessageCounts(int total, Map<String, Integer> streams, Map<String, Integer> hosts) {
BasicDBObject obj = new BasicDBObject();
obj.put("timestamp", Tools.getUTCTimestamp());
obj.put("total", total);
Please sign in to comment.
Something went wrong with that request. Please try again.