Examples of sendFault()


Examples of org.apache.sandesha.server.msgprocessors.FaultProcessor.sendFault()

                    msgContext.setPastPivot(true);
                }
            } catch (AxisFault af) {
                RMProvider.log.error(af);
                FaultProcessor faultProcessor = new FaultProcessor(storageManager, af);
                if (!faultProcessor.sendFault(rmMessageContext)) {
                    msgContext.setPastPivot(true);
                    msgContext.setResponseMessage(null);
                    return;
                }
                return;
View Full Code Here

Examples of org.switchyard.Exchange.sendFault()

   
    @Test
    public void testSendFaultOnNewExchange() {
        Exchange exchange = new ExchangeImpl(_domain, _dispatch);
        try {
            exchange.sendFault(exchange.createMessage());
            Assert.fail("Sending a fault on a new exchange is not allowed");
        } catch (IllegalStateException illEx) {
            return;
        }
    }
View Full Code Here

Examples of org.switchyard.bus.camel.CamelExchange.sendFault()

            Throwable content = detectHandlerException(exception);
            org.switchyard.Property rollbackOnFaultProperty = ex.getContext().getProperty(org.switchyard.Exchange.ROLLBACK_ON_FAULT);
            if (rollbackOnFaultProperty == null || rollbackOnFaultProperty.getValue() == null) {
                ex.getContext().setProperty(org.switchyard.Exchange.ROLLBACK_ON_FAULT, Boolean.TRUE, Scope.EXCHANGE);
            }
            ex.sendFault(ex.createMessage().setContent(content));
            ExchangeHelper.setFailureHandled(exchange);
        }
    }

    private Throwable detectHandlerException(Throwable throwable) {
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.