You are viewing a plain text version of this content. The canonical link for it is here.
Posted to pubscribe-dev@ws.apache.org by sc...@apache.org on 2005/05/26 20:06:37 UTC
svn commit: r178659 -
/incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/impl/SubscriptionTopicListener.java
Author: scamp
Date: Thu May 26 11:06:36 2005
New Revision: 178659
URL: http://svn.apache.org/viewcvs?rev=178659&view=rev
Log: (empty)
Modified:
incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/impl/SubscriptionTopicListener.java
Modified: incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/impl/SubscriptionTopicListener.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/impl/SubscriptionTopicListener.java?rev=178659&r1=178658&r2=178659&view=diff
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/impl/SubscriptionTopicListener.java (original)
+++ incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/impl/SubscriptionTopicListener.java Thu May 26 11:06:36 2005
@@ -20,6 +20,7 @@
import org.apache.commons.logging.LogFactory;
import org.apache.ws.XmlObjectWrapper;
import org.apache.ws.addressing.EndpointReference;
+import org.apache.ws.addressing.XmlBeansEndpointReference;
import org.apache.ws.addressing.v2003_03.AddressingConstants;
import org.apache.ws.notification.base.Subscription;
import org.apache.ws.notification.base.v2004_06.BaseNotificationConstants;
@@ -126,7 +127,7 @@
EndpointReference consumerEPR = m_subscription.getConsumerReference();
SOAPMessage soapMessage =
buildSOAPMessage( document,
- (EndpointReferenceType) ( (XmlObjectWrapper) consumerEPR ).getXmlObject() );
+ (EndpointReferenceType) ( (XmlBeansEndpointReference) consumerEPR ).getXmlObject(org.apache.ws.addressing.v2003_03.AddressingConstants.NSURI_ADDRESSING_SCHEMA) );
EMITTER_POOL.execute( EmitterTask.createEmitterTask( soapMessage,
new URL( consumerEPR.getAddress().toString() ) ) );
}
@@ -140,7 +141,7 @@
NotifyDocument.Notify notify = notifyDoc.addNewNotify();
NotificationMessageHolderType notifMsgHolder = notify.addNewNotificationMessage();
notifMsgHolder.setMessage( msg );
- notifMsgHolder.setProducerReference( (EndpointReferenceType) ( (XmlObjectWrapper) m_subscription.getProducerResource().getEndpointReference() ).getXmlObject() );
+ notifMsgHolder.setProducerReference( (EndpointReferenceType) ( (XmlBeansEndpointReference) m_subscription.getProducerResource().getEndpointReference() ).getXmlObject(org.apache.ws.addressing.v2003_03.AddressingConstants.NSURI_ADDRESSING_SCHEMA) );
TopicExpressionType topicExpr = (TopicExpressionType) ( (XmlObjectWrapper) m_subscription.getTopicExpression() ).getXmlObject();
notifMsgHolder.setTopic( topicExpr );
msg = notifyDoc;
---------------------------------------------------------------------
To unsubscribe, e-mail: hermes-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: hermes-dev-help@ws.apache.org