import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import org.junit.Assert;
-import org.opendaylight.controller.cluster.raft.SerializationUtils;
import scala.concurrent.Await;
import scala.concurrent.Future;
import scala.concurrent.duration.Duration;
} else if(CLEAR_MESSAGES.equals(message)) {
clear();
} else if(message != null) {
- messages.add(SerializationUtils.fromSerializable(message));
+ messages.add(message);
}
}