Package org.apache.axis2.transport

Examples of org.apache.axis2.transport.TransportSender.cleanup()

143
144
145
146
147
148
149
150
151
152
153
            if (index > 10) {
                throw new AxisFault(
                        "Server was shutdown as the async response take too long to complete");
            }
        }
        sender.cleanup();
    }

    public void testEchoXMLSync() throws Exception {
        OMElement payload = createPayload();
View Full Code Here
160
161
162
163
164
165
166
167
168
169
170
        sender.setOptions(options);
        OMElement result = sender.sendReceive(operationName, payload);

        result.serialize(StAXUtils.createXMLStreamWriter(
                System.out));
        sender.cleanup();
    }

    public void testEchoXMLCompleteSync() throws Exception {
        OMFactory fac = OMAbstractFactory.getOMFactory();
View Full Code Here
184
185
186
187
188
189
190
191
192
193
194
        sender.setOptions(options);
        OMElement result = sender.sendReceive(operationName, payloadElement);

        result.serialize(StAXUtils.createXMLStreamWriter(
                System.out));
        sender.cleanup();

    }

    public void testEchoXMLSyncMC() throws Exception {       
        AxisOperation opdesc = new OutInAxisOperation(new QName("echoOMElement"));
View Full Code Here
224
225
226
227
228
229
230
231
232
233
        MessageContext response = opClient.getMessageContext(WSDLConstants.MESSAGE_LABEL_IN_VALUE);
        SOAPEnvelope env = response.getEnvelope();
        assertNotNull(env);
        env.getBody().serialize(StAXUtils.createXMLStreamWriter(
                System.out));
        sender.cleanup();
    }


}
View Full Code Here
68
69
70
71
72
73
74
75
76
77
78
        OMElement message = createMessageEl(eventSinkReferenceEPR, filterEl, expireTime);

        ServiceClient serviceClient = createServiceClient(message);
        OMElement responseMessage = serviceClient.sendReceive(message);
        serviceClient.cleanup();
        serviceClient.cleanupTransport();
        if (responseMessage == null) {
            throw AxisFault.makeFault(new RuntimeException("no response recieved for subscription message"));
        }
        OMElement responseSubscriptionsManagerElement = responseMessage.getFirstChildWithName(new QName(
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
        message.addChild(publisherRef);

        ServiceClient client = createServiceClient(message);

        OMElement responseMessage = client.sendReceive(message);
        client.cleanup();
        client.cleanupTransport();

        OMElement publisherRegistrationRef = responseMessage.getFirstChildWithName(new QName(NameSpaceConstants.WSBR_NS
                .getNamespaceURI(), "PublisherRegistrationReference"));
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
        try {
            OMElement subscriptionMsg = WSEProtocolClient.createSubscription(eventSinkLocation, topicExpression,
                    xpathExpression, expireTime);
            ServiceClient serviceClient = configureServiceClientForSubscription(subscriptionMsg);
            OMElement responseMessage = serviceClient.sendReceive(subscriptionMsg);
            serviceClient.cleanup();
            serviceClient.cleanupTransport();

            if (responseMessage == null) {
                throw new MsgBrokerClientException("no response recieved for subscription message");
            }
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
    public static void clear(){
        CarbonUtils.checkSecurity();
        if (configCtx != null) {
            AxisConfiguration axisConfig = configCtx.getAxisConfiguration();
            if (axisConfig != null) {
                axisConfig.cleanup();
            }
            try {
                configCtx.terminate();
            } catch (AxisFault e) {
                log.error("Error occurred while terminating ConfigurationContext", e);
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
        MessageContext msgContext = new MessageContext();
        HttpMethod httpMethod = new GetMethod();
        msgContext.setProperty(HTTPConstants.HTTP_METHOD, httpMethod);
        assertNotNull("HttpMethod can not be null",
                msgContext.getProperty(HTTPConstants.HTTP_METHOD));
        sender.cleanup(msgContext);
        assertNull("HttpMethod should be null", msgContext.getProperty(HTTPConstants.HTTP_METHOD));

    }
   
    public void testInit() throws AxisFault {
View Full Code Here
39
40
41
42
43
44
45
46
47
        MessageContext msgContext = new MessageContext();
        HttpGet httpMethod = new HttpGet();
        msgContext.setProperty(HTTPConstants.HTTP_METHOD, httpMethod);
        assertNotNull("HttpMethod can not be null",
                msgContext.getProperty(HTTPConstants.HTTP_METHOD));
        sender.cleanup(msgContext);
        assertNull("HttpMethod should be null", msgContext.getProperty(HTTPConstants.HTTP_METHOD));
    }
}
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.