memcached/JavaConsumer/Consumer.java

import net.spy.memcached.MemcachedClient;
import java.net.InetSocketAddress;

public class Consumer
{
        static final int SLOT_COUNT = 10;

        public static void main(String args[]) throws Exception
        {
                MemcachedClient c = new MemcachedClient( new InetSocketAddress("localhost", 11211) );

                int current = 0;
                while (true) {

                        String key = "slot:" + current;

                
                        String data = (String) c.get(key);
                        if ( data != null) {
                                System.out.println("Consuming slot " + current);
                        
                                System.out.println("Got >" +data + "<");

                                c.delete(key);
                        }


                        current = (current+1) % SLOT_COUNT;

                        Thread.sleep( 900 );
                }
        }
}
1	import net.spy.memcached.MemcachedClient;
2	import java.net.InetSocketAddress;
3
4	public class Consumer
5	{
6	static final int SLOT_COUNT = 10;
7
8	public static void main(String args[]) throws Exception
9	{
10	MemcachedClient c = new MemcachedClient( new InetSocketAddress("localhost", 11211) );
11
12	int current = 0;
13	while (true) {
14
15	String key = "slot:" + current;
16
17
18	String data = (String) c.get(key);
19	if ( data != null) {
20	System.out.println("Consuming slot " + current);
21
22	System.out.println("Got >" +data + "<");
23
24	c.delete(key);
25	}
26
27
28	current = (current+1) % SLOT_COUNT;
29
30	Thread.sleep( 900 );
31	}
32	}
33	}