jboss-remoting-commits
June 2010
jboss-remoting-commits@lists.jboss.org
- 1 participants
- 12 discussions
JBoss Remoting SVN: r5870 - remoting2/branches/2.2/src/main/org/jboss/remoting.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2010-06-15 15:10:28 -0400 (Tue, 15 Jun 2010)
New Revision: 5870
Modified:
remoting2/branches/2.2/src/main/org/jboss/remoting/ServerInvoker.java
Log:
JBREM-1229: Prints old and new locator when InvokerLocator.validateLocator() results in changes.
Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/ServerInvoker.java
===================================================================
--- remoting2/branches/2.2/src/main/org/jboss/remoting/ServerInvoker.java 2010-06-15 08:37:05 UTC (rev 5869)
+++ remoting2/branches/2.2/src/main/org/jboss/remoting/ServerInvoker.java 2010-06-15 19:10:28 UTC (rev 5870)
@@ -1199,6 +1199,10 @@
// need to check invoker locator to see if need to provide binding address (in the case 0.0.0.0 was used)
InvokerLocator originalLocator = locator;
locator = InvokerLocator.validateLocator(locator);
+ if (!locator.getLocatorURI().equals(originalLocator.getLocatorURI())) {
+ log.debug(this + " original locator: " + originalLocator);
+ log.debug(this + " new locator: " + locator);
+ }
// need to update the locator key used in the invoker registry
InvokerRegistry.updateServerInvokerLocator(originalLocator, locator);
13 years, 10 months
- 1
- 0
JBoss Remoting SVN: r5869 - remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/management.
by jboss-remoting-commits＠lists.jboss.org
Author: trustin
Date: 2010-06-15 04:37:05 -0400 (Tue, 15 Jun 2010)
New Revision: 5869
Modified:
remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/management/ConnectionMXBean.java
remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/management/Counters.java
remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/management/EndpointMXBean.java
remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/management/ServiceMXBean.java
Log:
* Javadoc (forgot to check in last week)
* Renamed getRequestCounters() to getInboundRequestCounters() or getOutboundRequestCounters()
* Split EndpointMXBean.getRequestCounters() into the inbound version and the outbound version
Modified: remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/management/ConnectionMXBean.java
===================================================================
--- remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/management/ConnectionMXBean.java 2010-05-28 15:52:52 UTC (rev 5868)
+++ remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/management/ConnectionMXBean.java 2010-06-15 08:37:05 UTC (rev 5869)
@@ -23,13 +23,42 @@
import javax.management.ObjectName;
+import org.jboss.remoting3.Client;
+import org.jboss.remoting3.Connection;
+
+/**
+ * Statistics and management information for a {@link Connection}.
+ *
+ * @author <a href="http://gleamynode.net/>Trustin Lee</a>
+ * @version $Rev$, $Date$
+ */
public interface ConnectionMXBean {
+ /**
+ * Returns the {@link ObjectName} of the {@link EndpointMXBean} which
+ * created the {@link Connection}.
+ */
ObjectName getEndpoint();
- Counters getRequestCounters();
+ /**
+ * Returns the statistics information of the outbound requests handled
+ * (or being handled) by the {@link Connection}.
+ */
+ Counters getOutboundRequestCounters();
+
+ /**
+ * Returns the statistics information of the {@link Client}s created by the
+ * the {@link Connection}.
+ */
Counters getClientCounters();
+ /**
+ * Closes all open {@link Client}s created by the {@link Connection}.
+ */
void close();
+
+ /**
+ * Closes all open {@link Client}s created by the {@link Connection} forcibly.
+ */
void forceClose();
}
Modified: remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/management/Counters.java
===================================================================
--- remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/management/Counters.java 2010-05-28 15:52:52 UTC (rev 5868)
+++ remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/management/Counters.java 2010-06-15 08:37:05 UTC (rev 5869)
@@ -23,11 +23,25 @@
import java.beans.ConstructorProperties;
+/**
+ * Provides the number of the currently running (or in-progress) activities and
+ * the cumulative number of the succeeded or failed activities so far.
+ *
+ * @author <a href="http://gleamynode.net/>Trustin Lee</a>
+ * @version $Rev$, $Date$
+ */
public class Counters {
private final long active;
private final long success;
private final long failure;
+ /**
+ * Creates a new instance.
+ *
+ * @param active the number of the currently running (or in-progress) activities
+ * @param success the cumulative number of the succeeded activities so far
+ * @param failure the cumulative number of the failed activities so far
+ */
@ConstructorProperties({"active", "success", "failure"})
public Counters(long active, long success, long failure) {
this.active = active;
@@ -35,14 +49,23 @@
this.failure = failure;
}
+ /**
+ * Returns the number of the currently running (or in-progress) activities.
+ */
public long getActive() {
return active;
}
+ /**
+ * Returns the cumulative number of the succeeded activities so far.
+ */
public long getSuccess() {
return success;
}
+ /**
+ * Returns the cumulative number of the failed activities so far.
+ */
public long getFailure() {
return failure;
}
Modified: remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/management/EndpointMXBean.java
===================================================================
--- remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/management/EndpointMXBean.java 2010-05-28 15:52:52 UTC (rev 5868)
+++ remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/management/EndpointMXBean.java 2010-06-15 08:37:05 UTC (rev 5869)
@@ -25,13 +25,51 @@
import javax.management.ObjectName;
+import org.jboss.remoting3.Client;
+import org.jboss.remoting3.Connection;
+import org.jboss.remoting3.Endpoint;
+/**
+ * Statistics and management information for an {@link Endpoint}.
+ *
+ * @author <a href="http://gleamynode.net/>Trustin Lee</a>
+ * @version $Rev$, $Date$
+ */
public interface EndpointMXBean {
+ /**
+ * Returns the {@link ObjectName}s of all {@link ServiceMXBean}s where
+ * the services they represent are registered to the {@link Endpoint}.
+ */
List<ObjectName> getServices();
+
+ /**
+ * Returns the {@link ObjectName}s of all {@link ConnectionMXBean}s where
+ * the {@link Connection}s they represent are created by the {@link Endpoint}.
+ */
List<ObjectName> getConnections();
- Counters getRequestCounters();
+ /**
+ * Returns the statistics information of the inbound requests handled
+ * (or being handled) by the services registered to the {@link Endpoint}.
+ */
+ Counters getInboundRequestCounters();
+
+ /**
+ * Returns the statistics information of the outbound requests made by
+ * the {@link Connection}s created by the {@link Endpoint}.
+ */
+ Counters getOutboundRequestCounters();
+
+ /**
+ * Returns the statistics information of the {@link Connection}s created by
+ * the {@link Endpoint}.
+ */
Counters getConnectionCounters();
+
+ /**
+ * Returns the statistics information of the {@link Client}s created by the
+ * {@link Endpoint}.
+ */
Counters getClientCounters();
}
Modified: remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/management/ServiceMXBean.java
===================================================================
--- remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/management/ServiceMXBean.java 2010-05-28 15:52:52 UTC (rev 5868)
+++ remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/management/ServiceMXBean.java 2010-06-15 08:37:05 UTC (rev 5869)
@@ -25,15 +25,55 @@
import javax.management.ObjectName;
+import org.jboss.remoting3.Endpoint;
+
+/**
+ * Statistics and management information for the service registered to an
+ * {@link Endpoint}.
+ *
+ * @author <a href="http://gleamynode.net/>Trustin Lee</a>
+ * @version $Rev$, $Date$
+ */
public interface ServiceMXBean {
+ /**
+ * Returns the {@link ObjectName} of the {@link EndpointMXBean} where the
+ * service is registered to.
+ */
ObjectName getEndpoint();
+ /**
+ * Returns the instance name of the service.
+ */
String getInstanceName();
+
+ /**
+ * Returns the service type string which follows the convention for Java
+ * package names (reversed domain names).
+ */
String getServiceType();
+
+ /**
+ * Returns the expected fully qualified class name of the request object
+ * handled by the service.
+ */
String getRequestType();
+
+ /**
+ * Returns the expected fully qualified class name of the reply object
+ * returned by the service.
+ */
String getReplyType();
+
+ /**
+ * Returns the additional configuration options provided when the service
+ * was created.
+ */
Map<String, String> getOptions();
- Counters getRequestCounters();
+ /**
+ * Returns the statistics information of the inbound requests handled
+ * (or being handled) by the service.
+ */
+ Counters getInboundRequestCounters();
}
13 years, 10 months
- 1
- 0