MainClass.java

import rx.Subscriber;

/**
 * Created by harshitbangar on 19/08/16.
 */
public class MainClass {

    public static void main(String[] args) {
        QueueLibraryManager queueLibraryManager = new QueueLibraryManager();
        queueLibraryManager.addToQueue("arbit").subscribe(new TestSubscriber());
        queueLibraryManager.addToQueue("bdsds").subscribe(new TestSubscriber());
        queueLibraryManager.addToQueue("arbidsdst").subscribe(new TestSubscriber());
        queueLibraryManager.addToQueue("arbitdsdsd").subscribe(new TestSubscriber());
    }

    public static class TestSubscriber extends Subscriber<String> {

        @Override
        public void onCompleted() {

        }

        @Override
        public void onError(Throwable throwable) {

        }

        @Override
        public void onNext(String o) {
            System.out.println(o);
        }
    }
}