Package xsul.xwsif_runtime

Examples of xsul.xwsif_runtime.WSIFClient

186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
//      WSIFService service = WSIFServiceFactory.newInstance().getService(
//          WSDLUtil.wsdlDefinitions5ToWsdlDefintions3(proxyWSDL) );
//            WSIFPort port = service.getPort();
//            WSIFClient wclient = WSIFRuntime.getDefault().newClientFor(port);
           
      WSIFClient wclient = WSIFRuntime.newClient(engineURL.toString())
          .addHandler(
              new StickySoapHeaderHandler("use-lead-header",
                  leadContext)).useAsyncMessaging(correlator)
          .setAsyncResponseTimeoutInMs(33000L); // to simplify testing
      // set to just few
      // seconds

      WSIFPort port = wclient.getPort();
      WSIFOperation operation = port.createOperation("deploy");

      WSIFMessage outputMessage = operation.createOutputMessage();
      WSIFMessage faultMessage = operation.createFaultMessage();
      XmlElement inputMessageElement = xmlObjectToEl(getDeploymentPayload(
View Full Code Here
367
368
369
370
371
372
373
374
375
376
377
    WSDLCleaner.cleanWSDL(streamEngine);

    WSIFService service = WSIFServiceFactory.newInstance().getService(
        WSDLUtil.wsdlDefinitions5ToWsdlDefintions3(streamEngine));
    WSIFPort port = service.getPort();
    WSIFClient client = WSIFRuntime.getDefault().newClientFor(port);

    String operationName = "registerQuery";
    WSIFOperation operation = port.createOperation(operationName);
    WSIFMessage inputMessage = operation.createInputMessage();
    WSIFMessage outputMessage = operation.createOutputMessage();
View Full Code Here
463
464
465
466
467
468
469
470
471
472
473
474
475
    WSIFServiceFactory factory = WSIFServiceFactory.newInstance();

    WSIFService service = factory.getService(WSDLUtil
        .wsdlDefinitions5ToWsdlDefintions3(streamEngine));
    WSIFClient client = WSIFRuntime.getDefault()
        .newClientFor(service, null);
    WSIFPort port = client.getPort();
    String operationName = "registerQuery";
    WSIFOperation operation = port.createOperation(operationName);
    WSIFMessage inputMessage = operation.createInputMessage();
    WSIFMessage outputMessage = operation.createOutputMessage();
    WSIFMessage faultMessage = operation.createFaultMessage();
View Full Code Here
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
      correlator = null;

      // pass some headers
      LeadContextHeader leadContext = getLeadContextHeader();

      WSIFClient wclient = WSIFRuntime.newClient(engineURL.toString())
          .addHandler(
              new StickySoapHeaderHandler("use-lead-header",
                  leadContext)).useAsyncMessaging(correlator)
          .setAsyncResponseTimeoutInMs(33000L); // to simplify testing
      // set to just few
      // seconds

      WSIFPort port = wclient.getPort();
      WSIFOperation operation = port.createOperation("createInstance");

      WSIFMessage outputMessage = operation.createOutputMessage();
      WSIFMessage faultMessage = operation.createFaultMessage();
View Full Code Here
260
261
262
263
264
265
266
267
268
269
270
271
272
            Map<String, String> outputMap, MonitorNotifier notifier) {

        WSIFServiceFactory factory = WSIFServiceFactory.newInstance();
        WSIFService service = factory.getService(WSDLUtil
                .wsdlDefinitions5ToWsdlDefintions3(definitions));
        WSIFClient client = WSIFRuntime.getDefault()
                .newClientFor(service, null);
        WSIFPort port = client.getPort();
        WSIFOperation operation = port.createOperation(operationName);
        WSIFMessage inputMessage = operation.createInputMessage();

        for (String key : inputMap.keySet()) {
            String value = inputMap.get(key);
View Full Code Here
504
505
506
507
508
509
510
511
512
513
514
515
516
517
    LeadContextHeader leadContextHeader = new LeadContextHeader("NEI", dn);
    leadContextHeader.setUserDn(dn);
    StickySoapHeaderHandler soapHeaderHandler = new StickySoapHeaderHandler(
        "use-lead-header", leadContextHeader);

    WSIFClient wcl = XmlBeansWSIFRuntime.newClient(wsdlLoc);
    wcl.addHandler(soapHeaderHandler);

    AgentPortType stub = (AgentPortType) wcl
        .generateDynamicStub(AgentPortType.class);

    return stub;

  }
View Full Code Here
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
   
   
   
    public static WSIFClient createWSIFClient(ApplicationGlobalContext globalConfiguration,
            String serviceURL,GSSCredential sessionCredentail) throws GfacException {
        WSIFClient client;
        if (serviceURL.startsWith("https")) {
            SoapHttpDynamicInfosetInvoker invoker = createSecureInvoker(globalConfiguration);
            String wsdlAsStr = invoker.invokeHttpGet(serviceURL);
            // System.out.println(wsdlAsStr);
            XmlElement el = XmlConstants.BUILDER
                    .parseFragmentFromReader(new StringReader(wsdlAsStr));
            WsdlDefinitions def = new WsdlDefinitions(el);
            WSIFServiceFactory wsf = WSIFServiceFactory.newInstance();
            WSIFService serv = wsf.getService(def);
            serv.addLocalProvider(new Provider(invoker));
            client = XmlBeansWSIFRuntime.getDefault().newClientFor(serv.getPort());
            ((XsulSoapPort) client.getPort()).setInvoker(invoker);
        } else {
            client = XmlBeansWSIFRuntime.newClient(serviceURL);
        }
        return client;
    }
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
        }
    }
   
    public static WSIFClient createWSIFClient(GlobalContext globalConfiguration,
            String serviceURL) throws XregistryException {
        WSIFClient client;
        try {
            if (serviceURL.startsWith("https")) {
                boolean useHostKey = true;

                if (globalConfiguration == null) {
                    throw new XregistryException(
                            "To make Secure WSIF client Global configuration must nor be Null");
                }
                SoapHttpDynamicInfosetInvoker invoker = createSecureInvoker(globalConfiguration,
                        useHostKey);
                String wsdlAsStr = invoker.invokeHttpGet(serviceURL);
                // System.out.println(wsdlAsStr);
                XmlElement el = XmlConstants.BUILDER
                        .parseFragmentFromReader(new StringReader(wsdlAsStr));
                WsdlDefinitions def = new WsdlDefinitions(el);
               
               
                WSIFServiceFactory wsf = WSIFServiceFactory.newInstance();
                WSIFService serv = wsf.getService(def);
                serv.addLocalProvider(new Provider(invoker));
                client = XmlBeansWSIFRuntime.getDefault().newClientFor(serv.getPort());
                ((XsulSoapPort) client.getPort()).setInvoker(invoker);
               
               
               
//                WsdlResolver wsdlResolver = WsdlResolver.getInstance();
//                wsdlResolver.setSecureInvoker(invoker);
View Full Code Here
92
93
94
95
96
97
98
99
100
101
      GlobalContext globalContext = new GlobalContext(true);
       String trustedCA = System.getProperty("ssl.hostcertsKeyFile");
      String hostCert =  System.getProperty("ssl.trustedCertsFile");
    globalContext.setTrustedCertsFile(trustedCA);
    globalContext.setHostcertsKeyFile(hostCert);
      WSIFClient client = Utils.createWSIFClient(globalContext, registryServiceWsdlUrl);
        proxy = (XregistryPortType)client.generateDynamicStub(XregistryPortType.class);
        userDN = globalContext.getUserDN();
        System.out.println("Create Stub for "+ registryServiceWsdlUrl + " using "+ userDN);
    }
View Full Code Here
98
99
100
101
102
103
104
105
106
107
        proxy = (XregistryPortType)client.generateDynamicStub(XregistryPortType.class);
        userDN = globalContext.getUserDN();
        System.out.println("Create Stub for "+ registryServiceWsdlUrl + " using "+ userDN);
    }
    public DocumentRegistryClient(GlobalContext context,String registryServiceWsdlUrl) throws XregistryException{
        WSIFClient client = Utils.createWSIFClient(context, registryServiceWsdlUrl);
        proxy = (XregistryPortType)client.generateDynamicStub(XregistryPortType.class);
        userDN = context.getUserDN();
        System.out.println("Create Stub for "+ registryServiceWsdlUrl + " using "+ userDN);
    }
View Full Code Here
TOP

Related Classes of xsul.xwsif_runtime.WSIFClient

  • edu.indiana.extreme.gfac.utils.CredentialsUtils
  • edu.indiana.extreme.xbaya.gfac.SimpleWSClient
  • edu.indiana.extreme.xbaya.jython.lib.GenericInvoker
  • edu.indiana.extreme.xbaya.jython.lib.invoker.GFacInvoker
  • edu.indiana.extreme.xbaya.mylead.MyLeadAgentStub
  • edu.indiana.extreme.xbaya.ode.ODEClient
  • edu.indiana.extreme.xbaya.ode.ODEInvokerWindow
  • edu.indiana.extreme.xbaya.ProxyServiceTester
  • edu.indiana.extreme.xbaya.test.DSCTestCase
  • edu.indiana.extreme.xbaya.test.LEADWorkflowInvokerTestCase
    • 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.