thanhbv200585 commented on code in PR #1651:
URL: https://github.com/apache/james-project/pull/1651#discussion_r1273323523
##########
server/queue/queue-pulsar/src/main/scala/org/apache/james/queue/pulsar/PulsarMailQueue.scala:
##########
@@ -97,6 +99,9 @@ class PulsarMailQueue(
import serializers._
type MessageAsJson = String
+ val DATE: Instant = Instant.parse("2023-04-14T10:00:00.00Z")
+ private val CLOCK: UpdatableTickingClock = new UpdatableTickingClock(DATE)
+ private val now: LocalDateTime = LocalDateTime.now(CLOCK)
Review Comment:
I use UpdatableTickingClock to test PulsarMailQueue whether Distributed test
works or not. I will revert to now when test is success
##########
server/queue/queue-pulsar/src/main/scala/org/apache/james/queue/pulsar/PulsarMailQueue.scala:
##########
@@ -97,6 +99,9 @@ class PulsarMailQueue(
import serializers._
type MessageAsJson = String
+ val DATE: Instant = Instant.parse("2023-04-14T10:00:00.00Z")
+ private val CLOCK: UpdatableTickingClock = new UpdatableTickingClock(DATE)
+ private val now: LocalDateTime = LocalDateTime.now(CLOCK)
Review Comment:
I use UpdatableTickingClock to test PulsarMailQueue whether Distributed test
works or not. I will revert to now when test is successful
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
