From 560b9b0b723cadc79b147b3a06001d36c17ab7fd Mon Sep 17 00:00:00 2001
From: Daniel Stonier <d.stonier@gmail.com>
Date: Thu, 12 Sep 2013 23:36:44 +0900
Subject: [PATCH] test_ros -> rosjava_test_msgs
---
CMakeLists.txt | 2 +-
docs/src/main/sphinx/getting_started.rst | 2 +-
rosjava/build.gradle | 3 +-
.../main/java/org/ros/node/ConnectedNode.java | 4 +-
.../node/service/ServiceIntegrationTest.java | 52 +++++++++----------
.../ros/node/topic/TopicIntegrationTest.java | 18 +++----
rosjava/test/composite_publisher.py | 8 +--
rosjava/test/test_composite_passthrough.py | 4 +-
rosjava/test/test_parameter_client.py | 2 +-
rosjava/test/test_testheader_passthrough.py | 4 +-
rosjava/test/testheader_publisher.py | 8 +--
.../java/org/ros/ParameterServerTestNode.java | 14 ++---
.../java/org/ros/PassthroughTestNode.java | 24 ++++-----
.../ros/rosjava_tutorial_services/Client.java | 10 ++--
.../ros/rosjava_tutorial_services/Server.java | 6 +--
15 files changed, 81 insertions(+), 80 deletions(-)
diff --git a/CMakeLists.txt b/CMakeLists.txt
index c93f34b2..b4c80f6e 100644
--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@@ -1,7 +1,7 @@
cmake_minimum_required(VERSION 2.8.3)
project(rosjava_core)
-find_package(catkin REQUIRED rosjava_tools)
+find_package(catkin REQUIRED rosjava_build_tools)
catkin_rosjava_setup(uploadArchives)
diff --git a/docs/src/main/sphinx/getting_started.rst b/docs/src/main/sphinx/getting_started.rst
index b1f92176..7d7952c3 100644
--- a/docs/src/main/sphinx/getting_started.rst
+++ b/docs/src/main/sphinx/getting_started.rst
@@ -241,7 +241,7 @@ Services
The following class (:javadoc:`org.ros.rosjava_tutorial_services.Server`) is
available from the rosjava_tutorial_services package. In this example, we
create a :javadoc:`org.ros.node.service.ServiceServer` for the
-``test_ros.AddTwoInts`` service. This should feel relatively familiar if you're
+``rosjava_test_msgs.AddTwoInts`` service. This should feel relatively familiar if you're
a ROS veteran.
.. literalinclude:: ../../../../rosjava_tutorial_services/src/main/java/org/ros/rosjava_tutorial_services/Server.java
diff --git a/rosjava/build.gradle b/rosjava/build.gradle
index ba87144c..b2b44a13 100644
--- a/rosjava/build.gradle
+++ b/rosjava/build.gradle
@@ -18,7 +18,8 @@ dependencies {
compile project(':apache_xmlrpc_common')
compile project(':apache_xmlrpc_server')
compile project(':apache_xmlrpc_client')
- compile 'org.ros.rosjava_bootstrap:message_generator:0.1.+'
+ compile 'org.ros.rosjava_bootstrap:message_generation:0.1.+'
+ compile 'org.ros.rosjava_messages:rosjava_test_msgs:0.1.+'
compile 'org.ros.rosjava_messages:rosgraph_msgs:1.9.+'
compile 'org.ros.rosjava_messages:geometry_msgs:1.10.+'
compile 'org.ros.rosjava_messages:nav_msgs:1.10.+'
diff --git a/rosjava/src/main/java/org/ros/node/ConnectedNode.java b/rosjava/src/main/java/org/ros/node/ConnectedNode.java
index ea9753d1..34d6994c 100644
--- a/rosjava/src/main/java/org/ros/node/ConnectedNode.java
+++ b/rosjava/src/main/java/org/ros/node/ConnectedNode.java
@@ -93,7 +93,7 @@ public interface ConnectedNode extends Node {
* @param serviceName
* the name of the service
* @param serviceType
- * the type of the service (e.g. "test_ros/AddTwoInts")
+ * the type of the service (e.g. "rosjava_test_msgs/AddTwoInts")
* @param serviceResponseBuilder
* called for every request to build a response
* @return a {@link ServiceServer}
@@ -139,7 +139,7 @@ public interface ConnectedNode extends Node {
* @param serviceName
* the name of the service
* @param serviceType
- * the type of the service (e.g. "test_ros/AddTwoInts")
+ * the type of the service (e.g. "rosjava_test_msgs/AddTwoInts")
* @return a {@link ServiceClient}
* @throws ServiceNotFoundException
* thrown if no matching service could be found
diff --git a/rosjava/src/test/java/org/ros/node/service/ServiceIntegrationTest.java b/rosjava/src/test/java/org/ros/node/service/ServiceIntegrationTest.java
index a338ff53..edba5933 100644
--- a/rosjava/src/test/java/org/ros/node/service/ServiceIntegrationTest.java
+++ b/rosjava/src/test/java/org/ros/node/service/ServiceIntegrationTest.java
@@ -43,7 +43,7 @@ public class ServiceIntegrationTest extends RosTest {
@Test
public void testPesistentServiceConnection() throws Exception {
- final CountDownServiceServerListener<test_ros.AddTwoIntsRequest, test_ros.AddTwoIntsResponse> countDownServiceServerListener =
+ final CountDownServiceServerListener<rosjava_test_msgs.AddTwoIntsRequest, rosjava_test_msgs.AddTwoIntsResponse> countDownServiceServerListener =
CountDownServiceServerListener.newDefault();
nodeMainExecutor.execute(new AbstractNodeMain() {
@Override
@@ -53,20 +53,20 @@ public class ServiceIntegrationTest extends RosTest {
@Override
public void onStart(final ConnectedNode connectedNode) {
- ServiceServer<test_ros.AddTwoIntsRequest, test_ros.AddTwoIntsResponse> serviceServer =
+ ServiceServer<rosjava_test_msgs.AddTwoIntsRequest, rosjava_test_msgs.AddTwoIntsResponse> serviceServer =
connectedNode
.newServiceServer(
SERVICE_NAME,
- test_ros.AddTwoInts._TYPE,
- new ServiceResponseBuilder<test_ros.AddTwoIntsRequest, test_ros.AddTwoIntsResponse>() {
+ rosjava_test_msgs.AddTwoInts._TYPE,
+ new ServiceResponseBuilder<rosjava_test_msgs.AddTwoIntsRequest, rosjava_test_msgs.AddTwoIntsResponse>() {
@Override
- public void build(test_ros.AddTwoIntsRequest request,
- test_ros.AddTwoIntsResponse response) {
+ public void build(rosjava_test_msgs.AddTwoIntsRequest request,
+ rosjava_test_msgs.AddTwoIntsResponse response) {
response.setSum(request.getA() + request.getB());
}
});
try {
- connectedNode.newServiceServer(SERVICE_NAME, test_ros.AddTwoInts._TYPE, null);
+ connectedNode.newServiceServer(SERVICE_NAME, rosjava_test_msgs.AddTwoInts._TYPE, null);
fail();
} catch (DuplicateServiceException e) {
// Only one ServiceServer with a given name can be created.
@@ -86,23 +86,23 @@ public class ServiceIntegrationTest extends RosTest {
@Override
public void onStart(ConnectedNode connectedNode) {
- ServiceClient<test_ros.AddTwoIntsRequest, test_ros.AddTwoIntsResponse> serviceClient;
+ ServiceClient<rosjava_test_msgs.AddTwoIntsRequest, rosjava_test_msgs.AddTwoIntsResponse> serviceClient;
try {
- serviceClient = connectedNode.newServiceClient(SERVICE_NAME, test_ros.AddTwoInts._TYPE);
+ serviceClient = connectedNode.newServiceClient(SERVICE_NAME, rosjava_test_msgs.AddTwoInts._TYPE);
// Test that requesting another client for the same service returns
// the same instance.
ServiceClient<?, ?> duplicate =
- connectedNode.newServiceClient(SERVICE_NAME, test_ros.AddTwoInts._TYPE);
+ connectedNode.newServiceClient(SERVICE_NAME, rosjava_test_msgs.AddTwoInts._TYPE);
assertEquals(serviceClient, duplicate);
} catch (ServiceNotFoundException e) {
throw new RosRuntimeException(e);
}
- test_ros.AddTwoIntsRequest request = serviceClient.newMessage();
+ rosjava_test_msgs.AddTwoIntsRequest request = serviceClient.newMessage();
request.setA(2);
request.setB(2);
- serviceClient.call(request, new ServiceResponseListener<test_ros.AddTwoIntsResponse>() {
+ serviceClient.call(request, new ServiceResponseListener<rosjava_test_msgs.AddTwoIntsResponse>() {
@Override
- public void onSuccess(test_ros.AddTwoIntsResponse response) {
+ public void onSuccess(rosjava_test_msgs.AddTwoIntsResponse response) {
assertEquals(response.getSum(), 4);
latch.countDown();
}
@@ -116,9 +116,9 @@ public class ServiceIntegrationTest extends RosTest {
// Regression test for issue 122.
request.setA(3);
request.setB(3);
- serviceClient.call(request, new ServiceResponseListener<test_ros.AddTwoIntsResponse>() {
+ serviceClient.call(request, new ServiceResponseListener<rosjava_test_msgs.AddTwoIntsResponse>() {
@Override
- public void onSuccess(test_ros.AddTwoIntsResponse response) {
+ public void onSuccess(rosjava_test_msgs.AddTwoIntsResponse response) {
assertEquals(response.getSum(), 6);
latch.countDown();
}
@@ -137,7 +137,7 @@ public class ServiceIntegrationTest extends RosTest {
@Test
public void testRequestFailure() throws Exception {
final String errorMessage = "Error!";
- final CountDownServiceServerListener<test_ros.AddTwoIntsRequest, test_ros.AddTwoIntsResponse> countDownServiceServerListener =
+ final CountDownServiceServerListener<rosjava_test_msgs.AddTwoIntsRequest, rosjava_test_msgs.AddTwoIntsResponse> countDownServiceServerListener =
CountDownServiceServerListener.newDefault();
nodeMainExecutor.execute(new AbstractNodeMain() {
@Override
@@ -147,15 +147,15 @@ public class ServiceIntegrationTest extends RosTest {
@Override
public void onStart(ConnectedNode connectedNode) {
- ServiceServer<test_ros.AddTwoIntsRequest, test_ros.AddTwoIntsResponse> serviceServer =
+ ServiceServer<rosjava_test_msgs.AddTwoIntsRequest, rosjava_test_msgs.AddTwoIntsResponse> serviceServer =
connectedNode
.newServiceServer(
SERVICE_NAME,
- test_ros.AddTwoInts._TYPE,
- new ServiceResponseBuilder<test_ros.AddTwoIntsRequest, test_ros.AddTwoIntsResponse>() {
+ rosjava_test_msgs.AddTwoInts._TYPE,
+ new ServiceResponseBuilder<rosjava_test_msgs.AddTwoIntsRequest, rosjava_test_msgs.AddTwoIntsResponse>() {
@Override
- public void build(test_ros.AddTwoIntsRequest request,
- test_ros.AddTwoIntsResponse response) throws ServiceException {
+ public void build(rosjava_test_msgs.AddTwoIntsRequest request,
+ rosjava_test_msgs.AddTwoIntsResponse response) throws ServiceException {
throw new ServiceException(errorMessage);
}
});
@@ -174,16 +174,16 @@ public class ServiceIntegrationTest extends RosTest {
@Override
public void onStart(ConnectedNode connectedNode) {
- ServiceClient<test_ros.AddTwoIntsRequest, test_ros.AddTwoIntsResponse> serviceClient;
+ ServiceClient<rosjava_test_msgs.AddTwoIntsRequest, rosjava_test_msgs.AddTwoIntsResponse> serviceClient;
try {
- serviceClient = connectedNode.newServiceClient(SERVICE_NAME, test_ros.AddTwoInts._TYPE);
+ serviceClient = connectedNode.newServiceClient(SERVICE_NAME, rosjava_test_msgs.AddTwoInts._TYPE);
} catch (ServiceNotFoundException e) {
throw new RosRuntimeException(e);
}
- test_ros.AddTwoIntsRequest request = serviceClient.newMessage();
- serviceClient.call(request, new ServiceResponseListener<test_ros.AddTwoIntsResponse>() {
+ rosjava_test_msgs.AddTwoIntsRequest request = serviceClient.newMessage();
+ serviceClient.call(request, new ServiceResponseListener<rosjava_test_msgs.AddTwoIntsResponse>() {
@Override
- public void onSuccess(test_ros.AddTwoIntsResponse message) {
+ public void onSuccess(rosjava_test_msgs.AddTwoIntsResponse message) {
fail();
}
diff --git a/rosjava/src/test/java/org/ros/node/topic/TopicIntegrationTest.java b/rosjava/src/test/java/org/ros/node/topic/TopicIntegrationTest.java
index 2c2f5919..d6aa4e59 100644
--- a/rosjava/src/test/java/org/ros/node/topic/TopicIntegrationTest.java
+++ b/rosjava/src/test/java/org/ros/node/topic/TopicIntegrationTest.java
@@ -175,13 +175,13 @@ public class TopicIntegrationTest extends RosTest {
}, nodeConfiguration);
}
- private final class Listener implements MessageListener<test_ros.TestHeader> {
+ private final class Listener implements MessageListener<rosjava_test_msgs.TestHeader> {
private final CountDownLatch latch = new CountDownLatch(10);
- private test_ros.TestHeader lastMessage;
+ private rosjava_test_msgs.TestHeader lastMessage;
@Override
- public void onNewMessage(test_ros.TestHeader message) {
+ public void onNewMessage(rosjava_test_msgs.TestHeader message) {
int seq = message.getHeader().getSeq();
long stamp = message.getHeader().getStamp().totalNsecs();
if (lastMessage != null) {
@@ -210,13 +210,13 @@ public class TopicIntegrationTest extends RosTest {
@Override
public void onStart(final ConnectedNode connectedNode) {
- final Publisher<test_ros.TestHeader> publisher =
- connectedNode.newPublisher("foo", test_ros.TestHeader._TYPE);
+ final Publisher<rosjava_test_msgs.TestHeader> publisher =
+ connectedNode.newPublisher("foo", rosjava_test_msgs.TestHeader._TYPE);
connectedNode.executeCancellableLoop(new CancellableLoop() {
@Override
public void loop() throws InterruptedException {
- test_ros.TestHeader message =
- connectedNode.getTopicMessageFactory().newFromType(test_ros.TestHeader._TYPE);
+ rosjava_test_msgs.TestHeader message =
+ connectedNode.getTopicMessageFactory().newFromType(rosjava_test_msgs.TestHeader._TYPE);
message.getHeader().setStamp(connectedNode.getCurrentTime());
publisher.publish(message);
// There needs to be some time between messages in order to
@@ -236,8 +236,8 @@ public class TopicIntegrationTest extends RosTest {
@Override
public void onStart(ConnectedNode connectedNode) {
- Subscriber<test_ros.TestHeader> subscriber =
- connectedNode.newSubscriber("foo", test_ros.TestHeader._TYPE);
+ Subscriber<rosjava_test_msgs.TestHeader> subscriber =
+ connectedNode.newSubscriber("foo", rosjava_test_msgs.TestHeader._TYPE);
subscriber.addMessageListener(listener, QUEUE_CAPACITY);
}
}, nodeConfiguration);
diff --git a/rosjava/test/composite_publisher.py b/rosjava/test/composite_publisher.py
index 313a66ed..54626ca1 100755
--- a/rosjava/test/composite_publisher.py
+++ b/rosjava/test/composite_publisher.py
@@ -1,14 +1,14 @@
#!/usr/bin/env python
from ros import rospy
-from ros import test_ros
-import test_ros.msg
+from ros import rosjava_test_msgs
+import rosjava_test_msgs.msg
import random
def publisher():
rospy.init_node('composite_publisher')
- pub = rospy.Publisher('composite_in', test_ros.msg.Composite)
+ pub = rospy.Publisher('composite_in', rosjava_test_msgs.msg.Composite)
r = rospy.Rate(10)
- m = test_ros.msg.Composite()
+ m = rosjava_test_msgs.msg.Composite()
m.a.x = random.random() * 10000.
m.a.y = random.random() * 10000.
m.a.z = random.random() * 10000.
diff --git a/rosjava/test/test_composite_passthrough.py b/rosjava/test/test_composite_passthrough.py
index 5014b0c8..53ea068a 100755
--- a/rosjava/test/test_composite_passthrough.py
+++ b/rosjava/test/test_composite_passthrough.py
@@ -38,14 +38,14 @@ NAME = 'composite_passthrough'
import roslib; roslib.load_manifest(PKG)
from ros import rospy
-from ros import test_ros
+from ros import rosjava_test_msgs
from ros import rostest
import sys
import time
import unittest
-from test_ros.msg import Composite
+from rosjava_test_msgs.msg import Composite
class CompositePassthrough(unittest.TestCase):
diff --git a/rosjava/test/test_parameter_client.py b/rosjava/test/test_parameter_client.py
index 7701f5e3..85ee4061 100755
--- a/rosjava/test/test_parameter_client.py
+++ b/rosjava/test/test_parameter_client.py
@@ -48,7 +48,7 @@ import time
import unittest
from std_msgs.msg import String, Bool, Int64, Float64
-from test_ros.msg import Composite, CompositeA, CompositeB, TestArrays
+from rosjava_test_msgs.msg import Composite, CompositeA, CompositeB, TestArrays
class TestParameterClient(unittest.TestCase):
diff --git a/rosjava/test/test_testheader_passthrough.py b/rosjava/test/test_testheader_passthrough.py
index 29746b11..b6ca6a8b 100755
--- a/rosjava/test/test_testheader_passthrough.py
+++ b/rosjava/test/test_testheader_passthrough.py
@@ -38,14 +38,14 @@ NAME = 'testheader_passthrough'
import roslib; roslib.load_manifest(PKG)
from ros import rospy
-from ros import test_ros
+from ros import rosjava_test_msgs
from ros import rostest
import sys
import time
import unittest
-from test_ros.msg import TestHeader
+from rosjava_test_msgs.msg import TestHeader
class TestHeaderPassthrough(unittest.TestCase):
diff --git a/rosjava/test/testheader_publisher.py b/rosjava/test/testheader_publisher.py
index 912d8381..276334af 100755
--- a/rosjava/test/testheader_publisher.py
+++ b/rosjava/test/testheader_publisher.py
@@ -1,13 +1,13 @@
#!/usr/bin/env python
from ros import rospy
-from ros import test_ros
-import test_ros.msg
+from ros import rosjava_test_msgs
+import rosjava_test_msgs.msg
def publisher():
rospy.init_node('testheader_publisher')
- pub = rospy.Publisher('test_header_in', test_ros.msg.TestHeader)
+ pub = rospy.Publisher('test_header_in', rosjava_test_msgs.msg.TestHeader)
r = rospy.Rate(10)
- m = test_ros.msg.TestHeader()
+ m = rosjava_test_msgs.msg.TestHeader()
m.caller_id = rospy.get_name()
m.header.stamp = rospy.get_rostime()
while not rospy.is_shutdown():
diff --git a/rosjava_test/src/main/java/org/ros/ParameterServerTestNode.java b/rosjava_test/src/main/java/org/ros/ParameterServerTestNode.java
index 6c139d07..523f0b08 100644
--- a/rosjava_test/src/main/java/org/ros/ParameterServerTestNode.java
+++ b/rosjava_test/src/main/java/org/ros/ParameterServerTestNode.java
@@ -55,10 +55,10 @@ public class ParameterServerTestNode extends AbstractNodeMain {
connectedNode.newPublisher("bool", std_msgs.Bool._TYPE);
final Publisher<std_msgs.Float64> pub_float =
connectedNode.newPublisher("float", std_msgs.Float64._TYPE);
- final Publisher<test_ros.Composite> pub_composite =
- connectedNode.newPublisher("composite", test_ros.Composite._TYPE);
- final Publisher<test_ros.TestArrays> pub_list =
- connectedNode.newPublisher("list", test_ros.TestArrays._TYPE);
+ final Publisher<rosjava_test_msgs.Composite> pub_composite =
+ connectedNode.newPublisher("composite", rosjava_test_msgs.Composite._TYPE);
+ final Publisher<rosjava_test_msgs.TestArrays> pub_list =
+ connectedNode.newPublisher("list", rosjava_test_msgs.TestArrays._TYPE);
ParameterTree param = connectedNode.getParameterTree();
@@ -90,8 +90,8 @@ public class ParameterServerTestNode extends AbstractNodeMain {
float_m.setData(param.getDouble(resolver.resolve("float")));
log.info("float: " + float_m.getData());
- final test_ros.Composite composite_m =
- topicMessageFactory.newFromType(test_ros.Composite._TYPE);
+ final rosjava_test_msgs.Composite composite_m =
+ topicMessageFactory.newFromType(rosjava_test_msgs.Composite._TYPE);
Map composite_map = param.getMap(resolver.resolve("composite"));
composite_m.getA().setW((Double) ((Map) composite_map.get("a")).get("w"));
composite_m.getA().setX((Double) ((Map) composite_map.get("a")).get("x"));
@@ -101,7 +101,7 @@ public class ParameterServerTestNode extends AbstractNodeMain {
composite_m.getB().setY((Double) ((Map) composite_map.get("b")).get("y"));
composite_m.getB().setZ((Double) ((Map) composite_map.get("b")).get("z"));
- final test_ros.TestArrays list_m = topicMessageFactory.newFromType(test_ros.TestArrays._TYPE);
+ final rosjava_test_msgs.TestArrays list_m = topicMessageFactory.newFromType(rosjava_test_msgs.TestArrays._TYPE);
// only using the integer part for easier (non-float) comparison
@SuppressWarnings("unchecked")
List<Integer> list = (List<Integer>) param.getList(resolver.resolve("list"));
diff --git a/rosjava_test/src/main/java/org/ros/PassthroughTestNode.java b/rosjava_test/src/main/java/org/ros/PassthroughTestNode.java
index 9ad05183..2d251bdd 100644
--- a/rosjava_test/src/main/java/org/ros/PassthroughTestNode.java
+++ b/rosjava_test/src/main/java/org/ros/PassthroughTestNode.java
@@ -67,31 +67,31 @@ public class PassthroughTestNode extends AbstractNodeMain {
int64Subscriber.addMessageListener(int64_cb);
// TestHeader pass through
- final Publisher<test_ros.TestHeader> pub_header =
- connectedNode.newPublisher("test_header_out", test_ros.TestHeader._TYPE);
- MessageListener<test_ros.TestHeader> header_cb = new MessageListener<test_ros.TestHeader>() {
+ final Publisher<rosjava_test_msgs.TestHeader> pub_header =
+ connectedNode.newPublisher("test_header_out", rosjava_test_msgs.TestHeader._TYPE);
+ MessageListener<rosjava_test_msgs.TestHeader> header_cb = new MessageListener<rosjava_test_msgs.TestHeader>() {
@Override
- public void onNewMessage(test_ros.TestHeader m) {
+ public void onNewMessage(rosjava_test_msgs.TestHeader m) {
m.setOrigCallerId(m.getCallerId());
m.setCallerId(connectedNode.getName().toString());
pub_header.publish(m);
}
};
- Subscriber<test_ros.TestHeader> testHeaderSubscriber =
- connectedNode.newSubscriber("test_header_in", "test_ros/TestHeader");
+ Subscriber<rosjava_test_msgs.TestHeader> testHeaderSubscriber =
+ connectedNode.newSubscriber("test_header_in", "rosjava_test_msgs/TestHeader");
testHeaderSubscriber.addMessageListener(header_cb);
// TestComposite pass through
- final Publisher<test_ros.Composite> pub_composite =
- connectedNode.newPublisher("composite_out", "test_ros/Composite");
- MessageListener<test_ros.Composite> composite_cb = new MessageListener<test_ros.Composite>() {
+ final Publisher<rosjava_test_msgs.Composite> pub_composite =
+ connectedNode.newPublisher("composite_out", "rosjava_test_msgs/Composite");
+ MessageListener<rosjava_test_msgs.Composite> composite_cb = new MessageListener<rosjava_test_msgs.Composite>() {
@Override
- public void onNewMessage(test_ros.Composite m) {
+ public void onNewMessage(rosjava_test_msgs.Composite m) {
pub_composite.publish(m);
}
};
- Subscriber<test_ros.Composite> compositeSubscriber =
- connectedNode.newSubscriber("composite_in", "test_ros/Composite");
+ Subscriber<rosjava_test_msgs.Composite> compositeSubscriber =
+ connectedNode.newSubscriber("composite_in", "rosjava_test_msgs/Composite");
compositeSubscriber.addMessageListener(composite_cb);
}
}
diff --git a/rosjava_tutorial_services/src/main/java/org/ros/rosjava_tutorial_services/Client.java b/rosjava_tutorial_services/src/main/java/org/ros/rosjava_tutorial_services/Client.java
index 0c3d5fc9..1f1e69a6 100644
--- a/rosjava_tutorial_services/src/main/java/org/ros/rosjava_tutorial_services/Client.java
+++ b/rosjava_tutorial_services/src/main/java/org/ros/rosjava_tutorial_services/Client.java
@@ -40,18 +40,18 @@ public class Client extends AbstractNodeMain {
@Override
public void onStart(final ConnectedNode connectedNode) {
- ServiceClient<test_ros.AddTwoIntsRequest, test_ros.AddTwoIntsResponse> serviceClient;
+ ServiceClient<rosjava_test_msgs.AddTwoIntsRequest, rosjava_test_msgs.AddTwoIntsResponse> serviceClient;
try {
- serviceClient = connectedNode.newServiceClient("add_two_ints", test_ros.AddTwoInts._TYPE);
+ serviceClient = connectedNode.newServiceClient("add_two_ints", rosjava_test_msgs.AddTwoInts._TYPE);
} catch (ServiceNotFoundException e) {
throw new RosRuntimeException(e);
}
- final test_ros.AddTwoIntsRequest request = serviceClient.newMessage();
+ final rosjava_test_msgs.AddTwoIntsRequest request = serviceClient.newMessage();
request.setA(2);
request.setB(2);
- serviceClient.call(request, new ServiceResponseListener<test_ros.AddTwoIntsResponse>() {
+ serviceClient.call(request, new ServiceResponseListener<rosjava_test_msgs.AddTwoIntsResponse>() {
@Override
- public void onSuccess(test_ros.AddTwoIntsResponse response) {
+ public void onSuccess(rosjava_test_msgs.AddTwoIntsResponse response) {
connectedNode.getLog().info(
String.format("%d + %d = %d", request.getA(), request.getB(), response.getSum()));
}
diff --git a/rosjava_tutorial_services/src/main/java/org/ros/rosjava_tutorial_services/Server.java b/rosjava_tutorial_services/src/main/java/org/ros/rosjava_tutorial_services/Server.java
index a53109fe..5a313bfb 100644
--- a/rosjava_tutorial_services/src/main/java/org/ros/rosjava_tutorial_services/Server.java
+++ b/rosjava_tutorial_services/src/main/java/org/ros/rosjava_tutorial_services/Server.java
@@ -37,11 +37,11 @@ public class Server extends AbstractNodeMain {
@Override
public void onStart(ConnectedNode connectedNode) {
- connectedNode.newServiceServer("add_two_ints", test_ros.AddTwoInts._TYPE,
- new ServiceResponseBuilder<test_ros.AddTwoIntsRequest, test_ros.AddTwoIntsResponse>() {
+ connectedNode.newServiceServer("add_two_ints", rosjava_test_msgs.AddTwoInts._TYPE,
+ new ServiceResponseBuilder<rosjava_test_msgs.AddTwoIntsRequest, rosjava_test_msgs.AddTwoIntsResponse>() {
@Override
public void
- build(test_ros.AddTwoIntsRequest request, test_ros.AddTwoIntsResponse response) {
+ build(rosjava_test_msgs.AddTwoIntsRequest request, rosjava_test_msgs.AddTwoIntsResponse response) {
response.setSum(request.getA() + request.getB());
}
});
--
GitLab