@@ -0,0 +1,404 @@
+package pw.koj.jetstreem.core;%0A%0Aimport java.util.concurrent.LinkedBlockingQueue;%0A%0Apublic final class StrmQueue extends LinkedBlockingQueue %7B%0A    private static StrmQueue instance;%0A%0A    private StrmQueue() %7B%0A        super();%0A    %7D%0A%0A    public static synchronized StrmQueue getInstance() %7B%0A        if (instance == null) %7B%0A            instance = new StrmQueue();%0A        %7D%0A        return instance;%0A    %7D%0A%7D%0A%0A

add class StrmQueue