Skip to content
Snippets Groups Projects
Commit 1d6764f5 authored by Ramin Yaghoubzadeh Torky's avatar Ramin Yaghoubzadeh Torky
Browse files

Merge portb:/homes/hbuschme/repo/ipaaca

parents 8e9aefba 76748278
No related branches found
No related tags found
No related merge requests found
...@@ -139,11 +139,12 @@ public class InputBuffer extends Buffer ...@@ -139,11 +139,12 @@ public class InputBuffer extends Buffer
String shortIDName = getUniqueShortName(); String shortIDName = getUniqueShortName();
uniqueName = "/ipaaca/component/" + shortIDName + "/IB"; uniqueName = "/ipaaca/component/" + shortIDName + "/IB";
this.channel = ipaaca_channel;
for (String cat : categoryInterests) for (String cat : categoryInterests)
{ {
createCategoryListenerIfNeeded(cat); createCategoryListenerIfNeeded(cat);
} }
this.channel = ipaaca_channel;
// add own uuid as identifier for hidden channel. (dlw) // add own uuid as identifier for hidden channel. (dlw)
createCategoryListenerIfNeeded(shortIDName); createCategoryListenerIfNeeded(shortIDName);
......
...@@ -22,7 +22,7 @@ import com.google.common.collect.ImmutableSet; ...@@ -22,7 +22,7 @@ import com.google.common.collect.ImmutableSet;
public class InputBufferTest public class InputBufferTest
{ {
private static final String COMPID = "Comp1"; private static final String COMPID = "Comp1";
private static final String CATEGORY = "category1"; private static final String CATEGORY = "testcat";
private InputBuffer inBuffer; private InputBuffer inBuffer;
...@@ -47,10 +47,10 @@ public class InputBufferTest ...@@ -47,10 +47,10 @@ public class InputBufferTest
@Test @Test
public void testHandleRemotePushEvent() throws RSBException, InterruptedException public void testHandleRemotePushEvent() throws RSBException, InterruptedException
{ {
Informer<Object> informer = Factory.getInstance().createInformer("/ipaaca/category/"+CATEGORY); Informer<Object> informer = Factory.getInstance().createInformer("/ipaaca/channel/default/category/"+CATEGORY);
informer.activate(); informer.activate();
RemotePushIU iu = new RemotePushIU("uid1"); RemotePushIU iu = new RemotePushIU("uid1");
iu.setCategory("/ipaaca/category/"+CATEGORY); iu.setCategory("/ipaaca/channel/default/category/"+CATEGORY);
iu.setOwnerName("owner"); iu.setOwnerName("owner");
iu.setReadOnly(false); iu.setReadOnly(false);
iu.setRevision(1); iu.setRevision(1);
......
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