[jboss-svn-commits] JBL Code SVN: r19699 - in labs/jbosstm/trunk/XTS: WS-T/dev/src11/com/arjuna/webservices11/wsat/client and 2 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Wed Apr 23 12:31:33 EDT 2008
Author: adinn
Date: 2008-04-23 12:31:33 -0400 (Wed, 23 Apr 2008)
New Revision: 19699
Modified:
labs/jbosstm/trunk/XTS/WS-C/dev/src11/com/arjuna/webservices11/wsaddr/AddressingHelper.java
labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsat/client/CompletionCoordinatorClient.java
labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsat/client/CompletionInitiatorClient.java
labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsat/client/CoordinatorClient.java
labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsat/client/ParticipantClient.java
labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/CoordinatorCompletionCoordinatorClient.java
labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/CoordinatorCompletionParticipantClient.java
labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/ParticipantCompletionCoordinatorClient.java
labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/ParticipantCompletionParticipantClient.java
labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/WSBAClient.java
labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/wst11/messaging/engines/ParticipantCompletionParticipantEngine.java
Log:
addressing properties for oneway protocol messages now include from=<service-opposite-number> and replyto=<none>
Modified: labs/jbosstm/trunk/XTS/WS-C/dev/src11/com/arjuna/webservices11/wsaddr/AddressingHelper.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-C/dev/src11/com/arjuna/webservices11/wsaddr/AddressingHelper.java 2008-04-23 15:47:08 UTC (rev 19698)
+++ labs/jbosstm/trunk/XTS/WS-C/dev/src11/com/arjuna/webservices11/wsaddr/AddressingHelper.java 2008-04-23 16:31:33 UTC (rev 19699)
@@ -4,6 +4,7 @@
import javax.xml.ws.addressing.*;
import java.net.URISyntaxException;
+import java.net.URI;
/**
* The complete addressing context.
@@ -159,7 +160,9 @@
final AddressingProperties requestProperties = builder.newAddressingProperties();
requestProperties.setMessageID (makeURI(builder, messageID));
requestProperties.setAction(makeURI(builder, ""));
-
+ URI noneURI = URI.create(builder.newAddressingConstants().getNoneURI());
+ requestProperties.setReplyTo(builder.newEndpointReference(noneURI));
+
return requestProperties;
}
Modified: labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsat/client/CompletionCoordinatorClient.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsat/client/CompletionCoordinatorClient.java 2008-04-23 15:47:08 UTC (rev 19698)
+++ labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsat/client/CompletionCoordinatorClient.java 2008-04-23 16:31:33 UTC (rev 19699)
@@ -11,9 +11,11 @@
import javax.xml.ws.addressing.AddressingBuilder;
import javax.xml.ws.addressing.AddressingProperties;
import javax.xml.ws.addressing.AttributedURI;
+import javax.xml.ws.addressing.EndpointReference;
import javax.xml.ws.wsaddressing.W3CEndpointReference;
import java.io.IOException;
import java.net.URISyntaxException;
+import java.net.URI;
/**
* The Client side of the Completion Coordinator.
@@ -38,7 +40,7 @@
/**
* The completion initiator URI for replies.
*/
- private AttributedURI completionInitiator ;
+ private EndpointReference completionInitiator ;
/**
* Construct the completion coordinator client.
@@ -59,10 +61,11 @@
// Add client policies
// ClientPolicy.register(handlerRegistry) ;
- final String completionInitiatorURI =
+ final String completionInitiatorURIString =
ServiceRegistry.getRegistry().getServiceURI(AtomicTransactionConstants.COMPLETION_INITIATOR_SERVICE_NAME) ;
try {
- completionInitiator = builder.newURI(completionInitiatorURI) ;
+ URI completionInitiatorURI = new URI(completionInitiatorURIString) ;
+ completionInitiator = builder.newEndpointReference(completionInitiatorURI);
} catch (URISyntaxException use) {
// TODO - log fault and throw exception
}
@@ -110,7 +113,7 @@
}
/**
- * obtain a port from the endpoint configured with the instance identifier handler and the supplied
+ * obtain a port from the completion coordinator endpoint configured with the instance identifier handler and the supplied
* addressing properties supplemented with the given action
* @param endpoint
* @param addressingProperties
@@ -121,6 +124,7 @@
final AddressingProperties addressingProperties,
final AttributedURI action)
{
+ addressingProperties.setFrom(completionInitiator);
return WSATClient.getCompletionCoordinatorPort(endpoint, action, addressingProperties);
}
}
Modified: labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsat/client/CompletionInitiatorClient.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsat/client/CompletionInitiatorClient.java 2008-04-23 15:47:08 UTC (rev 19698)
+++ labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsat/client/CompletionInitiatorClient.java 2008-04-23 16:31:33 UTC (rev 19699)
@@ -11,9 +11,11 @@
import javax.xml.ws.addressing.AddressingBuilder;
import javax.xml.ws.addressing.AddressingProperties;
import javax.xml.ws.addressing.AttributedURI;
+import javax.xml.ws.addressing.EndpointReference;
import javax.xml.ws.wsaddressing.W3CEndpointReference;
import java.io.IOException;
import java.net.URISyntaxException;
+import java.net.URI;
/**
* The Client side of the Completion Initiator.
@@ -42,7 +44,7 @@
/**
* The completion coordinator URI for replies.
*/
- private AttributedURI completionCoordinator ;
+ private EndpointReference completionCoordinator ;
/**
* Construct the completion initiator client.
@@ -64,10 +66,11 @@
// Add client policies
// ClientPolicy.register(handlerRegistry) ;
- final String completionCoordinatorURI =
+ final String completionCoordinatorURIString =
ServiceRegistry.getRegistry().getServiceURI(AtomicTransactionConstants.COMPLETION_COORDINATOR_SERVICE_NAME) ;
try {
- completionCoordinator = builder.newURI(completionCoordinatorURI) ;
+ URI completionCoordinatorURI = new URI(completionCoordinatorURIString) ;
+ completionCoordinator = builder.newEndpointReference(completionCoordinatorURI);
} catch (URISyntaxException use) {
// TODO - log fault and throw exception
}
@@ -129,7 +132,7 @@
}
/**
- * obtain a port from the participant endpoint configured with the instance identifier handler and the supplied
+ * obtain a port from the completion participant endpoint configured with the instance identifier handler and the supplied
* addressing properties supplemented with the given action
* @param participant
* @param addressingProperties
@@ -140,6 +143,7 @@
final AddressingProperties addressingProperties,
final AttributedURI action)
{
+ addressingProperties.setFrom(completionCoordinator);
return WSATClient.getCompletionInitiatorPort(participant, action, addressingProperties);
}
}
Modified: labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsat/client/CoordinatorClient.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsat/client/CoordinatorClient.java 2008-04-23 15:47:08 UTC (rev 19698)
+++ labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsat/client/CoordinatorClient.java 2008-04-23 16:31:33 UTC (rev 19699)
@@ -11,9 +11,11 @@
import javax.xml.ws.addressing.AddressingBuilder;
import javax.xml.ws.addressing.AddressingProperties;
import javax.xml.ws.addressing.AttributedURI;
+import javax.xml.ws.addressing.EndpointReference;
import javax.xml.ws.wsaddressing.W3CEndpointReference;
import java.io.IOException;
import java.net.URISyntaxException;
+import java.net.URI;
/**
* The Client side of the Coordinator.
@@ -50,7 +52,7 @@
/**
* The participant URI for replies.
*/
- private AttributedURI participant ;
+ private EndpointReference participant ;
/**
* Construct the coordinator client.
@@ -74,10 +76,11 @@
// Add client policies
// ClientPolicy.register(handlerRegistry) ;
- final String participantURI =
+ final String participantURIString =
ServiceRegistry.getRegistry().getServiceURI(AtomicTransactionConstants.PARTICIPANT_SERVICE_NAME);
try {
- participant = builder.newURI(participantURI);
+ URI participantURI = new URI(participantURIString);
+ participant = builder.newEndpointReference(participantURI);
} catch (URISyntaxException use) {
// TODO - log fault and throw exception
}
@@ -171,17 +174,18 @@
}
/**
- * obtain a port from the participant endpoint configured with the instance identifier handler and the supplied
+ * obtain a port from the coordinator endpoint configured with the instance identifier handler and the supplied
* addressing properties supplemented with the given action
- * @param participant
+ * @param endpoint
* @param addressingProperties
* @param action
* @return
*/
- private CoordinatorPortType getPort(final W3CEndpointReference participant,
+ private CoordinatorPortType getPort(final W3CEndpointReference endpoint,
final AddressingProperties addressingProperties,
final AttributedURI action)
{
- return WSATClient.getCoordinatorPort(participant, action, addressingProperties);
+ addressingProperties.setFrom(participant);
+ return WSATClient.getCoordinatorPort(endpoint, action, addressingProperties);
}
}
Modified: labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsat/client/ParticipantClient.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsat/client/ParticipantClient.java 2008-04-23 15:47:08 UTC (rev 19698)
+++ labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsat/client/ParticipantClient.java 2008-04-23 16:31:33 UTC (rev 19699)
@@ -11,9 +11,11 @@
import javax.xml.ws.addressing.AddressingBuilder;
import javax.xml.ws.addressing.AddressingProperties;
import javax.xml.ws.addressing.AttributedURI;
+import javax.xml.ws.addressing.EndpointReference;
import javax.xml.ws.wsaddressing.W3CEndpointReference;
import java.io.IOException;
import java.net.URISyntaxException;
+import java.net.URI;
/**
* The Client side of the Participant.
@@ -46,7 +48,7 @@
/**
* The coordinator URI for replies.
*/
- private AttributedURI coordinator ;
+ private EndpointReference coordinator ;
/**
* Construct the completion initiator client.
@@ -68,9 +70,10 @@
// Add client policies
// ClientPolicy.register(handlerRegistry) ;
- final String coordinatorURI = ServiceRegistry.getRegistry().getServiceURI(AtomicTransactionConstants.COORDINATOR_SERVICE_NAME);
+ final String coordinatorURIString = ServiceRegistry.getRegistry().getServiceURI(AtomicTransactionConstants.COORDINATOR_SERVICE_NAME);
try {
- coordinator = builder.newURI(coordinatorURI);
+ URI coordinatorURI = new URI(coordinatorURIString);
+ coordinator = builder.newEndpointReference(coordinatorURI);
} catch (URISyntaxException use) {
// TODO - log fault and throw exception
}
@@ -160,6 +163,7 @@
final AddressingProperties addressingProperties,
final AttributedURI action)
{
+ addressingProperties.setFrom(coordinator);
return WSATClient.getParticipantPort(participant, action, addressingProperties);
}
}
Modified: labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/CoordinatorCompletionCoordinatorClient.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/CoordinatorCompletionCoordinatorClient.java 2008-04-23 15:47:08 UTC (rev 19698)
+++ labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/CoordinatorCompletionCoordinatorClient.java 2008-04-23 16:31:33 UTC (rev 19699)
@@ -34,9 +34,11 @@
import javax.xml.ws.addressing.AddressingBuilder;
import javax.xml.ws.addressing.AddressingProperties;
import javax.xml.ws.addressing.AttributedURI;
+import javax.xml.ws.addressing.EndpointReference;
import javax.xml.ws.wsaddressing.W3CEndpointReference;
import java.io.IOException;
import java.net.URISyntaxException;
+import java.net.URI;
/**
* The Client side of the Coordinator Completion Coordinator.
@@ -89,7 +91,7 @@
/**
* The coordinator completion participant URI for replies.
*/
- private AttributedURI coordinatorCompletionParticipant = null;
+ private EndpointReference coordinatorCompletionParticipant = null;
/**
* Construct the participant completion coordinator client.
@@ -117,10 +119,11 @@
// Add client policies
//ClientPolicy.register(handlerRegistry) ;
- final String coordinatorCompletionParticipantURI =
+ final String coordinatorCompletionParticipantURIString =
ServiceRegistry.getRegistry().getServiceURI(BusinessActivityConstants.COORDINATOR_COMPLETION_PARTICIPANT_SERVICE_NAME) ;
try {
- coordinatorCompletionParticipant = builder.newURI(coordinatorCompletionParticipantURI) ;
+ URI coordinatorCompletionParticipantURI = new URI(coordinatorCompletionParticipantURIString) ;
+ coordinatorCompletionParticipant = builder.newEndpointReference(coordinatorCompletionParticipantURI);
} catch (URISyntaxException use) {
// TODO - log fault and throw exception
}
@@ -293,7 +296,7 @@
}
/**
- * obtain a port from the participant endpoint configured with the instance identifier handler and the supplied
+ * obtain a port from the coordinator endpoint configured with the instance identifier handler and the supplied
* addressing properties supplemented with the given action
* @param participant
* @param addressingProperties
@@ -303,6 +306,7 @@
private BusinessAgreementWithCoordinatorCompletionCoordinatorPortType
getPort(final W3CEndpointReference participant, final AddressingProperties addressingProperties, final AttributedURI action)
{
+ addressingProperties.setFrom(coordinatorCompletionParticipant);
return WSBAClient.getCoordinatorCompletionCoordinatorPort(participant, action, addressingProperties);
}
}
\ No newline at end of file
Modified: labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/CoordinatorCompletionParticipantClient.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/CoordinatorCompletionParticipantClient.java 2008-04-23 15:47:08 UTC (rev 19698)
+++ labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/CoordinatorCompletionParticipantClient.java 2008-04-23 16:31:33 UTC (rev 19699)
@@ -33,9 +33,11 @@
import javax.xml.ws.addressing.AddressingBuilder;
import javax.xml.ws.addressing.AddressingProperties;
import javax.xml.ws.addressing.AttributedURI;
+import javax.xml.ws.addressing.EndpointReference;
import javax.xml.ws.wsaddressing.W3CEndpointReference;
import java.io.IOException;
import java.net.URISyntaxException;
+import java.net.URI;
/**
* The Client side of the Coordinator Participant Coordinator.
@@ -88,7 +90,7 @@
/**
* The coordinator completion coordinator URI for replies.
*/
- private AttributedURI coordinatorCompletionCoordinator = null;
+ private EndpointReference coordinatorCompletionCoordinator = null;
/**
* Construct the participant completion coordinator client.
@@ -116,10 +118,11 @@
// Add client policies
// ClientPolicy.register(handlerRegistry) ;
- final String coordinatorCompletionCoordinatorURI =
+ final String coordinatorCompletionCoordinatorURIString =
ServiceRegistry.getRegistry().getServiceURI(BusinessActivityConstants.COORDINATOR_COMPLETION_COORDINATOR_SERVICE_NAME) ;
try {
- coordinatorCompletionCoordinator = builder.newURI(coordinatorCompletionCoordinatorURI) ;
+ URI coordinatorCompletionCoordinatorURI = new URI(coordinatorCompletionCoordinatorURIString) ;
+ coordinatorCompletionCoordinator = builder.newEndpointReference(coordinatorCompletionCoordinatorURI);
} catch (URISyntaxException use) {
// TODO - log fault and throw exception
}
@@ -300,6 +303,7 @@
private BusinessAgreementWithCoordinatorCompletionParticipantPortType
getPort(final W3CEndpointReference participant, final AddressingProperties addressingProperties, final AttributedURI action)
{
+ addressingProperties.setFrom(coordinatorCompletionCoordinator);
return WSBAClient.getCoordinatorCompletionParticipantPort(participant, action, addressingProperties);
}
}
\ No newline at end of file
Modified: labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/ParticipantCompletionCoordinatorClient.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/ParticipantCompletionCoordinatorClient.java 2008-04-23 15:47:08 UTC (rev 19698)
+++ labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/ParticipantCompletionCoordinatorClient.java 2008-04-23 16:31:33 UTC (rev 19699)
@@ -34,9 +34,11 @@
import javax.xml.ws.addressing.AddressingBuilder;
import javax.xml.ws.addressing.AddressingProperties;
import javax.xml.ws.addressing.AttributedURI;
+import javax.xml.ws.addressing.EndpointReference;
import javax.xml.ws.wsaddressing.W3CEndpointReference;
import java.io.IOException;
import java.net.URISyntaxException;
+import java.net.URI;
/**
* The Client side of the Participant Completion Coordinator.
@@ -89,7 +91,7 @@
/**
* The participant completion participant URI for replies.
*/
- private AttributedURI participantCompletionParticipant = null;
+ private EndpointReference participantCompletionParticipant = null;
/**
* Construct the participant completion coordinator client.
@@ -117,10 +119,11 @@
// Add client policies
// ClientPolicy.register(handlerRegistry) ;
- final String participantCompletionParticipantURI =
+ final String participantCompletionParticipantURIString =
ServiceRegistry.getRegistry().getServiceURI(BusinessActivityConstants.PARTICIPANT_COMPLETION_PARTICIPANT_SERVICE_NAME) ;
try {
- participantCompletionParticipant = builder.newURI(participantCompletionParticipantURI) ;
+ URI participantCompletionParticipantURI = new URI(participantCompletionParticipantURIString) ;
+ participantCompletionParticipant = builder.newEndpointReference(participantCompletionParticipantURI);
} catch (URISyntaxException use) {
// TODO - log fault and throw exception
}
@@ -293,7 +296,7 @@
}
/**
- * obtain a port from the participant endpoint configured with the instance identifier handler and the supplied
+ * obtain a port from the coordinator endpoint configured with the instance identifier handler and the supplied
* addressing properties supplemented with the given action
* @param participant
* @param addressingProperties
@@ -303,6 +306,7 @@
private BusinessAgreementWithParticipantCompletionCoordinatorPortType
getPort(final W3CEndpointReference participant, final AddressingProperties addressingProperties, final AttributedURI action)
{
+ addressingProperties.setFrom(participantCompletionParticipant);
return WSBAClient.getParticipantCompletionCoordinatorPort(participant, action, addressingProperties);
}
}
\ No newline at end of file
Modified: labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/ParticipantCompletionParticipantClient.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/ParticipantCompletionParticipantClient.java 2008-04-23 15:47:08 UTC (rev 19698)
+++ labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/ParticipantCompletionParticipantClient.java 2008-04-23 16:31:33 UTC (rev 19699)
@@ -33,9 +33,11 @@
import javax.xml.ws.addressing.AddressingBuilder;
import javax.xml.ws.addressing.AddressingProperties;
import javax.xml.ws.addressing.AttributedURI;
+import javax.xml.ws.addressing.EndpointReference;
import javax.xml.ws.wsaddressing.W3CEndpointReference;
import java.io.IOException;
import java.net.URISyntaxException;
+import java.net.URI;
/**
* The Client side of the Participant Participant Coordinator.
@@ -84,7 +86,7 @@
/**
* The participant completion coordinator URI for replies.
*/
- private AttributedURI participantCompletionCoordinator = null;
+ private EndpointReference participantCompletionCoordinator = null;
/**
* Construct the participant completion coordinator client.
@@ -111,10 +113,11 @@
// Add client policies
// ClientPolicy.register(handlerRegistry) ;
- final String participantCompletionCoordinatorURI =
+ final String participantCompletionCoordinatorURIString =
ServiceRegistry.getRegistry().getServiceURI(BusinessActivityConstants.PARTICIPANT_COMPLETION_COORDINATOR_SERVICE_NAME) ;
try {
- participantCompletionCoordinator = builder.newURI(participantCompletionCoordinatorURI) ;
+ URI participantCompletionCoordinatorURI = new URI(participantCompletionCoordinatorURIString) ;
+ participantCompletionCoordinator = builder.newEndpointReference(participantCompletionCoordinatorURI);
} catch (URISyntaxException use) {
// TODO - log fault and throw exception
}
@@ -278,6 +281,7 @@
private BusinessAgreementWithParticipantCompletionParticipantPortType
getPort(final W3CEndpointReference participant, final AddressingProperties addressingProperties, final AttributedURI action)
{
+ addressingProperties.setFrom(participantCompletionCoordinator);
return WSBAClient.getParticipantCompletionParticipantPort(participant, action, addressingProperties);
}
}
\ No newline at end of file
Modified: labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/WSBAClient.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/WSBAClient.java 2008-04-23 15:47:08 UTC (rev 19698)
+++ labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/webservices11/wsba/client/WSBAClient.java 2008-04-23 16:31:33 UTC (rev 19699)
@@ -6,10 +6,7 @@
import org.jboss.ws.extensions.addressing.jaxws.WSAddressingClientHandler;
import javax.xml.ws.BindingProvider;
-import javax.xml.ws.addressing.AddressingBuilder;
-import javax.xml.ws.addressing.AddressingProperties;
-import javax.xml.ws.addressing.AttributedURI;
-import javax.xml.ws.addressing.JAXWSAConstants;
+import javax.xml.ws.addressing.*;
import javax.xml.ws.handler.Handler;
import javax.xml.ws.soap.AddressingFeature;
import javax.xml.ws.wsaddressing.W3CEndpointReference;
Modified: labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/wst11/messaging/engines/ParticipantCompletionParticipantEngine.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/wst11/messaging/engines/ParticipantCompletionParticipantEngine.java 2008-04-23 15:47:08 UTC (rev 19698)
+++ labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/wst11/messaging/engines/ParticipantCompletionParticipantEngine.java 2008-04-23 16:31:33 UTC (rev 19699)
@@ -948,6 +948,7 @@
private AddressingProperties createContext()
{
final String messageId = MessageId.getMessageId() ;
+
return AddressingHelper.createNotificationContext(messageId) ;
}
}
\ No newline at end of file
More information about the jboss-svn-commits
mailing list