## Consumer.java [java]
import java.io.*;
import java.util.concurrent.*;

public class Consumer {
      public void consume(LinkedBlockingQueue queue) throws InterruptedException {
      for(int i = 0; i < 5 ; i ++) {
        String message = (String)queue.take();
        System.out.println(message);
      }
    }
}


##producer.rb [ruby]
require 'java'
require 'Consumer'
import 'java.util.concurrent.LinkedBlockingQueue'
queue = java.util.concurrent.LinkedBlockingQueue.new

t = Thread.new{Java.Default.Consumer.new.consume(queue)}

sleep 1

queue.put('pete')
queue.put('toddy')
queue.put('susan')
queue.put('sooze')
queue.put('beans')