implicit subscirtion fixed

jboulmal · jboulmal · commit a8cfd6189969 · 2016-11-09T11:18:47.000+01:00
diff --git a/src/main/components/rethink/ObjectAllocationManager.js b/src/main/components/rethink/ObjectAllocationManager.js
@@ -112,15 +112,15 @@ class ObjectAllocationManager {
     for (i = 0; i < number; i++) {
       let url = scheme + this.baseURL + uuid.v4();
       list.push(url);
-      clientMessage.getResource().subscribe(url + '/subscription');
+      clientMessage.getResource().subscribe(url);
     }
 
     this.logger.info('[' + this.getName() + '] allocate scheme', list);
     return list;
   }
 
   deallocate(clientMessage, url) {
-    clientMessage.getResource().unsubscribe(url + '/subscription');
+    clientMessage.getResource().unsubscribe(url);
   }
 }
 module.exports = ObjectAllocationManager;

Original file line number	Diff line number	Diff line change
`@@ -112,15 +112,15 @@ class ObjectAllocationManager {`
`112`	`112`	`for (i = 0; i < number; i++) {`
`113`	`113`	`let url = scheme + this.baseURL + uuid.v4();`
`114`	`114`	`list.push(url);`
`115`		`- clientMessage.getResource().subscribe(url + '/subscription');`
	`115`	`+ clientMessage.getResource().subscribe(url);`
`116`	`116`	`}`
`117`	`117`
`118`	`118`	`this.logger.info('[' + this.getName() + '] allocate scheme', list);`
`119`	`119`	`return list;`
`120`	`120`	`}`
`121`	`121`
`122`	`122`	`deallocate(clientMessage, url) {`
`123`		`- clientMessage.getResource().unsubscribe(url + '/subscription');`
	`123`	`+ clientMessage.getResource().unsubscribe(url);`
`124`	`124`	`}`
`125`	`125`	`}`
`126`	`126`	`module.exports = ObjectAllocationManager;`