Package org.apache.axis2.clientapi

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

169
170
171
172
173
174
175
176
177
178
179
          Constants.VALUE_TRUE);

      rmMsgCtx.getMessageContext().setProperty(
          Sandesha2Constants.ACK_WRITTEN, "true");
      try {
        engine.send(ackRMMsgCtx.getMessageContext());
      } catch (AxisFault e1) {
        throw new SandeshaException(e1.getMessage());
      }
    } else {
View Full Code Here
249
250
251
252
253
254
255
256
257
258
259
     
      ackMsgCtx.setTransportOut(new Sandesha2TransportOutDesc ());
     
      AxisEngine engine = new AxisEngine (configurationContext);
      try {
        engine.send(ackMsgCtx);
      } catch (AxisFault e) {
        throw new SandeshaException (e.getMessage());
      }
     
      SandeshaUtil.startSenderForTheSequence(configurationContext,sequenceID);
View Full Code Here
149
150
151
152
153
154
155
156
157
158
159
            }

            oc.addMessageContext(mc);
            // ship it out
            AxisEngine engine = new AxisEngine(cc);
            engine.send(mc);
        }

    }

    public OperationContext getOperationContext() {
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
        AxisEngine ae = new AxisEngine(messageContext.getConfigurationContext());
        try {
            messageContext.setProperty(Constants.ISRESPONSE_PROPERTY, Boolean.TRUE);
            // check for addressing is alredy engaged for this message.
            // if engage we should use the address enable Configuraion context.
            ae.send(messageContext);

        } catch (AxisFault e) {
            throw new SynapseException(e);
        }
    }
View Full Code Here
140
141
142
143
144
145
146
147
148
149
150
                // Building a nicely formatted fault
                envelope.getBody().addFault(toSoapFault(e, soapFactory));
            }
            AxisEngine engine = new AxisEngine(
                    msgContext.getOperationContext().getServiceContext().getConfigurationContext());
            engine.send(outMsgContext);
        } catch (IllegalAccessException e) {
            throw new OdeFault("Couldn't invoke method named " + methodName + " in management interface!", e);
        } catch (InvocationTargetException e) {
            throw new OdeFault("Invocation of method " + methodName + " in management interface failed!", e.getTargetException());
        }
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
                        + msgContext.getAxisOperation().getName());
                __log.debug("Reply message " + outMsgContext.getEnvelope());
            }
            AxisEngine engine = new AxisEngine(msgContext.getOperationContext().getServiceContext()
                    .getConfigurationContext());
            engine.send(outMsgContext);
        } else {
            if (__log.isDebugEnabled())
                __log.debug("Received one-way message for " + msgContext.getAxisService().getName() + "."
                        + msgContext.getAxisOperation().getName());
            invokeBusinessLogic(msgContext, null);
View Full Code Here
274
275
276
277
278
279
280
281
282
283
284
            OMElement responseOp = factory.createOMElement(op, _pmapi);
            responseOp.addChild(response);
            envelope.getBody().addChild(response);
            AxisEngine engine = new AxisEngine(
                    messageContext.getOperationContext().getServiceContext().getConfigurationContext());
            engine.send(outMsgContext);
        }
    }

    private static void copyInputStream(InputStream in, OutputStream out)
            throws IOException {
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
                        + msgContext.getAxisOperation().getName());
        __log.debug("Reply message " + outMsgContext.getEnvelope());
      }
            AxisEngine engine = new AxisEngine(msgContext.getOperationContext().getServiceContext()
                    .getConfigurationContext());
      engine.send(outMsgContext);
    } else {
            if (__log.isDebugEnabled())
                __log.debug("Received one-way message for " + msgContext.getAxisService().getName() + "."
                        + msgContext.getAxisOperation().getName());
            invokeBusinessLogic(msgContext, null);
View Full Code Here
127
128
129
130
131
132
133
134
135
136
137
                            "." + msgContext.getAxisOperation().getName());
                    __log.debug("Reply mgmt message " + outMsgContext.getEnvelope());
                }
                AxisEngine engine = new AxisEngine(
                        msgContext.getOperationContext().getServiceContext().getConfigurationContext());
                engine.send(outMsgContext);
            }
        } catch (IllegalAccessException e) {
            throw new OdeFault("Couldn't invoke method named " + methodName + " in management interface!", e);
        } catch (InvocationTargetException e) {
            throw new OdeFault("Invocation of method " + methodName + " in management interface failed!", e);
View Full Code Here
116
117
118
119
120
121
122
123
124
125
126
        TestLogger.logger.debug("[server] response message [" + responseEnv.toString() + "]");
       
        response.getOperationContext().addMessageContext(response);
        AxisEngine engine = new AxisEngine(response.getConfigurationContext());
        engine.send(response);   
    }
   
    /*
     * Verify that the AxisOperation on the MessageContext is the
     * one that we were expecting based on the request.
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.