在 WebSphere Application Server V6.1 中实现 WS_Notification

				
<?xml version="1.0" encoding="UTF-8">
<wsdl:definitions targetNamespace="com.cna.wsn/consumer" 
    xmlns="http://schemas.xmlsoap.org/wsdl/" 
    xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/" 
    xmlns:xsd="http://www.w3.org/2001/XMLSchema" 
    xmlns:wsn-bw="http://docs.oasis-open.org/wsn/bw-2" 
    xmlns:wsdlsoap="http://schemas.xmlsoap.org/wsdl/soap/" 
    xmlns:tns="com.cna.wsn/consumer" 
    xmlns:wsdl1="http://docs.oasis-open.org/wsn/bw-2">
    <wsdl:import namespace="http://docs.oasis-open.org/wsn/bw-2" location="bw-2.wsdl" />
    <wsdl:binding name="NotificationConsumerBinding" type="wsn-bw:NotificationConsumer">
        <wsdlsoap:binding style="document" 
                                    transport="http://schemas.xmlsoap.org/soap/http" />
        <wsdl:operation name="Notify">
            <wsdlsoap:operation soapAction="" />
            <wsdl:input>
                <wsdlsoap:body use="literal" />
            </wsdl:input>
        </wsdl:operation>
    </wsdl:binding>
    <wsdl:service name="NotificationConsumerService">
        <wsdl:port name="NotificationConsumerPort" 
                                          binding="tns:NotificationConsumerBinding">
            <wsdlsoap:address location="http://myserver.cna.com/Consumer" />
        </wsdl:port>
    </wsdl:service>
</wsdl:definitions>
      

				
package wsn.consumer.cna.com;

import java.util.Iterator;
import javax.xml.rpc.server.ServletEndpointContext;
import javax.xml.soap.SOAPElement;
import javax.xml.soap.SOAPFactory;
import org.apache.xml.serialize.OutputFormat;
import org.apache.xml.serialize.XMLSerializer;
import org.oasis_open.docs.wsn.bw_2.NotificationConsumer;
import com.ibm.websphere.sib.wsn.NotificationMessage;
import com.ibm.websphere.sib.wsn.TopicExpression;
import com.ibm.websphere.wsaddressing.EndpointReference;

public class NotificationConsumerBindingImpl implements NotificationConsumer{

    public void notify(NotificationMessage[] notificationMessage, SOAPElement[] any) 
                                                     throws java.rmi.RemoteException {
	
        System.out.println("Receiving Notification ...");
				
        // Process each NotificationMessage
        for (int i=0; i<notificationMessage.length; i++) {                
            NotificationMessage message = notificationMessage[i];
                
            // Get the contents of the message
            SOAPElement messageContent = message.getMessageContents();
            System.out.println("Notification message:");
            try{
                OutputFormat ouf = new OutputFormat();
                XMLSerializer serializer = new XMLSerializer(System.out,ouf);
                serializer.serialize(messageContent);
                System.out.println(" ");
            }
            catch(Exception e){
                e.printStackTrace();
            }
    		
            // Get the expression indicating which topic the message is associated with
            TopicExpression topic = message.getTopic();
            System.out.println("Notification topic:");
            System.out.println(topic.getTopic());
                
            // Get a reference to the producer (this is optional and so may be null)
            EndpointReference producerRef = message.getProducerReference();
            if(producerRef != null){
                System.out.println("Producer Reference: " + producerRef);
                try{
                    com.ibm.wsspi.wsaddressing.EndpointReference ref = 
                          (com.ibm.wsspi.wsaddressing.EndpointReference)producerRef;
                    SOAPFactory sFactory = SOAPFactory.newInstance();
                    SOAPElement sel = sFactory.createElement("root");
                    SOAPElement root = ref.getSOAPElement(sel);
                    ...................................
                }
                catch(Exception e){
                    e.printStackTrace();
                }
            }
                
            // Get a reference to the subscription (this is optional and so may be null)
            EndpointReference subscriptionRef = message.getSubscriptionReference();
            if(subscriptionRef != null){
                System.out.println("Subscription Reference: " + subscriptionRef);
                .............................................
            }
        }
        
        // Get information associated with the message
        if(any != null){
            for(int i=0; i < any.length; i++){
                SOAPElement extra = any[i];
                if(extra != null){
                    System.out.println("Additional information:");
					
                .........................................
                }
            }
         }    
     }
}
      

				
package com.cna.notification.tester;

import java.net.URI;
import java.util.Calendar;
import java.util.HashMap;
import java.util.Map;
import javax.xml.rpc.holders.CalendarHolder;
import javax.xml.soap.SOAPElement;
import javax.xml.soap.SOAPFactory;
import org.apache.xml.serialize.OutputFormat;
import org.apache.xml.serialize.XMLSerializer;
import org.oasis_open.docs.wsn.b_2.holders.AnyArrayHolder;
import org.w3.www.holders.EndpointReferenceTypeHolder;
import com.cna.services.container.epContainer;
import com.ibm.www.NotificationBroker;
import com.ibm.www.NotificationBrokerProxy;
import com.ibm.websphere.sib.wsn.AbsoluteOrRelativeTime;
import com.ibm.websphere.sib.wsn.Filter;
import com.ibm.websphere.sib.wsn.TopicExpression;
import com.ibm.wsspi.wsaddressing.EndpointReference;
import com.ibm.wsspi.wsaddressing.EndpointReferenceManager;


public class subscriberBasic {
	
    private NotificationBroker stub = null;
	
    public subscriberBasic(){

       try{

//          Get a stub for the port on which you want to invoke operations
            NotificationBrokerProxy proxy = new NotificationBrokerProxy();
            stub = proxy.getNotificationBroker();
			
        }
        catch(Exception e){
            System.out.println("Error creating service stub");
            e.printStackTrace();
        }
    }

    public void subscribe(String ep){
		
        if(stub == null)
            return;
		
//      Create the ConsumerReference. 
//      This contains the address of the consumer Web service which is being subscribed
		EndpointReference consumerEPR = null;
        try{
            URI epURI = new URI(ep);
            consumerEPR = EndpointReferenceManager.createEndpointReference(epURI);			
|-------10--------20--------30--------40--------50--------60--------70--------80--------9|
|-------- XML error:  The previous line is longer than the max of 90 characters ---------|
        }
        catch(Exception e){
            System.out.println("Error creating notification URI");
            e.printStackTrace();
        }
        if(consumerEPR == null)
            return;
		
//      Create the Filter. 
//      This provides the name of the topic to which you want to subscribe the consumer
        Filter filter = new Filter();

//      Create a topic expression and add it to the filter. The prefixMappings are 
//      mappings between namespace prefixes and their 
//      corresponding namespaces for prefixes used in the expression
        Map prefixMappings = new HashMap();
        prefixMappings.put("test", "http://www.cna.com/test/topic");
        TopicExpression exp = 
		      new TopicExpression(TopicExpression.SIMPLE_TOPIC_EXPRESSION, 
		                                      "test:TestTopic", prefixMappings);        
|-------10--------20--------30--------40--------50--------60--------70--------80--------9|
|-------- XML error:  The previous line is longer than the max of 90 characters ---------|
        filter.addTopicExpression(exp);
        
//      Create the InitialTerminationTime. 
//      This is the time when the subscription will terminate. 
        Calendar cal = Calendar.getInstance();
        cal.add(Calendar.YEAR, 1);
        AbsoluteOrRelativeTime initialTerminationTime = new AbsoluteOrRelativeTime(cal);
		        
//      Create the Policy information
        SOAPElement[] policyElements = null;
		        
//      Create holders to hold the multiple values returned from the broker:
//      The subscription reference
        EndpointReferenceTypeHolder subscriptionRefHolder = 
		                                         new EndpointReferenceTypeHolder();
|-------10--------20--------30--------40--------50--------60--------70--------80--------9|
|-------- XML error:  The previous line is longer than the max of 90 characters ---------|
		        
//      The current time at the broker
        CalendarHolder currentTimeHolder = new CalendarHolder();
		        
//      The termination time for the subscription
        CalendarHolder terminationTimeHolder = new CalendarHolder();
		        
//      Any additional elements
        AnyArrayHolder anyOtherElements = new AnyArrayHolder();

        try{
//          Invoke the Subscribe operation by calling the associated method on the stub
            System.out.println("Sending message to the Broker... ");
            stub.subscribe(consumerEPR,
		                       filter,
		                       initialTerminationTime,
		                       policyElements,
		                       anyOtherElements,
		                       subscriptionRefHolder,
		                       currentTimeHolder,
		                       terminationTimeHolder);
		        
//          Get the returned values:
//          An endpoint reference for the subscription is required for subsequent 
//          lifetime management of the subscription, for example pausing or canceling
//          of the subscription  
            com.ibm.websphere.wsaddressing.EndpointReference subscriptionRef = 
			                                            subscriptionRefHolder.value;
|-------10--------20--------30--------40--------50--------60--------70--------80--------9|
|-------- XML error:  The previous line is longer than the max of 90 characters ---------|
            System.out.println("Subscription Reference: " + subscriptionRef);
            epContainer.saveReference(subscriptionRef,0);
	..............................................        	
//          The current time at the broker
            Calendar currentTime = currentTimeHolder.value;
            System.out.println("Current Broker time: " + currentTime.toString());
		        
//          The termination time of the subscription
            Calendar terminationTime = terminationTimeHolder.value;
            System.out.println("Subscription termination time: " + 
                                                    terminationTime.toString());
		        
//          Any other information
            SOAPElement[] otherElements = anyOtherElements.value;
            if(otherElements != null){
                  ........................................
            }
        }
        catch(Exception e){
            System.out.println("Error invoking notification broker");
            e.printStackTrace();
        }
    }
}
     

				
package com.cna.notification.tester;

import java.net.URI;
import javax.xml.namespace.QName;
import javax.xml.soap.SOAPElement;
import javax.xml.soap.SOAPFactory;
import com.cna.services.container.epContainer;
import com.ibm.ws.wsaddressing.WSAConstants;
import com.ibm.websphere.wsaddressing.EndpointReference;
import com.ibm.www.SubscriptionManager;
import com.ibm.www.SubscriptionManagerProxy;

public class unsubscriber {
	
    private SubscriptionManager stub = null;
	
    public unsubscriber(){

        try{

//          Get a stub for the port on which you want to invoke operations
            SubscriptionManagerProxy proxy = new SubscriptionManagerProxy();
            stub = proxy.getSubscriptionManager();
        }
        catch(Exception e){
            System.out.println("Error creating service stub");
            e.printStackTrace();
        }
    }

    public void unsubscribe(int subs){
		
        if(stub == null)
            return;
	
//      Get the subscriptionReference. 		
        EndpointReference consumerEPR = epContainer.getReference(subs);
        if(consumerEPR == null){
            System.out.println("Unable to get ID");		        
            return;
        }
		
        try{
//          Invoke the Unsubscribe operation by calling the associated method
            System.out.println("Sending message to the Subscription Manger... ");
            ((javax.xml.rpc.Stub)stub)._setProperty(
            		WSAConstants.WSADDRESSING_DESTINATION_EPR, consumerEPR);
            stub.unsubscribe(null);
            System.out.println("Done unsbscribing ");		        
        }
        catch(Exception e){
            System.out.println("Error invoking notification broker");
            e.printStackTrace();
        }
    }
}
     

				
 package com.cna.notification.tester;

import java.util.HashMap;
import java.util.Map;
import javax.xml.soap.SOAPFactory;
import javax.xml.soap.SOAPElement;
import com.ibm.websphere.sib.wsn.NotificationMessage;
import com.ibm.websphere.sib.wsn.TopicExpression;
import com.ibm.www.NotificationBroker;
import com.ibm.www.NotificationBrokerProxy;

public class publisher {

    private NotificationBroker stub = null;
	
    public publisher(){

        try{
//          Get a stub for the port on which you want to invoke operations
            NotificationBrokerProxy proxy = new NotificationBrokerProxy();
            stub = proxy.getNotificationBroker();
        }
		catch(Exception e){
            System.out.println("Error creating service stub");
            e.printStackTrace();
        }
    }

    public void publish(){
		
        if(stub == null)
            return;
//      Create the message contents for a notification message
        SOAPElement messageContents = null;
        try{
            SOAPFactory soapFactory = SOAPFactory.newInstance();
            messageContents = soapFactory.createElement("MyData", 
			                            "cnaData", "http://www.cna.com/data");
            messageContents.addTextNode("Some notification data");
        }
        catch(Exception e){
            System.out.println("Error creating service stub");
            e.printStackTrace();
        }
                
//      Create a notification message from the contents
        NotificationMessage message = new NotificationMessage(messageContents);

//      Add a topic expression to the notification message 
        Map prefixMappings = new HashMap();
        prefixMappings.put("test", "http://www.cna.com/test/topic");
        TopicExpression exp = 
		      new TopicExpression(TopicExpression.SIMPLE_TOPIC_EXPRESSION, 
		                                   "test:TestTopic", prefixMappings);        
|-------10--------20--------30--------40--------50--------60--------70--------80--------9|
|-------- XML error:  The previous line is longer than the max of 90 characters ---------|
        message.setTopic(exp);

//      Invoke the Notify operation by calling the associated method on the stub
        try{
            System.out.println("Publishing Notification ...");
            stub.notify(new NotificationMessage[] { message }, null);
            System.out.println("Publishing successful");
        }
        catch(Exception e){
            System.out.println("Error publishing message");
            e.printStackTrace();
        }
    }
}
      

				
package com.cna.service.handler;

import javax.xml.namespace.QName;
import javax.xml.rpc.handler.GenericHandler;
import javax.xml.rpc.handler.MessageContext;
import javax.xml.rpc.handler.soap.SOAPMessageContext;
import javax.xml.soap.SOAPMessage;

public class debugHandler extends GenericHandler {

    public QName[] getHeaders() {
         return null;
    }

    public boolean handleRequest(MessageContext mc){
		
        System.out.println("Handling message request");
        printMessage(mc);
        System.out.println("Done handling message request");
        return true;
    }

    public boolean handleResponse(MessageContext mc){

        System.out.println("Handling message response");
        printMessage(mc);
        System.out.println("Done handling message response");
        return true;
	}
	
    private void printMessage(MessageContext mc){
		
        try{
            SOAPMessageContext smc = (SOAPMessageContext) mc;
            SOAPMessage sMessage = smc.getMessage();
            sMessage.writeTo(System.out);
            sMessage.saveChanges();
        }
        catch(Exception e){
            System.out.println("Error printing SOAP message");
            e.printStackTrace();
        }
    }
}
      

				
package com.cna.services.container;

import com.ibm.websphere.wsaddressing.EndpointReference;

public class epContainer {
		
    private static EndpointReference[] references = new EndpointReference[10];
	
    public static void saveReference(EndpointReference subscriptionRef, int id){
		
        references[id] = subscriptionRef;
    }

    public static EndpointReference getReference(int id){
		
        return references[id];
    }
}
      

				
<%@ page language="java" contentType="text/html; charset=ISO-8859-1"
    pageEncoding="ISO-8859-1"%>
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
<head>
<%@ page 
language="java"
%>
<jsp:useBean id="publisher" scope="session" 
                             class="com.cna.notification.tester.publisher" />
<meta http-equiv="Content-Type" content="text/html; charset=ISO-8859-1">
<title>WSN Publisher</title>
</head>
<body>
<P>Publishing to WSN ... </P>
<% publisher.publish(); %>
</body>
</html>
      

				
<soapenv:Envelope
    xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
    xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/"
    xmlns:xsd="http://www.w3.org/2001/XMLSchema"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
    <soapenv:Header />
    <soapenv:Body>
        <p38:Subscribe xmlns:p38="http://docs.oasis-open.org/wsn/b-2">
           <ConsumerReference xmlns="http://docs.oasis-open.org/wsn/b-2">
                <wsa:Address xmlns:wsa="http://www.w3.org/2005/08/addressing">
          http://localhost:9080/notificationConsumer/services/NotificationConsumerPort
                </wsa:Address>
            </ConsumerReference>
            <Filter xmlns="http://docs.oasis-open.org/wsn/b-2">
                <b2:TopicExpression
                    Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Simple"
                    xmlns:test="http://www.cna.com/test/topic"
                    xmlns:b2="http://docs.oasis-open.org/wsn/b-2">
                    test:TestTopic
                </b2:TopicExpression>
            </Filter>
            <InitialTerminationTime xmlns="http://docs.oasis-open.org/wsn/b-2">
                2007-09-11T13:07:18.332Z
            </InitialTerminationTime>
        </p38:Subscribe>
    </soapenv:Body>
</soapenv:Envelope>
	  

				
<soapenv:Envelope
    xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
    xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/"
    xmlns:xsd="http://www.w3.org/2001/XMLSchema"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:wsa="http://www.w3.org/2005/08/addressing">
    <soapenv:Header />
    <soapenv:Body>
        <p38:SubscribeResponse
            xmlns:p38="http://docs.oasis-open.org/wsn/b-2">
            <SubscriptionReference
                xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
                xmlns="http://docs.oasis-open.org/wsn/b-2"
                xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/"
                xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
                xmlns:xsd="http://www.w3.org/2001/XMLSchema"
                xmlns:wsa="http://www.w3.org/2005/08/addressing"
                xmlns:p38="http://docs.oasis-open.org/wsn/b-2">
                <wsa:Address xmlns:wsa="http://www.w3.org/2005/08/addressing">
        http://MXPCHWKAJXS.cna.com:9080/NotificationListener/soaphttpengine
        /myBus%2FMyPubSubSubscriptionManager%2FWSNServicePointSubscriptionManagerPort
                </wsa:Address>
                <wsa:ReferenceParameters
                    xmlns:wsa="http://www.w3.org/2005/08/addressing">
                    <wsaucf:RoutingInformation
                        xmlns:wsaucf="http://ucf.wsaddressing.ws.ibm.com">
                        <wsaucf:HAClusterId>
                            00000000020004747970650010575341465f5349425f4d455f
                            55554944000475756964001036383741343237323035383844423638
                        </wsaucf:HAClusterId>
                    </wsaucf:RoutingInformation>
                    <wsaucf:VirtualHostName
                        xmlns:wsaucf="http://ucf.wsaddressing.ws.ibm.com">
                        default_host
                    </wsaucf:VirtualHostName>
                    <subscriptionId
                        xmlns="http://www.ibm.com/websphere/wsn/reference">
                        sub_8bb445adce37a29598f6d3e2_10d9cfd2503_3
                    </subscriptionId>
                    <messagingEngineUuid
                        xmlns="http://www.ibm.com/websphere/wsn/reference">
                        687A42720588DB68
                    </messagingEngineUuid>
                </wsa:ReferenceParameters>
            </SubscriptionReference>
            <p38:CurrentTime>2006-09-11T13:07:18.403Z</p38:CurrentTime>
            <p38:TerminationTime>
                2007-09-11T13:07:18.332Z
            </p38:TerminationTime>
        </p38:SubscribeResponse>
    </soapenv:Body>
</soapenv:Envelope>
	  

				
<soapenv:Envelope
    xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
    xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/"
    xmlns:xsd="http://www.w3.org/2001/XMLSchema"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
    <soapenv:Header />
    <soapenv:Body>
        <p38:Notify xmlns:p38="http://docs.oasis-open.org/wsn/b-2">
            <NotificationMessage xmlns="http://docs.oasis-open.org/wsn/b-2">
                <b2:Topic
                    Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Simple"
                    xmlns:test="http://www.cna.com/test/topic"
                    xmlns:b2="http://docs.oasis-open.org/wsn/b-2">
                    test:TestTopic
                </b2:Topic>
                <b2:Message xmlns:b2="http://docs.oasis-open.org/wsn/b-2">
                    <cnaData:MyData xmlns:cnaData="http://www.cna.com/data">
                        Some notification data
                    </cnaData:MyData>
                </b2:Message>
            </NotificationMessage>
        </p38:Notify>
    </soapenv:Body>
</soapenv:Envelope>
	  

				
<soapenv:Envelope
    xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
    xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/"
    xmlns:xsd="http://www.w3.org/2001/XMLSchema"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:wsa="http://www.w3.org/2005/08/addressing">
    <soapenv:Header/>
    <soapenv:Body>
        <p38:Notify xmlns:p38="http://docs.oasis-open.org/wsn/b-2">
            <NotificationMessage xmlns="http://docs.oasis-open.org/wsn/b-2">
                <b2:SubscriptionReference
                    xmlns:b2="http://docs.oasis-open.org/wsn/b-2">
                        <wsa:Address 
                        xmlns:wsa="http://www.w3.org/2005/08/addressing">
    http://MXPCHWKAJXS.cna.com:9080/NotificationListener/soaphttpengine/
    myBus%2FMyPubSubSubscriptionManager%2FWSNServicePointSubscriptionManagerPort
                    </wsa:Address>
                    <wsa:ReferenceParameters
                        xmlns:wsa="http://www.w3.org/2005/08/addressing">
                        <wsaucf:RoutingInformation
                            xmlns:wsaucf="http://ucf.wsaddressing.ws.ibm.com">
                            <wsaucf:HAClusterId>
                                00000000020004747970650010575341465f5349425f4d455f555549
                                44000475756964001036383741343237323035383844423638
                            </wsaucf:HAClusterId>
                        </wsaucf:RoutingInformation>
                        <wsaucf:VirtualHostName
                            xmlns:wsaucf="http://ucf.wsaddressing.ws.ibm.com">
                            default_host
                        </wsaucf:VirtualHostName>
                        <subscriptionId
                            xmlns="http://www.ibm.com/websphere/wsn/reference">
                            sub_8bb445adce37a29598f6d3e2_10d9cfd2503_3
                        </subscriptionId>
                        <messagingEngineUuid
                            xmlns="http://www.ibm.com/websphere/wsn/reference">
                            687A42720588DB68
                        </messagingEngineUuid>
                    </wsa:ReferenceParameters>
                </b2:SubscriptionReference>
                <b2:Topic
                    Dialect="http://docs.oasis-open.org/wsn/t-1/TopicExpression/Simple"
                    xmlns:wsntopprefix="http://www.cna.com/test/topic"
                    xmlns:b2="http://docs.oasis-open.org/wsn/b-2">
                    wsntopprefix:TestTopic
                </b2:Topic>
                <b2:Message
                    xmlns:b2="http://docs.oasis-open.org/wsn/b-2">
                    <cnaData:MyData
                        xmlns:cnaData="http://www.cna.com/data">
                        Some notification data
                    </cnaData:MyData>
                </b2:Message>
            </NotificationMessage>
        </p38:Notify>
    </soapenv:Body>
</soapenv:Envelope>
	  

				
<soapenv:Envelope
    xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
    xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/"
    xmlns:xsd="http://www.w3.org/2001/XMLSchema"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
    <soapenv:Header />	
    <soapenv:Body>
        <p38:Unsubscribe xmlns:p38="http://docs.oasis-open.org/wsn/b-2" />	
    </soapenv:Body>
</soapenv:Envelope>
	  

				
EndpointReference consumerEPR = null;
QName pname = new QName("http://www.cna.com/data/name","name", "name");
try{
    URI epURI = new URI(ep);
    consumerEPR = EndpointReferenceManager.createEndpointReference(epURI);
			
    // Add custom parameter to the consumer reference
    SOAPFactory soapFactory = SOAPFactory.newInstance();
    SOAPElement param = soapFactory.createElement("param", "param", 
										"http://www.cna.com/data/param");
|-------10--------20--------30--------40--------50--------60--------70--------80--------9|
|-------- XML error:  The previous line is longer than the max of 90 characters ---------|
    param.addTextNode("Some parameter data");
    consumerEPR.setReferenceParameter(pname,param);
}
catch(Exception e){
    System.out.println("Error creating notification URI");
    e.printStackTrace();
}
	  

				
<ConsumerReference xmlns="http://docs.oasis-open.org/wsn/b-2">
    <wsa:Address xmlns:wsa="http://www.w3.org/2005/08/addressing">
        http://localhost:9080/notificationConsumer/services/NotificationConsumerPort
    </wsa:Address>
    <wsa:ReferenceParameters xmlns:wsa="http://www.w3.org/2005/08/addressing">
        <name:name xmlns:name="http://www.cna.com/data/name">
            <param:param xmlns:param="http://www.cna.com/data/param">
                Some parameter data
            </param:param>
        </name:name>
    </wsa:ReferenceParameters>
</ConsumerReference>
	  

				
<soapenv:Header>
	<name:name wsa:IsReferenceParameter="true"
			xmlns:name="http://www.cna.com/data/name"
			xmlns:wsa="http://www.w3.org/2005/08/addressing">
		<param:param xmlns:param="http://www.cna.com/data/param">
			Some parameter data
		</param:param>
	</name:name>
</soapenv:Header>
	  

				
public class NotificationConsumerBindingImpl 
                           implements NotificationConsumer, ServiceLifecycle{

    protected MessageContext context;

    public void init(Object ctx){

        System.out.println("Inside Service init method");
        // Initialize message context for the service use
        ServletEndpointContext sc = (ServletEndpointContext)ctx;
        if(ctx != null)
            context = sc.getMessageContext();
        else
            context = null;
    }

    public void destroy(){

        System.out.println("Inside Service destroy method");
    }
	
    public void notify(NotificationMessage[] notificationMessage, SOAPElement[] any) 
	                                                throws java.rmi.RemoteException {

        System.out.println("Recieving Notification ...");
		
        try{
            SOAPMessageContext smc = (SOAPMessageContext) context;
            SOAPMessage sMessage = smc.getMessage();
            SOAPHeader header = sMessage.getSOAPHeader();
            if(header != null){
                Iterator elements = header.getChildElements();
                while(elements.hasNext()){
                    SOAPElement hElement = (SOAPElement)elements.next();
                    System.out.println("Additional SOAP header:");
                    OutputFormat ouf = new OutputFormat();
                    XMLSerializer serializer = new XMLSerializer(System.out,ouf);
                    serializer.serialize(hElement);
                    System.out.println(" ");
                }
            }
        }
        catch(Exception e){
            System.out.println("Error getting additional SOAP headers");
            e.printStackTrace();
        }
    .................................
    }
}