diff --git a/kombu/clocks.py b/kombu/clocks.py index 612ddb49..a9862382 100644 --- a/kombu/clocks.py +++ b/kombu/clocks.py @@ -107,8 +107,8 @@ class LamportClock(object): def adjust(self, other): with self.mutex: - self.value = max(self.value, other) + 1 - return self.value + value = self.value = max(self.value, other) + 1 + return value def forward(self): with self.mutex: