Examples of pushFaultHandler()

Examples of org.apache.synapse.MessageContext.pushFaultHandler()

84
85
86
87
88
89
90
91
92
93
94
            List<FaultHandler> newFaultStack = new ArrayList<FaultHandler>();
            newFaultStack.addAll(faultStack);
           
            for (FaultHandler faultHandler : newFaultStack) {
                if (faultHandler != null) {
                    newCtx.pushFaultHandler(faultHandler);
                }
            }
        }

        if (log.isDebugEnabled()) {
View Full Code Here

Examples of org.apache.synapse.MessageContext.pushFaultHandler()

225
226
227
228
229
230
231
232
233
234
235
                        messageStore.wait(delay);
                    } catch (InterruptedException ignored) {

                    }

                    synCtx.pushFaultHandler((FaultHandler) storableMessage.getEndpoint());
                    storableMessage.getEndpoint().send(storableMessage.getMessageContext());

                    if (log.isDebugEnabled()) {
                        log.debug("Sent: " + storableMessage.getMessageContext().getEnvelope());
                    }
View Full Code Here

Examples of org.apache.synapse.MessageContext.pushFaultHandler()

78
79
80
81
82
83
84
85
86
87
88
            SynapseConstants.SYNAPSE_SERVICE_NAME);
        ((Axis2MessageContext) synCtx).setServiceLog(serviceLog);

        try {
            // set default fault handler
            synCtx.pushFaultHandler(new MediatorFaultHandler(synCtx.getFaultSequence()));

            // invoke synapse message mediation through the main sequence
            synCtx.getEnvironment().injectMessage(synCtx);

        } catch (SynapseException syne) {
View Full Code Here

Examples of org.apache.synapse.MessageContext.pushFaultHandler()

143
144
145
146
147
148
149
150
151
152
153
    }

        MessageContext mc = synapseEnvironment.createMessageContext();
//        AspectHelper.setGlobalAudit(mc);    TODO
        mc.pushFaultHandler(new MediatorFaultHandler(mc.getFaultSequence()));
        mc.setTo(new EndpointReference(to));
        if (format == null) {
            PayloadHelper.setXMLPayload(mc, message.cloneOMElement());
        } else {
            try {
View Full Code Here

Examples of org.apache.synapse.MessageContext.pushFaultHandler()

84
85
86
87
88
89
90
91
92
93
94
            List<FaultHandler> newFaultStack = new ArrayList<FaultHandler>();
            newFaultStack.addAll(faultStack);
           
            for (FaultHandler faultHandler : newFaultStack) {
                if (faultHandler != null) {
                    newCtx.pushFaultHandler(faultHandler);
                }
            }
        }

        if (log.isDebugEnabled()) {
View Full Code Here

Examples of org.apache.synapse.MessageContext.pushFaultHandler()

130
131
132
133
134
135
136
137
138
139
140
                newCtx.setProperty(EIPConstants.MESSAGE_SEQUENCE,
                                   String.valueOf(i++) + EIPConstants.MESSAGE_SEQUENCE_DELEMITER +
                                   children.size());
                // evaluate the endpoint properties
                evaluateProperties(newCtx);
                newCtx.pushFaultHandler(this);
                childEndpoint.send(newCtx);
            }
        }

        if (!foundEndpoint) {
View Full Code Here

Examples of org.apache.synapse.MessageContext.pushFaultHandler()

243
244
245
246
247
248
249
250
251
252
253
          + ":"
          + ("http".equals(transport) ? member.getHttpPort()
              : member.getHttpsPort()) + address);

      newCtx.setTo(epr);
      newCtx.pushFaultHandler(this);

      AddressEndpoint endpoint = new AddressEndpoint();
      EndpointDefinition definition = new EndpointDefinition();
      endpoint.setDefinition(definition);
      endpoint.init(newCtx.getEnvironment());
View Full Code Here

Examples of org.apache.synapse.MessageContext.pushFaultHandler()

84
85
86
87
88
89
90
91
92
93
94
            List<FaultHandler> newFaultStack = new ArrayList<FaultHandler>();
            newFaultStack.addAll(faultStack);
           
            for (FaultHandler faultHandler : newFaultStack) {
                if (faultHandler != null) {
                    newCtx.pushFaultHandler(faultHandler);
                }
            }
        }

        if (log.isDebugEnabled()) {
View Full Code Here

Examples of org.apache.synapse.MessageContext.pushFaultHandler()

81
82
83
84
85
86
87
88
89
90
91
            List<FaultHandler> newFaultStack = new ArrayList<FaultHandler>();
            newFaultStack.addAll(faultStack);
           
            for (FaultHandler faultHandler : newFaultStack) {
                if (faultHandler != null) {
                    newCtx.pushFaultHandler(faultHandler);
                }
            }
        }

        if (log.isDebugEnabled()) {
View Full Code Here

Examples of org.apache.synapse.MessageContext.pushFaultHandler()

80
81
82
83
84
85
86
87
88
89
90
            synapseServiceStack.put(SynapseConstants.SYNAPSE_SERVICE_NAME,
                System.currentTimeMillis(), !synCtx.isResponse(), true, isFault);
            synCtx.setProperty(SynapseConstants.SERVICE_STATS, synapseServiceStack);

            // set default fault handler
            synCtx.pushFaultHandler(new MediatorFaultHandler(
                        synCtx.getSequence(SynapseConstants.FAULT_SEQUENCE_KEY)));

            // invoke synapse message mediation through the main sequence
            synCtx.getEnvironment().injectMessage(synCtx);
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.