* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
import akka.pattern.Patterns;
import akka.util.Timeout;
import com.google.common.base.Predicate;
import akka.pattern.Patterns;
import akka.util.Timeout;
import com.google.common.base.Predicate;
private static final String ARE_YOU_READY = "ARE_YOU_READY";
public static final String GET_ALL_MESSAGES = "messages";
private static final String ARE_YOU_READY = "ARE_YOU_READY";
public static final String GET_ALL_MESSAGES = "messages";
} else if (GET_ALL_MESSAGES.equals(message)) {
getSender().tell(new ArrayList<>(messages), getSelf());
} else if (CLEAR_MESSAGES.equals(message)) {
} else if (GET_ALL_MESSAGES.equals(message)) {
getSender().tell(new ArrayList<>(messages), getSelf());
} else if (CLEAR_MESSAGES.equals(message)) {
- private static List<Object> getAllMessages(final ActorRef actor) {
- FiniteDuration operationDuration = Duration.create(5, TimeUnit.SECONDS);
+ public static List<Object> getAllMessages(final ActorRef actor) {
+ FiniteDuration operationDuration = FiniteDuration.create(5, TimeUnit.SECONDS);
Timeout operationTimeout = new Timeout(operationDuration);
Future<Object> future = Patterns.ask(actor, GET_ALL_MESSAGES, operationTimeout);
Timeout operationTimeout = new Timeout(operationDuration);
Future<Object> future = Patterns.ask(actor, GET_ALL_MESSAGES, operationTimeout);
- throw new AssertionError("Did not receive message of type " + clazz, lastEx);
+ throw new AssertionError(actor + ": Did not receive message of type " + clazz + ", Actual received was "
+ + getAllMessages(actor), lastEx);
for (int i = 0; i < 10; i++) {
try {
Await.ready(Patterns.ask(actor, ARE_YOU_READY, timeout), duration);
for (int i = 0; i < 10; i++) {
try {
Await.ready(Patterns.ask(actor, ARE_YOU_READY, timeout), duration);