You are viewing a plain text version of this content. The canonical link for it is here.
Posted to scm@geronimo.apache.org by jd...@apache.org on 2007/09/22 16:25:08 UTC
svn commit: r578447 - in
/geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport:
Transport.java TransportServer.java base/BaseTransport.java
base/BaseTransportServer.java
Author: jdillon
Date: Sat Sep 22 07:25:07 2007
New Revision: 578447
URL: http://svn.apache.org/viewvc?rev=578447&view=rev
Log:
Expose the Mina service and session bits and the bound/connected status
Modified:
geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/Transport.java
geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/TransportServer.java
geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/base/BaseTransport.java
geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/base/BaseTransportServer.java
Modified: geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/Transport.java
URL: http://svn.apache.org/viewvc/geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/Transport.java?rev=578447&r1=578446&r2=578447&view=diff
==============================================================================
--- geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/Transport.java (original)
+++ geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/Transport.java Sat Sep 22 07:25:07 2007
@@ -26,6 +26,8 @@
import org.apache.geronimo.gshell.remote.message.Message;
import org.apache.mina.common.WriteFuture;
+import org.apache.mina.common.IoService;
+import org.apache.mina.common.IoSession;
/**
* Provides the client-side protocol interface.
@@ -38,7 +40,13 @@
URI getLocalLocation();
+ IoService getService();
+
+ IoSession getSession();
+
void connect() throws Exception;
+
+ boolean isConnected();
void close();
Modified: geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/TransportServer.java
URL: http://svn.apache.org/viewvc/geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/TransportServer.java?rev=578447&r1=578446&r2=578447&view=diff
==============================================================================
--- geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/TransportServer.java (original)
+++ geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/TransportServer.java Sat Sep 22 07:25:07 2007
@@ -21,6 +21,8 @@
import java.net.URI;
+import org.apache.mina.common.IoService;
+
/**
* Provides the server-side protocol interface.
*
@@ -30,7 +32,11 @@
{
URI getLocation();
+ IoService getService();
+
void bind() throws Exception;
+
+ boolean isBound();
void close();
}
Modified: geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/base/BaseTransport.java
URL: http://svn.apache.org/viewvc/geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/base/BaseTransport.java?rev=578447&r1=578446&r2=578447&view=diff
==============================================================================
--- geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/base/BaseTransport.java (original)
+++ geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/base/BaseTransport.java Sat Sep 22 07:25:07 2007
@@ -115,6 +115,10 @@
log.info("Connected");
}
+ public boolean isConnected() {
+ return connected;
+ }
+
public synchronized void close() {
try {
CloseFuture cf = session.close();
@@ -134,6 +138,10 @@
public URI getLocalLocation() {
return localLocation;
+ }
+
+ public IoSession getSession() {
+ return session;
}
public WriteFuture send(final Object msg) throws Exception {
Modified: geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/base/BaseTransportServer.java
URL: http://svn.apache.org/viewvc/geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/base/BaseTransportServer.java?rev=578447&r1=578446&r2=578447&view=diff
==============================================================================
--- geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/base/BaseTransportServer.java (original)
+++ geronimo/sandbox/gshell/trunk/gshell-remote/gshell-remote-common/src/main/java/org/apache/geronimo/gshell/remote/transport/base/BaseTransportServer.java Sat Sep 22 07:25:07 2007
@@ -104,6 +104,10 @@
log.info("Listening on: {}", address);
}
+ public boolean isBound() {
+ return bound;
+ }
+
public synchronized void close() {
try {
acceptor.unbind(address);