[jira] [Commented] (CAMEL-17121) Investigate and consolidate do-wait-retry logic in components

["Otavio Rodolfo Piske (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/CAMEL-17121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440179#comment-17440179 ] 

Otavio Rodolfo Piske commented on CAMEL-17121:
----------------------------------------------

Converted: 
* org.apache.camel.component.optaplanner.OptaPlannerProducer#processWithXmlFile

> Investigate and consolidate do-wait-retry logic in components
> -------------------------------------------------------------
>
>                 Key: CAMEL-17121
>                 URL: https://issues.apache.org/jira/browse/CAMEL-17121
>             Project: Camel
>          Issue Type: Task
>    Affects Versions: 3.13.0
>            Reporter: Otavio Rodolfo Piske
>            Assignee: Otavio Rodolfo Piske
>            Priority: Major
>             Fix For: 3.x
>
>
> In many components we have pieces of code that resemble the following:
>  * do some (usually remote) work
>  * test the result
>  ** if failed
>  *** wait (usually w/ Thread.sleep)
>  *** repeat
>  * Break loop if successful
>  
> We may have some potential for consolidating this logic in one of the core modules to reduce the code size and increase reuse.
>  
> Some likely candidates as of 3.13.0-SNAPSHOT are:
> org.apache.camel.component.mllp.internal.TcpServerBindThread#doAccept
> org.apache.camel.component.file.remote.strategy.FtpChangedExclusiveReadLockStrategy#acquireExclusiveReadLock
> org.apache.camel.component.file.remote.SftpOperations#connect
> org.apache.camel.component.file.remote.FtpOperations#doConnect
> org.apache.camel.component.file.GenericFilePollingConsumer#doReceive
> org.apache.camel.component.jms.reply.ReplyManagerSupport#waitForProvisionCorrelationToBeUpdated
> org.apache.camel.component.couchdb.CouchDbChangesetTracker#waitForStability
> org.apache.camel.component.mock.MockEndpoint#expectedFileExists(java.lang.String, java.lang.String)
> org.apache.camel.component.mongodb.MongoAbstractConsumerThread#run
> org.apache.camel.component.mongodb.gridfs.GridFsConsumer#run
> org.apache.camel.component.optaplanner.OptaPlannerProducer#processWithXmlFile
> org.apache.camel.component.rabbitmq.RabbitConsumer#handleShutdownSignal
> org.apache.camel.component.rabbitmq.RabbitMQConsumer.StartConsumerCallable#call
> org.apache.camel.component.rabbitmq.reply.ReplyManagerSupport#waitForProvisionCorrelationToBeUpdated
> org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper#performClientRestart
> org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper#subscribe
> org.apache.camel.component.smpp.SmppConsumer#reconnect
> org.apache.camel.component.soroushbot.utils.ExponentialBackOffStrategy
> org.apache.camel.component.soroushbot.utils.FixedBackOffStrategy
> org.apache.camel.component.soroushbot.utils.LinearBackOffStrategy
> org.apache.camel.component.splunk.support.SplunkDataReader#savedSearch
> org.apache.camel.component.splunk.support.SplunkDataReader#runQuery
> org.apache.camel.component.ssh.SshHelper#getPrompt
> org.apache.camel.component.stream.StreamConsumer#readFromStream
> org.apache.camel.component.stream.StreamConsumer#doPromptMessage
> org.apache.camel.support.cache.DefaultProducerCache#acquireProducer
> org.apache.camel.test.junit4.TestSupport#deleteDirectory(java.io.File)
> org.apache.camel.test.junit5.TestSupport#deleteDirectory(java.io.File)
> org.apache.camel.util.FileUtil#delete
> org.apache.camel.util.FileUtil#renameFile
> org.apache.camel.util.FileUtil#deleteFile
> org.apache.camel.component.websocket.WebsocketProducer#sendToAll
> org.apache.camel.component.zookeeper.ZooKeeperConsumer.OperationsExecutor#run
> org.apache.camel.component.zookeeper.cluster.ZooKeeperClusterView.CamelLeaderElectionListener#takeLeadership



--
This message was sent by Atlassian Jira
(v8.20.1#820001)