Renamed IOLoop & Netty to *MessagingManager for consistency.
Change-Id: Id8859e24d0c7ac7f948516388069639093bad524
diff --git a/utils/netty/src/main/java/org/onlab/netty/NettyMessagingService.java b/utils/netty/src/main/java/org/onlab/netty/NettyMessagingManager.java
similarity index 98%
rename from utils/netty/src/main/java/org/onlab/netty/NettyMessagingService.java
rename to utils/netty/src/main/java/org/onlab/netty/NettyMessagingManager.java
index eeba05e..bfc1c70 100644
--- a/utils/netty/src/main/java/org/onlab/netty/NettyMessagingService.java
+++ b/utils/netty/src/main/java/org/onlab/netty/NettyMessagingManager.java
@@ -65,7 +65,7 @@
/**
* Implementation of MessagingService based on <a href="http://netty.io/">Netty</a> framework.
*/
-public class NettyMessagingService implements MessagingService {
+public class NettyMessagingManager implements MessagingService {
private final Logger log = LoggerFactory.getLogger(getClass());
@@ -111,15 +111,15 @@
clientChannelClass = NioSocketChannel.class;
}
- public NettyMessagingService(IpAddress ip, int port) {
+ public NettyMessagingManager(IpAddress ip, int port) {
localEp = new Endpoint(ip, port);
}
- public NettyMessagingService() {
+ public NettyMessagingManager() {
this(8080);
}
- public NettyMessagingService(int port) {
+ public NettyMessagingManager(int port) {
try {
localEp = new Endpoint(IpAddress.valueOf(InetAddress.getLocalHost()), port);
} catch (UnknownHostException e) {
diff --git a/utils/netty/src/test/java/org/onlab/netty/PingPongTest.java b/utils/netty/src/test/java/org/onlab/netty/PingPongTest.java
index 61d8541..53a36e3 100644
--- a/utils/netty/src/test/java/org/onlab/netty/PingPongTest.java
+++ b/utils/netty/src/test/java/org/onlab/netty/PingPongTest.java
@@ -38,8 +38,8 @@
@Ignore("Turning off fragile test")
@Test
public void testPingPong() throws Exception {
- NettyMessagingService pinger = new NettyMessagingService(8085);
- NettyMessagingService ponger = new NettyMessagingService(9086);
+ NettyMessagingManager pinger = new NettyMessagingManager(8085);
+ NettyMessagingManager ponger = new NettyMessagingManager(9086);
try {
pinger.activate();
ponger.activate();