[jboss-cvs] JBossRemoting/src/main/org/jboss/remoting ...
Ron Sigal
ron_sigal at yahoo.com
Wed Dec 13 20:00:09 EST 2006
User: rsigal
Date: 06/12/13 20:00:09
Modified: src/main/org/jboss/remoting Tag: remoting_2_x
ServerInvoker.java
Log:
JBREM-650: Made handleInternalInvocation() protected.
Revision Changes Path
No revision
No revision
1.52.2.5 +12 -3 JBossRemoting/src/main/org/jboss/remoting/ServerInvoker.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: ServerInvoker.java
===================================================================
RCS file: /cvsroot/jboss/JBossRemoting/src/main/org/jboss/remoting/ServerInvoker.java,v
retrieving revision 1.52.2.4
retrieving revision 1.52.2.5
diff -u -b -r1.52.2.4 -r1.52.2.5
--- ServerInvoker.java 9 Nov 2006 20:33:58 -0000 1.52.2.4
+++ ServerInvoker.java 14 Dec 2006 01:00:09 -0000 1.52.2.5
@@ -58,7 +58,7 @@
*
* @author <a href="mailto:jhaynie at vocalocity.net">Jeff Haynie</a>
* @author <a href="mailto:tom.elrod at jboss.com">Tom Elrod</a>
- * @version $Revision: 1.52.2.4 $
+ * @version $Revision: 1.52.2.5 $
*/
public abstract class ServerInvoker extends AbstractInvoker implements ServerInvokerMBean
{
@@ -1025,6 +1025,13 @@
}
else
{
+ log.error(this + ": not started");
+ log.error("request: " + invocation.getParameter());
+ if (invocation.getParameter() instanceof InternalInvocation)
+ {
+ InternalInvocation ii = (InternalInvocation) invocation.getParameter();
+ log.error("internal invocation: " + ii.getMethodName());
+ }
throw new InvalidStateException("Can not process invocation request since is not in started state.");
}
}
@@ -1155,7 +1162,7 @@
* @return
* @throws Throwable
*/
- private Object handleInternalInvocation(InternalInvocation param,
+ protected Object handleInternalInvocation(InternalInvocation param,
InvocationRequest invocation,
ServerInvocationHandler handler)
throws Throwable
@@ -1405,7 +1412,7 @@
public void start() throws IOException
{
started = true;
- log.debug("Invoker started for locator: " + getLocator());
+ log.debug(this + ": Invoker started for locator: " + getLocator());
}
/**
@@ -1423,6 +1430,7 @@
*/
public void stop()
{
+ log.info(this + ": stopping");
started = false;
Iterator it = callbackHandlers.values().iterator();
@@ -1431,6 +1439,7 @@
ServerInvokerCallbackHandler callbackHandler = (ServerInvokerCallbackHandler) it.next();
callbackHandler.destroy();
}
+ log.info(this + ": stopped");
}
/**
More information about the jboss-cvs-commits
mailing list