Skip to content
Snippets Groups Projects
Commit 97892a6d authored by Ramin Yaghoubzadeh's avatar Ramin Yaghoubzadeh
Browse files

Merge portb:/homes/hvanwelbergen/git_pool/ipaaca

parents 3403686e 5b98d7d1
No related branches found
No related tags found
No related merge requests found
......@@ -42,7 +42,7 @@ public class ComponentNotifier
private final InputBuffer inBuffer;
private List<HandlerFunctor> handlers = Collections.synchronizedList(new ArrayList<HandlerFunctor>());
private volatile boolean isInitialized = false;
private final BlockingQueue<String> receiverQueue = new LinkedBlockingQueue<>();
private final BlockingQueue<String> receiverQueue = new LinkedBlockingQueue<String>();
private class ComponentNotifyHandler implements HandlerFunctor
{
......@@ -79,7 +79,7 @@ public class ComponentNotifier
*/
public void waitForReceivers(ImmutableSet<String> categories)
{
Set<String> unhandledCategories = new HashSet<>(categories);
Set<String> unhandledCategories = new HashSet<String>(categories);
while(!unhandledCategories.isEmpty())
{
try
......
......@@ -10,7 +10,7 @@ import java.util.List;
*/
public class StoringEventHandler implements HandlerFunctor
{
private List<AbstractIU> addedIUs = new ArrayList<>();
private List<AbstractIU> addedIUs = new ArrayList<AbstractIU>();
public List<AbstractIU> getAddedIUs()
{
......
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