diff --git a/ipaacalib/java/src/ipaaca/InputBuffer.java b/ipaacalib/java/src/ipaaca/InputBuffer.java index 444d9aba5b1c70bc64d3b509200d07b1b0ab7599..9c1ff22422aed1c6f945aa2fdd93e978cc9e2d8d 100644 --- a/ipaacalib/java/src/ipaaca/InputBuffer.java +++ b/ipaacalib/java/src/ipaaca/InputBuffer.java @@ -139,11 +139,12 @@ public class InputBuffer extends Buffer String shortIDName = getUniqueShortName(); uniqueName = "/ipaaca/component/" + shortIDName + "/IB"; + this.channel = ipaaca_channel; + for (String cat : categoryInterests) { createCategoryListenerIfNeeded(cat); } - this.channel = ipaaca_channel; // add own uuid as identifier for hidden channel. (dlw) createCategoryListenerIfNeeded(shortIDName); diff --git a/ipaacalib/java/test/src/ipaaca/InputBufferTest.java b/ipaacalib/java/test/src/ipaaca/InputBufferTest.java index d0ff20a710a44ca5da7b8cce805cc7e86f9223d8..420a3687480cc2f0a2dbc2f425ac83f163858907 100644 --- a/ipaacalib/java/test/src/ipaaca/InputBufferTest.java +++ b/ipaacalib/java/test/src/ipaaca/InputBufferTest.java @@ -22,7 +22,7 @@ import com.google.common.collect.ImmutableSet; public class InputBufferTest { private static final String COMPID = "Comp1"; - private static final String CATEGORY = "category1"; + private static final String CATEGORY = "testcat"; private InputBuffer inBuffer; @@ -47,10 +47,10 @@ public class InputBufferTest @Test 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(); RemotePushIU iu = new RemotePushIU("uid1"); - iu.setCategory("/ipaaca/category/"+CATEGORY); + iu.setCategory("/ipaaca/channel/default/category/"+CATEGORY); iu.setOwnerName("owner"); iu.setReadOnly(false); iu.setRevision(1);