Skip to content
Snippets Groups Projects
Commit f3abd806 authored by Ernesto Corbellini's avatar Ernesto Corbellini
Browse files

Modified sending loop in test client.

Added a cancel demo.
parent a65e7fb6
Branches
Tags
No related merge requests found
...@@ -27,28 +27,44 @@ public class TestClient extends AbstractNodeMain implements ActionClientListener ...@@ -27,28 +27,44 @@ public class TestClient extends AbstractNodeMain implements ActionClientListener
@Override @Override
public void onStart(ConnectedNode node) { public void onStart(ConnectedNode node) {
ac = new ActionClient<FibonacciActionGoal, FibonacciActionFeedback, FibonacciActionResult>(node, "/fibonacci", FibonacciActionGoal._TYPE, FibonacciActionFeedback._TYPE, FibonacciActionResult._TYPE); ac = new ActionClient<FibonacciActionGoal, FibonacciActionFeedback, FibonacciActionResult>(node, "/fibonacci", FibonacciActionGoal._TYPE, FibonacciActionFeedback._TYPE, FibonacciActionResult._TYPE);
FibonacciActionGoal goalMessage;
int repeat = 3; int repeat = 3;
int i;
String goalId = "fibonacci_test_";
// Attach listener for the callbacks // Attach listener for the callbacks
ac.attachListener(this); ac.attachListener(this);
// Create Fibonacci goal message // Create Fibonacci goal message
FibonacciActionGoal goalMessage = (FibonacciActionGoal)ac.newGoalMessage(); //goalMessage = (FibonacciActionGoal)ac.newGoalMessage();
FibonacciGoal fibonacciGoal = goalMessage.getGoal(); //FibonacciGoal fibonacciGoal = goalMessage.getGoal();
// set Fibonacci parameter // set Fibonacci parameter
fibonacciGoal.setOrder(6); //fibonacciGoal.setOrder(6);
while (repeat > 0) { for (i = 0; i < repeat; i++) {
sleep(10000); sleep(10000);
System.out.println("Sending goal #" + repeat + "..."); System.out.println("Sending goal #" + i + "...");
ac.sendGoal(goalMessage); goalMessage = (FibonacciActionGoal)ac.newGoalMessage();
goalMessage.getGoal().setOrder(i);
ac.sendGoal(goalMessage, goalId + i);
System.out.println("Goal sent."); System.out.println("Goal sent.");
//while(!resultReceived) sleep(100);
resultReceived = false; resultReceived = false;
repeat--;
} }
// send another message and cancel it
goalId += i;
goalMessage = (FibonacciActionGoal)ac.newGoalMessage();
goalMessage.getGoal().setOrder(i);
System.out.println("Sending goal ID: " + goalId + "...");
ac.sendGoal(goalMessage, goalId);
System.out.println("Goal sent.");
sleep(2000);
System.out.println("Cancelling goal ID: " + goalId);
GoalID gid = ac.getGoalId(goalMessage);
ac.sendCancel(gid);
sleep(10000);
System.exit(0); System.exit(0);
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment