1 package org.indi.reactor;
2
3 import java.util.Queue;
4
5 /**
6 * Simple implementation of the QueueHandeler interface
7 *
8 * @author dirk
9 */
10 public class BasicQueueHandler implements QueueHandler {
11 /**
12 * The Queue containing the element to be read
13 */
14 private final Queue<Object> queue;
15
16 /**
17 * Class constructor
18 *
19 * @param queue
20 * The queue containing the elements to be read
21 */
22 public BasicQueueHandler(Queue<Object> queue) {
23 this.queue = queue;
24 }
25
26 /**
27 * @see org.indi.reactor.QueueHandler#getQueue()
28 */
29 public Queue<Object> getQueue() {
30 return this.queue;
31 }
32
33 /**
34 * @see org.indi.reactor.QueueHandler#onRead(java.lang.Object)
35 */
36 public void onRead(Object input) {
37 }
38 }