@Test public void testAddTwoStreams() throws Exception { Account linkedin = modelFactory.getDAOFactory().createAccount("urn:service:linkedin"); linkedin.setPrefLabel("LinkedIn"); resourceStore.createOrUpdate(null, linkedin); ResourceStore data = null; Collection<LivePost> messages = new ArrayList<LivePost>(); data = createResourceStore( this.getClass().getClassLoader().getResourceAsStream("account/liveposts-call1.ttl"), Syntax.Turtle); for (Status status : data.find(Status.class).distinct().results()) { messages.add((Status) status.castTo(Status.class)); } streamAccountUpdater.update(linkedin.asURI(), "/liveposts", messages); assertEquals(10, resourceStore.find(Status.class).distinct().results().size()); messages.clear(); data = createResourceStore( this.getClass().getClassLoader().getResourceAsStream("account/liveposts-call2.ttl"), Syntax.Turtle); for (Status status : data.find(Status.class).distinct().results()) { messages.add((Status) status.castTo(Status.class)); } streamAccountUpdater.update(linkedin.asURI(), "/liveposts", messages); assertEquals(13, resourceStore.find(Status.class).distinct().results().size()); }
@Override public void update(URI accountUri, String path, LivePost livepost) throws AccountIntegrationException { Collection<LivePost> liveposts = new ArrayList<LivePost>(1); liveposts.add(livepost); update(accountUri, path, liveposts); }
StreamAccountUpdater extends AccountUpdaterBase implements AccountUpdater<LivePost> { @Override public void update(URI accountUri, String path, LivePost livepost) throws AccountIntegrationException { Collection<LivePost> liveposts = new ArrayList<LivePost>(1); liveposts.add(livepost); update(accountUri, path, liveposts); } }
StreamAccountUpdater extends AccountUpdaterBase implements AccountUpdater<LivePost> { @Override public void update(URI accountUri, String path, LivePost livepost) throws AccountIntegrationException { Collection<LivePost> liveposts = new ArrayList<LivePost>(1); liveposts.add(livepost); update(accountUri, path, liveposts); } StreamAccountUpdater(ResourceStore resourceStore); }
StreamAccountUpdater extends AccountUpdaterBase implements AccountUpdater<LivePost> { @Override public void update(URI accountUri, String path, LivePost livepost) throws AccountIntegrationException { Collection<LivePost> liveposts = new ArrayList<LivePost>(1); liveposts.add(livepost); update(accountUri, path, liveposts); } StreamAccountUpdater(ResourceStore resourceStore); @Override void update(URI accountUri, String path, LivePost livepost); @Override void update(URI accountUri, String path, Collection<LivePost> liveposts); }
StreamAccountUpdater extends AccountUpdaterBase implements AccountUpdater<LivePost> { @Override public void update(URI accountUri, String path, LivePost livepost) throws AccountIntegrationException { Collection<LivePost> liveposts = new ArrayList<LivePost>(1); liveposts.add(livepost); update(accountUri, path, liveposts); } StreamAccountUpdater(ResourceStore resourceStore); @Override void update(URI accountUri, String path, LivePost livepost); @Override void update(URI accountUri, String path, Collection<LivePost> liveposts);  }