Package org.apache.camel.spi

Examples of org.apache.camel.spi.Synchronization

84
85
86
87
88
89
90
91
92
93
94
        private MyUOWProcessor(String id) {
            this.id = id;
        }

        public void process(Exchange exchange) throws Exception {
            exchange.getUnitOfWork().addSynchronization(new Synchronization() {
                public void onComplete(Exchange exchange) {
                    sync = "onComplete" + id;
                    lastOne = sync;
                }
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
        private MyUOWProcessor(String id) {
            this.id = id;
        }

        public void process(Exchange exchange) throws Exception {
            exchange.getUnitOfWork().addSynchronization(new Synchronization() {
                public void onComplete(Exchange exchange) {
                    sync = "onComplete" + id;
                    lastOne = sync;
                }
View Full Code Here
104
105
106
107
108
109
110
111
112
113
114
            // update pending number of exchanges
            pendingExchanges = total - index - 1;

            // add on completion to handle after work when the exchange is done
            exchange.addOnCompletion(new Synchronization() {
                public void onComplete(Exchange exchange) {
                    processCommit(exchange);
                }

                public void onFailure(Exchange exchange) {
View Full Code Here
104
105
106
107
108
109
110
111
112
113
114
            // update pending number of exchanges
            pendingExchanges = total - index - 1;

            // add on completion to handle after work when the exchange is done
            exchange.addOnCompletion(new Synchronization() {
                public void onComplete(Exchange exchange) {
                    processCommit(exchange);
                }

                public void onFailure(Exchange exchange) {
View Full Code Here
171
172
173
174
175
176
177
178
179
180
181
            return;
        }

        Iterator<Synchronization> it = synchronizations.iterator();
        while (it.hasNext()) {
            Synchronization synchronization = it.next();

            boolean handover = true;
            if (synchronization instanceof SynchronizationVetoable) {
                SynchronizationVetoable veto = (SynchronizationVetoable) synchronization;
                handover = veto.allowHandover();
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
        private MyUOWProcessor(String id) {
            this.id = id;
        }

        public void process(Exchange exchange) throws Exception {
            exchange.getUnitOfWork().addSynchronization(new Synchronization() {
                public void onComplete(Exchange exchange) {
                    sync = "onComplete" + id;
                    lastOne = sync;
                }
View Full Code Here
168
169
170
171
172
173
174
175
176
177
178
            // must use the original message in case we need to workaround a charset issue when extracting mail content
            final Message mail = exchange.getIn(MailMessage.class).getOriginalMessage();

            // add on completion to handle after work when the exchange is done
            exchange.addOnCompletion(new Synchronization() {
                public void onComplete(Exchange exchange) {
                    processCommit(mail, exchange);
                }

                public void onFailure(Exchange exchange) {
View Full Code Here
105
106
107
108
109
110
111
112
113
114
115
            // update pending number of exchanges
            pendingExchanges = total - index - 1;

            // add on completion to handle after work when the exchange is done
            exchange.addOnCompletion(new Synchronization() {
                public void onComplete(Exchange exchange) {
                    processCommit(exchange);
                }

                public void onFailure(Exchange exchange) {
View Full Code Here
98
99
100
101
102
103
104
105
106
107
108
            // update pending number of exchanges
            pendingExchanges = total - index - 1;

            // add on completion to handle after work when the exchange is done
            exchange.addOnCompletion(new Synchronization() {
                public void onComplete(Exchange exchange) {
                    processCommit(exchange);
                }

                public void onFailure(Exchange exchange) {
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
            // update pending number of exchanges
            pendingExchanges = total - index - 1;

            // add on completion to handle after work when the exchange is done
            exchange.addOnCompletion(new Synchronization() {
                public void onComplete(Exchange exchange) {
                    try {
                        dataStore.delete(exchange.getProperty(KratiConstants.KEY));
                    } catch (Exception e) {
                        LOG.warn("Failed to remove from datastore.", e);
View Full Code Here
TOP

Related Classes of org.apache.camel.spi.Synchronization

  • amqp.spring.camel.component.SpringAMQPProducerTest
  • org.apache.camel.component.aws.s3.S3Consumer
  • org.apache.camel.component.aws.sqs.SqsConsumer
  • org.apache.camel.component.disruptor.DisruptorConsumer
  • org.apache.camel.component.disruptor.DisruptorUnitOfWorkTest$MyUOWProcessor
  • org.apache.camel.component.ironmq.IronMQConsumer
  • org.apache.camel.component.jclouds.JcloudsBlobStoreConsumer
  • org.apache.camel.component.krati.KratiConsumer
  • org.apache.camel.component.mail.MailConsumer
  • org.apache.camel.component.seda.SedaUnitOfWorkTest$MyUOWProcessor
    • Copyright © 2018 www.massapicom. 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.