You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2018/05/03 13:42:00 UTC
svn commit: r1830824 -
/uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/monitor/builtin/RemoteStateObserver.java
Author: cwiklik
Date: Thu May 3 13:42:00 2018
New Revision: 1830824
URL: http://svn.apache.org/viewvc?rev=1830824&view=rev
Log:
UIMA-5756 modified to send process id and state to an agent monitor
Modified:
uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/monitor/builtin/RemoteStateObserver.java
Modified: uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/monitor/builtin/RemoteStateObserver.java
URL: http://svn.apache.org/viewvc/uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/monitor/builtin/RemoteStateObserver.java?rev=1830824&r1=1830823&r2=1830824&view=diff
==============================================================================
--- uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/monitor/builtin/RemoteStateObserver.java (original)
+++ uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/monitor/builtin/RemoteStateObserver.java Thu May 3 13:42:00 2018
@@ -77,7 +77,7 @@ public class RemoteStateObserver impleme
if ( socket == null ) {
return;
}
- String serviceData = "";
+ //String serviceData = "";
if ( additionalData == null ) {
additionalData = new Properties();
}
@@ -85,17 +85,17 @@ public class RemoteStateObserver impleme
!serviceConfiguration.getAssignedJmxPort().trim().isEmpty()) {
additionalData.setProperty(SERVICE_JMS_PORT, serviceConfiguration.getAssignedJmxPort().trim());
}
- serviceData = XStreamUtils.marshall(additionalData);
+ //serviceData = XStreamUtils.marshall(additionalData);
StringBuilder sb = new StringBuilder()
.append(SERVICE_UNIQUE_ID)
.append(serviceConfiguration.getDuccProcessUniqueId())
.append(SEPARATOR)
.append(SERVICE_STATE)
- .append(state)
- .append(SEPARATOR)
- .append(SERVICE_DATA)
- .append(serviceData);
+ .append(state);
+// .append(SEPARATOR)
+// .append(SERVICE_DATA)
+// .append(serviceData);
out = new DataOutputStream(socket.getOutputStream());
out.writeUTF(sb.toString());
out.flush();