KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > jboss > test > messaging > TestMessageReference


1 /*
2  * JBoss, the OpenSource J2EE webOS
3  *
4  * Distributable under LGPL license.
5  * See terms of license at gnu.org.
6  */
7 package org.jboss.test.messaging;
8
9 import java.util.Comparator JavaDoc;
10
11 import org.jboss.messaging.interfaces.MessageAddress;
12 import org.jboss.messaging.interfaces.MessageReference;
13
14 import EDU.oswego.cs.dl.util.concurrent.SynchronizedLong;
15
16 /**
17  * A simple implementation of a message reference
18  *
19  * @author <a HREF="mailto:adrian@jboss.org">Adrian Brock</a>
20  * @version $Revision: 1.1 $
21  */
22 public class TestMessageReference implements MessageReference
23 {
24    // Constants -----------------------------------------------------
25
26    // Attributes ----------------------------------------------------
27
28    Long JavaDoc messageID;
29    
30    // Static --------------------------------------------------------
31
32    private static final SynchronizedLong nextMessageID = new SynchronizedLong(0);
33
34    // Constructors --------------------------------------------------
35
36    public TestMessageReference()
37    {
38       messageID = new Long JavaDoc(nextMessageID.increment());
39    }
40    
41    // Public --------------------------------------------------------
42
43    // MessageReference implementation -------------------------------
44
45    public Comparable JavaDoc getMessageID()
46    {
47       return messageID;
48    }
49
50    public void release()
51    {
52    }
53    
54    public MessageAddress getMessageAddress()
55    {
56       return null;
57    }
58
59    public int getMessagePriority()
60    {
61       return 0;
62    }
63
64    public boolean isGuaranteed()
65    {
66       return false;
67    }
68    
69    // Protected -----------------------------------------------------
70
71    // Package Private -----------------------------------------------
72
73    // Private -------------------------------------------------------
74
75    // Inner Classes -------------------------------------------------
76
77    public static class TestMessageReferenceComparator implements Comparator JavaDoc
78    {
79       public int compare(Object JavaDoc o1, Object JavaDoc o2)
80       {
81          Comparable JavaDoc m1 = ((TestMessageReference) o1).getMessageID();
82          Comparable JavaDoc m2 = ((TestMessageReference) o2).getMessageID();
83          return m1.compareTo(m2);
84       }
85    }
86 }
87
Popular Tags