- private void processed(Object message, long messageElapseTimeInNanos){
- if(!enabled) {
- return;
- }
- if(!expectedMessageClass.isInstance(message)){
- this.messagesSinceLastExpectedMessage.add(new MessageProcessingTime(message.getClass(), messageElapseTimeInNanos));
- }
- }
-
- public List<MessageProcessingTime> getMessagesSinceLastExpectedMessage(){
- return ImmutableList.copyOf(this.messagesSinceLastExpectedMessage);
- }
-
- public static class MessageProcessingTime {
- private final Class<?> messageClass;
- private final long elapsedTimeInNanos;
-
- MessageProcessingTime(Class<?> messageClass, long elapsedTimeInNanos){
- this.messageClass = messageClass;
- this.elapsedTimeInNanos = elapsedTimeInNanos;
- }
-
- @Override
- public String toString() {
- return "MessageProcessingTime{" +
- "messageClass=" + messageClass.getSimpleName() +
- ", elapsedTimeInMillis=" + TimeUnit.NANOSECONDS.toMillis(elapsedTimeInNanos) +
- '}';
- }
-
- public Class<?> getMessageClass() {
- return messageClass;
- }
-
- public long getElapsedTimeInNanos() {
- return elapsedTimeInNanos;
+ void processed(final Object message, final long messageElapseTimeInNanos) {
+ if (expectedMessageWatch.isRunning() && !expectedMessageClass.isInstance(message)) {
+ messagesSinceLastExpectedMessage.add(new MessageProcessingTime(message.getClass(),
+ messageElapseTimeInNanos));