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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
package org.apache.qpid.client.messaging.address;
import org.apache.qpid.client.AMQDestination;
import org.apache.qpid.client.AMQDestination.AddressOption;
import org.apache.qpid.client.AMQDestination.Binding;
import org.apache.qpid.client.messaging.address.Link.Reliability;
import org.apache.qpid.messaging.Address;
import org.apache.qpid.test.utils.QpidTestCase;
public class AddressHelperTest extends QpidTestCase
{
public void testAddressOptions() throws Exception
{
Address addr = Address.parse("queue/test;{create:sender, assert:always, delete:receiver, mode:browse}");
AddressHelper helper = new AddressHelper(addr);
assertEquals(AddressOption.SENDER,AddressOption.getOption(helper.getCreate()));
assertEquals(AddressOption.ALWAYS,AddressOption.getOption(helper.getAssert()));
assertEquals(AddressOption.RECEIVER,AddressOption.getOption(helper.getDelete()));
assertTrue("'mode' option wasn't read properly",helper.isBrowseOnly());
}
public void testNodeProperties() throws Exception
{
Address addr = Address.parse("my-queue;{" +
"node: " +
"{" +
"type: queue ," +
"durable: true ," +
"x-declare: " +
"{" +
"exclusive: true," +
"auto-delete: true," +
"alternate-exchange: 'amq.fanout'," +
"arguments: {" +
"'qpid.max_size': 1000," +
"'qpid.max_count': 100" +
"}" +
"}, " +
"x-bindings: [{exchange : 'amq.direct', queue:my-queue, key : test}, " +
"{exchange : 'amq.fanout', queue:my-queue}," +
"{exchange: 'amq.match', queue:my-queue, arguments: {x-match: any, dep: sales, loc: CA}}," +
"{exchange : 'amq.topic',queue:my-queue, key : 'a.#'}" +
"]" +
"}" +
"}");
AddressHelper helper = new AddressHelper(addr);
Node node = helper.getNode();
assertEquals("'type' property wasn't read properly",AMQDestination.QUEUE_TYPE,helper.getNodeType());
assertTrue("'durable' property wasn't read properly",node.isDurable());
assertTrue("'auto-delete' property wasn't read properly",node.isAutoDelete());
assertTrue("'exclusive' property wasn't read properly",node.isExclusive());
assertEquals("'alternate-exchange' property wasn't read properly","amq.fanout",node.getAlternateExchange());
assertEquals("'arguments' in 'x-declare' property wasn't read properly",2,node.getDeclareArgs().size());
assertEquals("'bindings' property wasn't read properly",4,node.getBindings().size());
for (Binding binding: node.getBindings())
{
assertTrue("property 'exchange' in bindings wasn't read properly",binding.getExchange().startsWith("amq."));
assertEquals("property 'queue' in bindings wasn't read properly","my-queue",binding.getQueue());
if (binding.getExchange().equals("amq.direct"))
{
assertEquals("'key' property in bindings wasn't read properly","test",binding.getBindingKey());
}
if (binding.getExchange().equals("amq.match"))
{
assertEquals("'arguments' property in bindings wasn't read properly",3,binding.getArgs().size());
}
}
}
public void testLinkProperties() throws Exception
{
Address addr = Address.parse("my-queue;{" +
"link: " +
"{" +
"name: my-queue ," +
"durable: true ," +
"reliability: at-least-once," +
"capacity: {source:10, target:15}," +
"x-declare: " +
"{" +
"exclusive: true," +
"auto-delete: true," +
"alternate-exchange: 'amq.fanout'," +
"arguments: {" +
"'qpid.max_size': 1000," +
"'qpid.max_count': 100" +
"}" +
"}, " +
"x-bindings: [{exchange : 'amq.direct', queue:my-queue, key : test}, " +
"{exchange : 'amq.fanout', queue:my-queue}," +
"{exchange: 'amq.match', queue:my-queue, arguments: {x-match: any, dep: sales, loc: CA}}," +
"{exchange : 'amq.topic',queue:my-queue, key : 'a.#'}" +
"]," +
"x-subscribes:{exclusive: true, arguments: {a:b,x:y}}" +
"}" +
"}");
AddressHelper helper = new AddressHelper(addr);
Link link = helper.getLink();
assertEquals("'name' property wasn't read properly","my-queue",link.getName());
assertTrue("'durable' property wasn't read properly",link.isDurable());
assertEquals("'reliability' property wasn't read properly",Reliability.AT_LEAST_ONCE,link.getReliability());
assertTrue("'auto-delete' property in 'x-declare' wasn't read properly",link.getSubscriptionQueue().isAutoDelete());
assertTrue("'exclusive' property in 'x-declare' wasn't read properly",link.getSubscriptionQueue().isExclusive());
assertEquals("'alternate-exchange' property in 'x-declare' wasn't read properly","amq.fanout",link.getSubscriptionQueue().getAlternateExchange());
assertEquals("'arguments' in 'x-declare' property wasn't read properly",2,link.getSubscriptionQueue().getDeclareArgs().size());
assertEquals("'bindings' property wasn't read properly",4,link.getBindings().size());
for (Binding binding: link.getBindings())
{
assertTrue("property 'exchange' in bindings wasn't read properly",binding.getExchange().startsWith("amq."));
assertEquals("property 'queue' in bindings wasn't read properly","my-queue",binding.getQueue());
if (binding.getExchange().equals("amq.direct"))
{
assertEquals("'key' property in bindings wasn't read properly","test",binding.getBindingKey());
}
if (binding.getExchange().equals("amq.match"))
{
assertEquals("'arguments' property in bindings wasn't read properly",3,binding.getArgs().size());
}
}
assertTrue("'exclusive' property in 'x-subscribe' wasn't read properly",link.getSubscription().isExclusive());
assertEquals("'arguments' in 'x-subscribe' property wasn't read properly",2,link.getSubscription().getArgs().size());
}
}
|
