List of sendRobust() Examples

Examples of sendRobust()

org.apache.axis2.client.ServiceClient.sendRobust()
Directly invoke an anonymous operation with a Robust In-Only MEP. This method just sends your supplied XML and possibly receives a fault. For more control, you can instead create a client for the operation and use that client to execute the send. @param elem XML to send @throws AxisFault if something goes wrong while sending, or if a fault is received inresponse (per the Robust In-Only MEP). @see #createClient(QName)

Examples of org.apache.axis2.client.ServiceClient.sendRobust()

            client.addHeader(msgId);
            client.addHeader(to);
        }
        client.setOptions(opts);


        client.sendRobust(message);
    }


    public void setTerminationTime(Calendar cal) throws AxisFault {
        String uuid = UUIDGenerator.getUUID();
        opts.setMessageId(uuid);

View Full Code Here

Examples of org.apache.axis2.client.ServiceClient.sendRobust()

            client.addHeader(action);
            client.addHeader(msgId);
            client.addHeader(to);
        }
        client.setOptions(opts);
        client.sendRobust(message);


    }


    public List<OMElement> getResourceProperty(QName qn) throws AxisFault { // List<XmlElement>

View Full Code Here

Examples of org.apache.axis2.client.ServiceClient.sendRobust()

        OMElement header = fac.createOMElement(new QName(TOPIC_HEADER_NS, TOPIC_HEADER_NAME));
        header.setText(topic);
        serviceClient.addHeader(header);
        serviceClient.getOptions().setTo(new EndpointReference(brokerUrl+"/publish"));
        //serviceClient.getOptions().setTo(new EndpointReference(brokerUrl));
        serviceClient.sendRobust(element);
    }
    
    public void unsubscribe(String subscriptionID) throws RemoteException{
        log.debug("Unsubscribed to "+ subscriptionID);
        EventBrokerServiceStub service = new EventBrokerServiceStub(configurationContext, brokerUrl);

View Full Code Here

Examples of org.apache.axis2.client.ServiceClient.sendRobust()

        options.setAction("urn:echo");
        ServiceClient servicClient = new ServiceClient();


        servicClient.setOptions(options);


        servicClient.sendRobust(getPayload());
    }


    private static OMElement getPayload() {
        OMFactory fac = OMAbstractFactory.getOMFactory();
        OMNamespace omNs = fac.createOMNamespace(

View Full Code Here

Examples of org.apache.axis2.client.ServiceClient.sendRobust()

                new EndpointReference(toEpr));
        ServiceClient servicClient = new ServiceClient();


        servicClient.setOptions(options);


        servicClient.sendRobust(getPayload());
    }


    private static OMElement getPayload() {
        OMFactory fac = OMAbstractFactory.getOMFactory();
        OMNamespace omNs = fac.createOMNamespace(

View Full Code Here

Examples of org.apache.axis2.client.ServiceClient.sendRobust()

        ConfigurationContext configContext =
                ConfigurationContextFactory.createConfigurationContextFromFileSystem(null, null);
        ServiceClient sender = new ServiceClient(configContext, null);
        sender.setOptions(options);


        sender.sendRobust(payload);
        String value = System.getProperty("echoOMElementNoResponse");
        System.setProperty("echoOMElementNoResponse", "");
        assertEquals(value, "echoOMElementNoResponse");
    }

View Full Code Here

Examples of org.apache.axis2.client.ServiceClient.sendRobust()

                ConfigurationContextFactory.createConfigurationContextFromFileSystem(null, null);
        ServiceClient sender = new ServiceClient(configContext, null);
        sender.setOptions(options);


        try {
            sender.sendRobust(payload);
            TestCase.fail("Shoud get an exception");
        } catch (AxisFault axisFault) {
            assertEquals("Invoked the service", axisFault.getMessage());
        }

View Full Code Here

Examples of org.apache.axis2.client.ServiceClient.sendRobust()

                new EndpointReference(toEpr));
        ServiceClient servicClient = new ServiceClient();


        servicClient.setOptions(options);


        servicClient.sendRobust(getPayload());
    }


    private static OMElement getPayload() {
        OMFactory fac = OMAbstractFactory.getOMFactory();
        OMNamespace omNs = fac.createOMNamespace(

View Full Code Here

Examples of org.apache.axis2.client.ServiceClient.sendRobust()

                new EndpointReference(toEpr));
        ServiceClient servicClient = new ServiceClient();


        servicClient.setOptions(options);


        servicClient.sendRobust(getPayload());
    }


    private static OMElement getPayload() {
        OMFactory fac = OMAbstractFactory.getOMFactory();
        OMNamespace omNs = fac.createOMNamespace(

View Full Code Here

Examples of org.apache.axis2.client.ServiceClient.sendRobust()

                new EndpointReference("http://localhost:" + httpPort
                        + "/admin/services/SecurityVerifierService");
        opts.setTo(epr);


        client.setOptions(opts);
        client.sendRobust(createPayLoad());   // robust send. Will get reply only if there is a fault
        log.info("sent the message");
    }


    private OMElement createPayLoad() {
            OMFactory fac = OMAbstractFactory.getOMFactory();

View Full Code Here

0 1 2

TOP

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.