Using IFast and IReliable which are child marker interfaces to

IMessageSender.

Author: menacher

jetclient/src/main/java/org/menacheri/jetclient/app/ISession.java

@@ -3,6 +3,8 @@
 import java.util.List;
 
 import org.menacheri.jetclient.communication.IMessageSender;
+import org.menacheri.jetclient.communication.IMessageSender.IFast;
+import org.menacheri.jetclient.communication.IMessageSender.IReliable;
 import org.menacheri.jetclient.event.Events;
 import org.menacheri.jetclient.event.IEvent;
 import org.menacheri.jetclient.event.IEventDispatcher;
@@ -86,11 +88,11 @@ public interface ISession
 
 	void close();
 
-	void setUdpMessageSender(IMessageSender udpMessageSender);
+	void setUdpMessageSender(IFast udpMessageSender);
 
-	IMessageSender getUdpMessageSender();
+	IFast getUdpMessageSender();
 
-	void setTcpMessageSender(IMessageSender tcpMessageSender);
+	void setTcpMessageSender(IReliable tcpMessageSender);
 
-	IMessageSender getTcpMessageSender();
+	IReliable getTcpMessageSender();
 }

jetclient/src/main/java/org/menacheri/jetclient/app/impl/Session.java

@@ -5,7 +5,8 @@
 import java.util.Map;
 
 import org.menacheri.jetclient.app.ISession;
-import org.menacheri.jetclient.communication.IMessageSender;
+import org.menacheri.jetclient.communication.IMessageSender.IFast;
+import org.menacheri.jetclient.communication.IMessageSender.IReliable;
 import org.menacheri.jetclient.event.Events;
 import org.menacheri.jetclient.event.IEvent;
 import org.menacheri.jetclient.event.IEventDispatcher;
@@ -53,8 +54,8 @@ public class Session implements ISession
 
 	protected boolean isUDPEnabled;
 
-	protected IMessageSender tcpMessageSender;
-	protected IMessageSender udpMessageSender;
+	protected IReliable tcpMessageSender;
+	protected IFast udpMessageSender;
 
 	protected Session(SessionBuilder sessionBuilder)
 	{
@@ -318,25 +319,25 @@ public Map<String, Object> getSessionAttributes()
 	}
 
 	@Override
-	public IMessageSender getTcpMessageSender()
+	public IReliable getTcpMessageSender()
 	{
 		return tcpMessageSender;
 	}
 
 	@Override
-	public void setTcpMessageSender(IMessageSender tcpMessageSender)
+	public void setTcpMessageSender(IReliable tcpMessageSender)
 	{
 		this.tcpMessageSender = tcpMessageSender;
 	}
 
 	@Override
-	public IMessageSender getUdpMessageSender()
+	public IFast getUdpMessageSender()
 	{
 		return udpMessageSender;
 	}
 
 	@Override
-	public void setUdpMessageSender(IMessageSender udpMessageSender)
+	public void setUdpMessageSender(IFast udpMessageSender)
 	{
 		this.udpMessageSender = udpMessageSender;
 	}

jetclient/src/main/java/org/menacheri/jetclient/app/impl/SessionFactory.java

@@ -14,7 +14,8 @@
 import org.menacheri.jetclient.app.ISession;
 import org.menacheri.jetclient.app.impl.Session.SessionBuilder;
 import org.menacheri.jetclient.communication.IMessageBuffer;
-import org.menacheri.jetclient.communication.IMessageSender;
+import org.menacheri.jetclient.communication.IMessageSender.IFast;
+import org.menacheri.jetclient.communication.IMessageSender.IReliable;
 import org.menacheri.jetclient.communication.NettyTCPMessageSender;
 import org.menacheri.jetclient.communication.NettyUDPMessageSender;
 import org.menacheri.jetclient.event.Events;
@@ -144,7 +145,7 @@ public int getEventType()
 				}
 			};
 			session.addHandler(startEventHandler);
-			IMessageSender udpMessageSender = new NettyUDPMessageSender(
+			IFast udpMessageSender = new NettyUDPMessageSender(
 					udpClient.getServerAddress(), datagramChannel);
 			session.setUdpMessageSender(udpMessageSender);
 		}
@@ -157,7 +158,7 @@ public int getEventType()
 		// This will in turn invoke the startEventHandler when server sends
 		// Events.START event.
 		Channel channel = tcpClient.connect(tcpFactory, loginEvent);
-		IMessageSender tcpMessageSender = new NettyTCPMessageSender(channel);
+		IReliable tcpMessageSender = new NettyTCPMessageSender(channel);
 		session.setTcpMessageSender(tcpMessageSender);
 	}