prority small first out queue

yunheli · yunheli · commit daa5a21f02ea · 2018-01-01T16:08:56.000+08:00
diff --git a/platform-core/src/main/java/com/flow/platform/core/queue/PriorityMessage.java b/platform-core/src/main/java/com/flow/platform/core/queue/PriorityMessage.java
@@ -48,6 +48,6 @@ public Long getPriority() {
 
     @Override
     public int compareTo(PriorityQueueItem o) {
-        return o.getPriority().compareTo(getPriority());
+        return getPriority().compareTo(o.getPriority());
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -48,6 +48,6 @@ public Long getPriority() {`
`48`	`48`
`49`	`49`	`@Override`
`50`	`50`	`public int compareTo(PriorityQueueItem o) {`
`51`		`- return o.getPriority().compareTo(getPriority());`
	`51`	`+ return getPriority().compareTo(o.getPriority());`
`52`	`52`	`}`
`53`	`53`	`}`