Skip to content
Snippets Groups Projects
Commit 35403096 authored by Patient Ntumba's avatar Patient Ntumba
Browse files

Decreasing data size

parent 63b9e523
No related branches found
No related tags found
No related merge requests found
{"invocation_address":"http://128.93.64.132:1111/","service_port":"8891","subcomponent_port":"8891","subcomponent_address":"127.0.0.1","service_name":"","target_namespace":""} {"invocation_address":"http://128.93.64.132:1111/","service_port":"1112","subcomponent_port":"8891","subcomponent_address":"127.0.0.1","service_name":"","target_namespace":""}
\ No newline at end of file \ No newline at end of file
...@@ -52,7 +52,7 @@ public class MeasureAgent { ...@@ -52,7 +52,7 @@ public class MeasureAgent {
// Registry port for rmi communication // Registry port for rmi communication
LocateRegistry.createRegistry(port); LocateRegistry.createRegistry(port);
System.setProperty("java.rmi.server.hostname",address); //System.setProperty("java.rmi.server.hostname",address);
// Creating and starting MRI connector // Creating and starting MRI connector
JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://" + address + ":" + port + "/server"); JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://" + address + ":" + port + "/server");
......
...@@ -33,7 +33,7 @@ public class DPWSService extends DefaultService ...@@ -33,7 +33,7 @@ public class DPWSService extends DefaultService
this.addBinding(new HTTPBinding( this.addBinding(new HTTPBinding(
IPNetworkDetection.getInstance().getIPAddressOfAnyLocalInterface("128.93.64.132", false), IPNetworkDetection.getInstance().getIPAddressOfAnyLocalInterface("128.93.65.233", false),
5678, 5678,
"DPWSService", "DPWSService",
DPWSCommunicationManager.COMMUNICATION_MANAGER_ID) DPWSCommunicationManager.COMMUNICATION_MANAGER_ID)
......
...@@ -92,7 +92,7 @@ public class DpwsObserver extends DefaultClient { ...@@ -92,7 +92,7 @@ public class DpwsObserver extends DefaultClient {
HTTPBinding binding = new HTTPBinding( HTTPBinding binding = new HTTPBinding(
IPNetworkDetection.getInstance().getIPAddressOfAnyLocalInterface("128.93.65.233", false), IPNetworkDetection.getInstance().getIPAddressOfAnyLocalInterface("128.93.64.132", false),
10236, 10236,
"/EventSink", "/EventSink",
DPWSCommunicationManager.COMMUNICATION_MANAGER_ID); DPWSCommunicationManager.COMMUNICATION_MANAGER_ID);
......
...@@ -66,7 +66,6 @@ public class BcMQTTSubcomponent extends BcGmSubcomponent { ...@@ -66,7 +66,6 @@ public class BcMQTTSubcomponent extends BcGmSubcomponent {
agent = new MeasureAgent("timestamp_5", System.currentTimeMillis(), "localhost",9004); agent = new MeasureAgent("timestamp_5", System.currentTimeMillis(), "localhost",9004);
try { try {
client = new MqttClient("tcp://"+this.bcConfiguration.getServiceAddress()+":"+this.bcConfiguration.getServicePort(), "client"); client = new MqttClient("tcp://"+this.bcConfiguration.getServiceAddress()+":"+this.bcConfiguration.getServicePort(), "client");
System.out.println(" URL is "+this.bcConfiguration.getServiceAddress()+":"+this.bcConfiguration.getServicePort()); System.out.println(" URL is "+this.bcConfiguration.getServiceAddress()+":"+this.bcConfiguration.getServicePort());
} catch (MqttException e){ } catch (MqttException e){
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment