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
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
|
/*
* JBoss, Home of Professional Open Source
* Copyright 2005, JBoss Inc., and individual contributors as indicated
* by the @authors tag. See the copyright.txt in the distribution for a
* full listing of individual contributors.
*
* This is free software; you can redistribute it and/or modify it
* under the terms of the GNU Lesser General Public License as
* published by the Free Software Foundation; either version 2.1 of
* the License, or (at your option) any later version.
*
* This software is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this software; if not, write to the Free
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
*/
package org.jboss.ws.extensions.wsrm;
/**
* Encapsulates generation of reliable messaging quality assurance configurations
*
* @author richard.opalka@jboss.com
* @see org.jboss.ws.extensions.wsrm.RMDeliveryQuality
*/
public final class RMDeliveryAssuranceFactory
{
private static final RMDeliveryAssuranceFactory INSTANCE = new RMDeliveryAssuranceFactory();
private static final String[] ACCEPTABLE_IN_ORDER_VALUES = { "0", "1", "false", "true" };
private static final RMDeliveryAssurance EXACTLY_ONCE_WITH_ORDER;
private static final RMDeliveryAssurance EXACTLY_ONCE_WITHOUT_ORDER;
private static final RMDeliveryAssurance AT_MOST_ONCE_WITH_ORDER;
private static final RMDeliveryAssurance AT_MOST_ONCE_WITHOUT_ORDER;
private static final RMDeliveryAssurance AT_LEAST_ONCE_WITH_ORDER;
private static final RMDeliveryAssurance AT_LEAST_ONCE_WITHOUT_ORDER;
static
{
EXACTLY_ONCE_WITH_ORDER = new DeliveryAssuranceImpl(RMDeliveryQuality.EXACTLY_ONCE, true);
EXACTLY_ONCE_WITHOUT_ORDER = new DeliveryAssuranceImpl(RMDeliveryQuality.EXACTLY_ONCE, false);
AT_MOST_ONCE_WITH_ORDER = new DeliveryAssuranceImpl(RMDeliveryQuality.AT_MOST_ONCE, true);
AT_MOST_ONCE_WITHOUT_ORDER = new DeliveryAssuranceImpl(RMDeliveryQuality.AT_MOST_ONCE, false);
AT_LEAST_ONCE_WITH_ORDER = new DeliveryAssuranceImpl(RMDeliveryQuality.AT_LEAST_ONCE, true);
AT_LEAST_ONCE_WITHOUT_ORDER = new DeliveryAssuranceImpl(RMDeliveryQuality.AT_LEAST_ONCE, false);
}
// immutable object instance
private static final class DeliveryAssuranceImpl implements RMDeliveryAssurance
{
private final RMDeliveryQuality quality;
private final boolean inOrder;
private DeliveryAssuranceImpl(RMDeliveryQuality quality, boolean inOrder)
{
this.quality = quality;
this.inOrder = inOrder;
}
/*
* @see org.jboss.ws.extensions.wsrm.DeliveryAssurance#getDeliveryQuality()
*/
public RMDeliveryQuality getDeliveryQuality()
{
return quality;
}
/*
* @see org.jboss.ws.extensions.wsrm.DeliveryAssurance#inOrder()
*/
public boolean inOrder()
{
return inOrder;
}
}
private RMDeliveryAssuranceFactory()
{
// no instances
}
/**
* Factory getter
* @return factory instance
*/
public static RMDeliveryAssuranceFactory getInstance()
{
return INSTANCE;
}
/**
* Returns constructed DeliveryAssurance object
* @param quality string representing quality value
* @param inOrder string representing inOrder value
* @return DeliveryAssurance object
* @throws IllegalArgumentException if <b>quality</b> or <b>inOrder</b> are null or contain incorrect values
*/
public static RMDeliveryAssurance getDeliveryAssurance(String quality, String inOrder)
{
if ((quality == null) || (inOrder == null))
throw new IllegalArgumentException("Neither quality nor inOrder parameter cannot be null");
Boolean inOrderBoolean = null;
for (int i = 0; i < ACCEPTABLE_IN_ORDER_VALUES.length; i++)
{
if (ACCEPTABLE_IN_ORDER_VALUES[i].equals(inOrder))
{
inOrderBoolean = (i % 2 == 0) ? Boolean.FALSE : Boolean.TRUE;
break;
}
}
if (inOrderBoolean == null)
throw new IllegalArgumentException("Incorrect inOrder value: " + inOrder);
return getDeliveryAssurance(RMDeliveryQuality.parseDeliveryQuality(quality), inOrderBoolean);
}
/**
* Returns constructed DeliveryAssurance object
* @param quality object representing required quality
* @param inOrder string representing required inOrder value
* @return DeliveryAssurance object
* @throws IllegalArgumentException if <b>quality</b> is null
*/
public static RMDeliveryAssurance getDeliveryAssurance(RMDeliveryQuality quality, boolean inOrder)
{
if (quality == null)
throw new IllegalArgumentException("Quality cannot be null");
if (inOrder)
{
if (quality == RMDeliveryQuality.EXACTLY_ONCE) return EXACTLY_ONCE_WITH_ORDER;
if (quality == RMDeliveryQuality.AT_LEAST_ONCE) return AT_LEAST_ONCE_WITH_ORDER;
if (quality == RMDeliveryQuality.AT_MOST_ONCE) return AT_MOST_ONCE_WITH_ORDER;
}
else
{
if (quality == RMDeliveryQuality.EXACTLY_ONCE) return EXACTLY_ONCE_WITHOUT_ORDER;
if (quality == RMDeliveryQuality.AT_LEAST_ONCE) return AT_LEAST_ONCE_WITHOUT_ORDER;
if (quality == RMDeliveryQuality.AT_MOST_ONCE) return AT_MOST_ONCE_WITHOUT_ORDER;
}
return null; // never happens
}
}
|
