Package org.apache.axis2.client

Examples of org.apache.axis2.client.MessageSender.send()

1160
1161
1162
1163
1164
1165
1166
1167
1168
1169
1170
     
      Boolean isTransportNonBlocking = (Boolean) msgContext.getProperty(MessageContext.TRANSPORT_NON_BLOCKING);
      if (isTransportNonBlocking!=null && isTransportNonBlocking.booleanValue()==true)
        msgContext.setProperty(MessageContext.TRANSPORT_NON_BLOCKING, Boolean.FALSE);
     
      engine.send(msgContext);
     
      msgContext.setProperty(MessageContext.TRANSPORT_NON_BLOCKING, isTransportNonBlocking);
    }

  }
View Full Code Here
193
194
195
196
197
198
199
200
201
202
203
            //if we don't do this , this guy will wait till it gets HTTP 202 in the HTTP case
            mc.setProperty(MessageContext.TRANSPORT_NON_BLOCKING, Boolean.TRUE);
            AxisEngine engine = new AxisEngine(cc);
            mc.getConfigurationContext().registerOperationContext(mc.getMessageID(), oc);
            engine.send(mc);
        } else {
            if (block) {
                // Send the SOAP Message and receive a response
                send(mc);
                // check for a fault and return the result
View Full Code Here
232
233
234
235
236
237
238
239
240
241
242
        responseMessageContext.setServiceContext(msgctx.getServiceContext());
        responseMessageContext.setAxisMessage(
                axisOp.getMessage(WSDLConstants.MESSAGE_LABEL_IN_VALUE));

        //sending the message
        engine.send(msgctx);
        responseMessageContext.setDoingREST(msgctx.isDoingREST());

        responseMessageContext.setProperty(MessageContext.TRANSPORT_IN, msgctx
                .getProperty(MessageContext.TRANSPORT_IN));
        responseMessageContext.setTransportIn(msgctx.getTransportIn());
View Full Code Here
242
243
244
245
246
247
248
249
250
251
        // ship it out
        AxisEngine engine = new AxisEngine(cc);
        if (!block) {
            mc.setProperty(MessageContext.TRANSPORT_NON_BLOCKING, Boolean.TRUE);
        }
        engine.send(mc);
        // all done
        completed = true;
    }
}
View Full Code Here
138
139
140
141
142
143
144
145
146
147
148
        try {
            messageContext.setProperty(Constants.ISRESPONSE_PROPERTY, Boolean.TRUE);
            // check if addressing is already engaged for this message.
            // if engaged we should use the addressing enabled Configuraion context.
            ae.send(messageContext);

        } catch (AxisFault e) {
            handleException("Unexpected error during Sending message back", e);
        }
    }
View Full Code Here
266
267
268
269
270
271
272
273
274
275
276
        mc.setProperty(MessageContext.TRANSPORT_NON_BLOCKING,
            Boolean.TRUE);
        AxisEngine engine = new AxisEngine(cc);
        mc.getConfigurationContext().registerOperationContext(
            mc.getMessageID(), oc);
        engine.send(mc);

        // Options object reused so soapAction needs to be removed so
        // that soapAction+wsa:Action on response don't conflict
        options.setAction("");
      } else {
View Full Code Here
338
339
340
341
342
343
344
345
346
347
348
      responseMessageContext.setServerSide(false);
      responseMessageContext.setMessageID(msgctx.getMessageID());
      addMessageContext(responseMessageContext);

      // sending the message
      engine.send(msgctx);

      // fix case where there is no response message (in-only)
      if (msgctx.getOperationContext().getMessageContext(
          WSDL2Constants.MESSAGE_LABEL_OUT).getProperty(
          MessageContext.TRANSPORT_IN) == null)
View Full Code Here
145
146
147
148
149
150
151
152
153
154
155
        try {
            messageContext.setProperty(Constants.ISRESPONSE_PROPERTY, Boolean.TRUE);
            // check if addressing is already engaged for this message.
            // if engaged we should use the addressing enabled Configuraion context.
            ae.send(messageContext);

        } catch (AxisFault e) {
            handleException("Unexpected error during Sending message back", e);
        }
    }
View Full Code Here
65
66
67
68
69
70
71
72
73
        log.debug("Executed EmptyRMMessageReceiver#receive() and Java Return for RMMediator");

        AxisEngine engine = new AxisEngine(
                messageContext.getOperationContext().getServiceContext().getConfigurationContext());
        engine.send(outMsgContext);

    }
}
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
                            org.apache.synapse.Constants.ISRESPONSE_PROPERTY, Boolean.TRUE);
                    mc.getOperationContext().setProperty(
                            Constants.RESPONSE_WRITTEN, Constants.VALUE_TRUE);
                    // check for addressing is alredy engaged for this message.
                    // if engage we should use the address enable Configuraion context.
                    ae.send(axisOutMsgContext);

                } catch (AxisFault e) {
                    log.error("Axis fault encountered while forwarding message to endpoint : "
                            + targetEndpoint, e);
                }
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.