blob: 5a5e23baa51d04ae2568b915ede1620288e48f0e (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
package org.apache.qpid.test.client.message;
import javax.jms.Connection;
import javax.jms.Destination;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
import junit.framework.Assert;
import org.apache.log4j.Logger;
import org.apache.qpid.test.utils.QpidTestCase;
public class SelectorTest extends QpidTestCase
{
private static final Logger _logger = Logger.getLogger(SelectorTest.class);
public void testSelectorWithJMSMessageID() throws Exception
{
Connection conn = getConnection();
conn.start();
Session session = conn.createSession(true, Session.AUTO_ACKNOWLEDGE);
Destination dest = session.createQueue("SelectorQueue");
MessageProducer prod = session.createProducer(dest);
MessageConsumer consumer = session.createConsumer(dest,"JMSMessageID IS NOT NULL");
for (int i=0; i<2; i++)
{
Message msg = session.createTextMessage("Msg" + String.valueOf(i));
prod.send(msg);
}
session.commit();
Message msg1 = consumer.receive(1000);
Message msg2 = consumer.receive(1000);
Assert.assertNotNull("Msg1 should not be null", msg1);
Assert.assertNotNull("Msg2 should not be null", msg2);
session.commit();
prod.setDisableMessageID(true);
for (int i=0; i<2; i++)
{
Message msg = session.createTextMessage("Msg" + String.valueOf(i));
prod.send(msg);
}
session.commit();
Message msg3 = consumer.receive(1000);
Assert.assertNull("Msg3 should be null", msg3);
session.commit();
consumer = session.createConsumer(dest,"JMSMessageID IS NULL");
Message msg4 = consumer.receive(1000);
Message msg5 = consumer.receive(1000);
session.commit();
Assert.assertNotNull("Msg4 should not be null", msg4);
Assert.assertNotNull("Msg5 should not be null", msg5);
}
}
|
