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
|
package org.jboss.ws.extensions.addressing;
import java.net.URI;
import java.net.URISyntaxException;
import javax.xml.rpc.Stub;
import javax.xml.ws.addressing.AddressingBuilder;
import javax.xml.ws.addressing.AddressingConstants;
import javax.xml.ws.addressing.AddressingProperties;
import javax.xml.ws.addressing.AttributedURI;
import org.jboss.ws.core.utils.UUIDGenerator;
/**
* @author Heiko Braun, <heiko@openj.net>
* @since 04-Mar-2006
*/
public class AddressingClientUtil
{
private static AddressingBuilder BUILDER;
private static AddressingConstants CONSTANTS;
static
{
BUILDER = AddressingBuilder.getAddressingBuilder();
CONSTANTS = BUILDER.newAddressingConstants();
}
/* creates outbound addressing properties */
public static AddressingProperties createRequestProperties()
{
AddressingProperties addrProps = BUILDER.newAddressingProperties();
addrProps.setMessageID(BUILDER.newURI(generateMessageID()));
return addrProps;
}
/**
* create default outbound addressing properties.
*/
public static AddressingProperties createDefaultProps(String wsaAction, String wsaTo)
{
try
{
AddressingProperties addrProps = createRequestProperties();
addrProps.setMessageID(BUILDER.newURI(generateMessageID()));
addrProps.setAction(BUILDER.newURI(wsaAction));
addrProps.setTo(BUILDER.newURI(wsaTo));
return addrProps;
}
catch (URISyntaxException e)
{
throw new IllegalArgumentException(e.getMessage());
}
}
/**
* create anonymous request properties.
* wsa:ReplyTo is set to anonymous and a messageID is supplied.
*/
public static AddressingProperties createAnonymousProps(String wsaAction, String wsaTo)
{
try
{
AddressingProperties addrProps = createDefaultProps(wsaAction, wsaTo);
addrProps.setReplyTo(BUILDER.newEndpointReference(new URI(CONSTANTS.getAnonymousURI())));
return addrProps;
}
catch (URISyntaxException e)
{
throw new IllegalArgumentException(e.getMessage());
}
}
/**
* one-way properties cary a wsa:ReplyTo of none
* upon which no response is expected.
*/
public static AddressingProperties createOneWayProps(String wsaAction, String wsaTo)
{
try
{
AddressingProperties addrProps = createDefaultProps(wsaAction, wsaTo);
addrProps.setReplyTo(BUILDER.newEndpointReference(new URI(CONSTANTS.getNoneURI())));
return addrProps;
}
catch (URISyntaxException e)
{
throw new IllegalArgumentException(e.getMessage());
}
}
/**
* customize a stubs endpooint url
*/
public static void setTargetAddress(Stub stub, String url)
{
stub._setProperty(Stub.ENDPOINT_ADDRESS_PROPERTY, url);
}
/**
* generate a UUID based message id.
*/
public static URI generateMessageID()
{
URI messageId = null;
try
{
messageId = new URI("urn:uuid:" + UUIDGenerator.generateRandomUUIDString());
}
catch (URISyntaxException e)
{
// Doesnt happen
}
return messageId;
}
public static AttributedURI createMessageID()
{
return BUILDER.newURI(generateMessageID());
}
}
|
