Package org.apache.ws.pubsub

Examples of org.apache.ws.pubsub.wsaSOAPConnection


      org.apache.ws.notification.pubsub.Subscription ls      = this.sH.create(  );
      SubscribeResponseDocument.SubscribeResponse    sresres = null;
      try
      {
         //now call
         wsaSOAPConnection sconn = wsaSOAPConnection.newInstance(  );
         MessageFactory    mf    = MessageFactory.newInstance(  );
         SOAPMessage       soapm = mf.createMessage(  );

         //put XMLbean into SOAPBody
         soapm.getSOAPBody(  ).addDocument( (org.w3c.dom.Document) sdom.newDomNode(  ) );
         SOAPMessage                   subscribeResponse = sconn.call( soapm,
                                                                       epr.getAddress(  ).toString(  ) );
         java.io.ByteArrayOutputStream os = new java.io.ByteArrayOutputStream(  );
         subscribeResponse.writeTo( os );
         EnvelopeDocument sres =
            EnvelopeDocument.Factory.parse( new java.io.ByteArrayInputStream( os.toByteArray(  ) ) );
View Full Code Here


      SubscribeResponseDocument.SubscribeResponse sresres = null;
      try
      {
         //now call
         wsaSOAPConnection sconn = wsaSOAPConnection.newInstance(  );
         MessageFactory    mf    = MessageFactory.newInstance(  );
         SOAPMessage       soapm = mf.createMessage(  );

         //put XMLbean into SOAPBody
         soapm.getSOAPBody(  ).addDocument( (org.w3c.dom.Document) sdom.newDomNode(  ) );
         SOAPMessage                   subscribeResponse = sconn.call( soapm,
                                                                       epr.getAddress(  ).toString(  ) );
         java.io.ByteArrayOutputStream os = new java.io.ByteArrayOutputStream(  );
         subscribeResponse.writeTo( os );
         EnvelopeDocument sres =
            EnvelopeDocument.Factory.parse( new java.io.ByteArrayInputStream( os.toByteArray(  ) ) );
View Full Code Here

      RenewDocument.Renew r = rdom.addNewRenew(  );
      r.setExpires( terminationTime );
      try
      {
         //now call
         wsaSOAPConnection sconn = wsaSOAPConnection.newInstance(  );
         MessageFactory    mf    = MessageFactory.newInstance(  );
         SOAPMessage       soapm = mf.createMessage(  );

         //put XMLbean into SOAPBody
         soapm.getSOAPBody(  ).addDocument( (org.w3c.dom.Document) rdom.newDomNode(  ) );

         sconn.call( soapm,
                     getEndpointReference(  ) );
      }
      catch ( Exception e )
      {
         e.printStackTrace(  );
View Full Code Here

      UnsubscribeDocument usdom = UnsubscribeDocument.Factory.newInstance(  );
      usdom.addNewUnsubscribe(  );
      try
      {
         //now call
         wsaSOAPConnection sconn = wsaSOAPConnection.newInstance(  );
         MessageFactory    mf    = MessageFactory.newInstance(  );
         SOAPMessage       soapm = mf.createMessage(  );

         //put XMLbean into SOAPBody
         soapm.getSOAPBody(  ).addDocument( (org.w3c.dom.Document) usdom.newDomNode(  ) );

         sconn.call( soapm,
                     getEndpointReference(  ) );
      }
      catch ( Exception e )
      {
         e.printStackTrace(  );
View Full Code Here

        //add to local SubscriptionHome       
        org.apache.ws.notification.pubsub.Subscription ls = this.sH.create();        
        SubscribeResponseDocument.SubscribeResponse sresres=null;
        try{
            //now call
            wsaSOAPConnection sconn = wsaSOAPConnection.newInstance();
            MessageFactory mf = MessageFactory.newInstance();
            SOAPMessage soapm = mf.createMessage();
            //put XMLbean into SOAPBody
            soapm.getSOAPBody().addDocument((org.w3c.dom.Document) sdom.newDomNode());
            SOAPMessage subscribeResponse = sconn.call(soapm, epr.getAddress().toString());
            java.io.ByteArrayOutputStream os = new java.io.ByteArrayOutputStream();
            subscribeResponse.writeTo(os);
            EnvelopeDocument sres = EnvelopeDocument.Factory.parse(new java.io.ByteArrayInputStream(os.toByteArray()));

            //extract SubscribeResponse from SOAPBody
View Full Code Here

            filter.newCursor().setTextValue((String)xf.getExpression());
        }
        SubscribeResponseDocument.SubscribeResponse sresres=null;
        try{
            //now call
            wsaSOAPConnection sconn = wsaSOAPConnection.newInstance();
            MessageFactory mf = MessageFactory.newInstance();
            SOAPMessage soapm = mf.createMessage();
            //put XMLbean into SOAPBody
            soapm.getSOAPBody().addDocument((org.w3c.dom.Document) sdom.newDomNode());
            SOAPMessage subscribeResponse = sconn.call(soapm, epr.getAddress().toString());
            java.io.ByteArrayOutputStream os = new java.io.ByteArrayOutputStream();
            subscribeResponse.writeTo(os);
            EnvelopeDocument sres = EnvelopeDocument.Factory.parse(new java.io.ByteArrayInputStream(os.toByteArray()));
           
            //TODO handle faults
View Full Code Here

    public void unsubscribe(){
        UnsubscribeDocument usdom= UnsubscribeDocument.Factory.newInstance();
        usdom.addNewUnsubscribe();
        try{
            //now call
            wsaSOAPConnection sconn = wsaSOAPConnection.newInstance();
            MessageFactory mf = MessageFactory.newInstance();
            SOAPMessage soapm = mf.createMessage();
            //put XMLbean into SOAPBody
            soapm.getSOAPBody().addDocument((org.w3c.dom.Document) usdom.newDomNode());
           
            sconn.call(soapm,getEndpointReference());
        }catch(Exception e){
            e.printStackTrace();
        }           
    }
View Full Code Here

        RenewDocument rdom = RenewDocument.Factory.newInstance();
        RenewDocument.Renew r = rdom.addNewRenew();
        r.setExpires(terminationTime);
        try{
            //now call
            wsaSOAPConnection sconn = wsaSOAPConnection.newInstance();
            MessageFactory mf = MessageFactory.newInstance();
            SOAPMessage soapm = mf.createMessage();
            //put XMLbean into SOAPBody
            soapm.getSOAPBody().addDocument((org.w3c.dom.Document) rdom.newDomNode());
           
            sconn.call(soapm,getEndpointReference());
        }catch(Exception e){
            e.printStackTrace();
        }           
    }  
View Full Code Here

      SubscribeResponseDocument.SubscribeResponse sresres = null;
      try
      {
         //now call
         wsaSOAPConnection sconn = wsaSOAPConnection.newInstance(  );
         MessageFactory    mf    = MessageFactory.newInstance(  );
         SOAPMessage       soapm = mf.createMessage(  );

         //put XMLbean into SOAPBody
         soapm.getSOAPBody(  ).addDocument( (org.w3c.dom.Document) sdom.newDomNode(  ) );
         SOAPMessage                   subscribeResponse = sconn.call( soapm,
                                                                       epr.getAddress(  ).toString(  ) );
         java.io.ByteArrayOutputStream os = new java.io.ByteArrayOutputStream(  );
         subscribeResponse.writeTo( os );
         EnvelopeDocument sres =
            EnvelopeDocument.Factory.parse( new java.io.ByteArrayInputStream( os.toByteArray(  ) ) );
View Full Code Here

      RenewDocument.Renew r = rdom.addNewRenew(  );
      r.setExpires( terminationTime );
      try
      {
         //now call
         wsaSOAPConnection sconn = wsaSOAPConnection.newInstance(  );
         MessageFactory    mf    = MessageFactory.newInstance(  );
         SOAPMessage       soapm = mf.createMessage(  );

         //put XMLbean into SOAPBody
         soapm.getSOAPBody(  ).addDocument( (org.w3c.dom.Document) rdom.newDomNode(  ) );

         sconn.call( soapm,
                     getEndpointReference(  ) );
      }
      catch ( Exception e )
      {
         e.printStackTrace(  );
View Full Code Here

TOP

Related Classes of org.apache.ws.pubsub.wsaSOAPConnection

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.