View Issue Details

IDProjectCategoryView StatusLast Update
0002330SymmetricDSImprovementpublic2021-05-27 15:14
Reporterchenson Assigned To 
Prioritynormal 
Status closedResolutionno change required 
Target Version3.8.0Fixed in Version3.8.0 
Summary0002330: Make channels push and pull asynchronously
DescriptionMake channels push and pull asynchronously
TagsNo tags attached.

Relationships

related to 0005006 closedelong Push, pull, extract thread name has wrong queue 

Activities

hanes

2018-11-19 21:35

developer   ~0001349

Believed to have been done as part of 3.8

Related Changesets

SymmetricDS: master df48a906

2015-07-06 12:22:00

chenson

Details Diff
0002330: Make channels push asynchronously Affected Issues
0002330
mod - symmetric-android/src/main/java/org/jumpmind/symmetric/android/AndroidSymmetricEngine.java Diff File
mod - symmetric-client/src/main/java/org/jumpmind/symmetric/db/postgresql/PostgreSqlTriggerTemplate.java Diff File
mod - symmetric-client/src/main/java/org/jumpmind/symmetric/job/PushJob.java Diff File
mod - symmetric-client/src/main/java/org/jumpmind/symmetric/service/jmx/NodeManagementService.java Diff File
mod - symmetric-client/src/main/java/org/jumpmind/symmetric/util/SnapshotUtil.java Diff File
mod - symmetric-client/src/test/java/org/jumpmind/symmetric/DbExportImportTest.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/AbstractSymmetricEngine.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/ISymmetricEngine.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/common/ParameterConstants.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/common/TableConstants.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/BatchAck.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/IncomingBatch.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/NodeChannel.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/OutgoingBatch.java Diff File
add - symmetric-core/src/main/java/org/jumpmind/symmetric/model/OutgoingBatchByNodeChannelCount.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/OutgoingBatchSummary.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/ProcessInfo.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/ProcessInfoKey.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/RemoteNodeStatus.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/RemoteNodeStatuses.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/IClusterService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/IDataExtractorService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/IDataLoaderService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/IOutgoingBatchService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/IPushService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/AbstractService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/AcknowledgeService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ClusterService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ClusterServiceSqlMap.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchServiceSqlMap.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PushService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/AbstractTransportManager.java Diff File
add - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/ChannelDisabledException.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/ConcurrentConnectionManager.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/IConcurrentConnectionManager.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/ITransportManager.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/TransportManagerFactory.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/http/HttpBandwidthUrlSelector.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/http/HttpOutgoingTransport.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/http/HttpTransportManager.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/internal/InternalTransportManager.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/util/SymmetricUtils.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/web/WebConstants.java Diff File
mod - symmetric-core/src/main/resources/symmetric-default.properties Diff File
mod - symmetric-core/src/main/resources/symmetric-schema.xml Diff File
mod - symmetric-core/src/test/java/org/jumpmind/symmetric/transport/MockTransportManager.java Diff File
mod - symmetric-core/src/test/resources/symmetric-test.properties Diff File
add - symmetric-io/derby.log Diff File
mod - symmetric-io/src/main/java/org/jumpmind/symmetric/io/stage/StagedResource.java Diff File
mod - symmetric-jdbc/src/test/java/org/jumpmind/db/persist/JdbcPersistenceManagerTest.java Diff File
mod - symmetric-jdbc/src/test/resources/db-test.properties Diff File
add - symmetric-server/src/main/java/org/jumpmind/symmetric/web/AbstractHandler.java Diff File
mod - symmetric-server/src/main/java/org/jumpmind/symmetric/web/AbstractUriHandler.java Diff File
add - symmetric-server/src/main/java/org/jumpmind/symmetric/web/AckStatusUriHandler.java Diff File
mod - symmetric-server/src/main/java/org/jumpmind/symmetric/web/AckUriHandler.java Diff File
add - symmetric-server/src/main/java/org/jumpmind/symmetric/web/MakeReservationUriHandler.java Diff File
mod - symmetric-server/src/main/java/org/jumpmind/symmetric/web/NodeConcurrencyInterceptor.java Diff File
mod - symmetric-server/src/main/java/org/jumpmind/symmetric/web/PushUriHandler.java Diff File
mod - symmetric-server/src/main/java/org/jumpmind/symmetric/web/ServerSymmetricEngine.java Diff File
mod - symmetric-server/src/main/java/org/jumpmind/symmetric/web/rest/RestService.java Diff File
mod - symmetric-server/src/test/java/org/jumpmind/symmetric/test/AbstractIntegrationTest.java Diff File
mod - symmetric-server/src/test/java/org/jumpmind/symmetric/test/AbstractTest.java Diff File
mod - symmetric-server/src/test/java/org/jumpmind/symmetric/test/SimpleIntegrationTest.java Diff File
add - symmetric-util/src/main/java/org/jumpmind/util/CurrentThreadExecutor.java Diff File

SymmetricDS: master a18f2fbc

2015-07-07 14:44:52

chenson

Details Diff
0002330: Make channels push asynchronously Affected Issues
0002330
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchServiceSqlMap.java Diff File

SymmetricDS: master 1f2dd7ce

2015-07-08 08:07:19

chenson

Details Diff
0002330: Make channels push asynchronously Affected Issues
0002330
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/OutgoingBatchByNodeChannelCount.java Diff File

SymmetricDS: master ba668607

2015-07-08 15:04:06

chenson

Details Diff
0002330: Make channels push asynchronously Affected Issues
0002330
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/ProcessInfoKey.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/IDataLoaderService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java Diff File
mod - symmetric-server/src/main/java/org/jumpmind/symmetric/web/PushUriHandler.java Diff File

SymmetricDS: master d4c04fc0

2015-07-08 19:19:24

chenson

Details Diff
0002330: Make channels push asynchronously. Working on processinfo for what are now async processes Affected Issues
0002330
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/ProcessInfo.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/ProcessInfoKey.java Diff File
add - symmetric-core/src/main/java/org/jumpmind/symmetric/model/ProcessType.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapDetector.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapRouteReader.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/IDataLoaderService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/FileSyncService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PushService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/internal/InternalTransportManager.java Diff File
mod - symmetric-server/src/main/java/org/jumpmind/symmetric/web/FileSyncPullUriHandler.java Diff File
mod - symmetric-server/src/main/java/org/jumpmind/symmetric/web/PullUriHandler.java Diff File
mod - symmetric-server/src/main/java/org/jumpmind/symmetric/web/PushUriHandler.java Diff File
mod - symmetric-server/src/main/java/org/jumpmind/symmetric/web/rest/RestService.java Diff File

SymmetricDS: 3.8 d9ef280f

2015-12-21 11:03:24

Hicks, Josh

Details Diff
0002330 Channel Threading Affected Issues
0002330
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/AbstractSymmetricEngine.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/common/ParameterConstants.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/ChannelMap.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/NodeCommunication.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/OutgoingBatches.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/ProcessInfo.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/ProcessInfoKey.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/RemoteNodeStatus.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/RemoteNodeStatuses.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/IDataExtractorService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/IDataLoaderService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/INodeCommunicationService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/IOutgoingBatchService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorServiceSqlMap.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeCommunicationService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeCommunicationServiceSqlMap.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OfflinePushService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchServiceSqlMap.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PullService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PushService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RegistrationService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/ConcurrentConnectionManager.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/IConcurrentConnectionManager.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/ITransportManager.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/http/HttpOutgoingTransport.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/http/HttpTransportManager.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/web/WebConstants.java Diff File
mod - symmetric-core/src/main/resources/symmetric-schema.xml Diff File
mod - symmetric-server/src/main/java/org/jumpmind/symmetric/web/NodeConcurrencyInterceptor.java Diff File
mod - symmetric-server/src/main/java/org/jumpmind/symmetric/web/PullUriHandler.java Diff File
mod - symmetric-server/src/main/java/org/jumpmind/symmetric/web/PushUriHandler.java Diff File

SymmetricDS: 3.8 4e0e3478

2015-12-23 11:50:10

Hicks, Josh

Details Diff
0002330 Updates for acknowledgments for offline nodes Affected Issues
0002330
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/file/FileOutgoingTransport.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/transport/internal/InternalTransportManager.java Diff File

SymmetricDS: 3.8 d74c121c

2016-01-04 06:53:45

Hicks, Josh

Details Diff
0002330 - test compilation fix Affected Issues
0002330
mod - symmetric-core/src/test/java/org/jumpmind/symmetric/transport/MockTransportManager.java Diff File

SymmetricDS: 3.8 d35512ac

2016-01-04 07:26:56

Hicks, Josh

Details Diff
0002330 - Compilation fixes for Android Affected Issues
0002330
mod - symmetric-android/src/main/java/org/jumpmind/symmetric/android/AndroidSymmetricEngine.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/RemoteNodeStatuses.java Diff File
mod - symmetric-core/src/test/java/org/jumpmind/symmetric/service/impl/AbstractDataLoaderServiceTest.java Diff File

SymmetricDS: 3.8 fa7950d8

2016-02-07 16:46:35

chenson

Details Diff
0002330 Channel Threading Affected Issues
0002330
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/common/ParameterConstants.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeCommunicationService.java Diff File
mod - symmetric-core/src/main/resources/symmetric-default.properties Diff File

SymmetricDS: 3.8 c4535ea9

2016-04-28 12:47:37

josh-a-hicks

Details Diff
0002330 - Channel sync support for multiple threads Affected Issues
0002330
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java Diff File

SymmetricDS: 3.8 32466bb3

2016-04-28 13:04:15

josh-a-hicks

Details Diff
0002330 - Make channels push and pull asynchronously Affected Issues
0002330
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/Channel.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/NodeChannel.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/NodeCommunication.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ConfigurationService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ConfigurationServiceSqlMap.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeCommunicationService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeCommunicationServiceSqlMap.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchServiceSqlMap.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PullService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PushService.java Diff File
add - symmetric-core/src/main/resources/symmetric-schema.out.xml Diff File
mod - symmetric-core/src/main/resources/symmetric-schema.xml Diff File
mod - symmetric-core/src/test/java/org/jumpmind/symmetric/VersionUnitTest.java Diff File
mod - symmetric-core/src/test/java/org/jumpmind/symmetric/service/impl/AbstractDataExtractorServiceTest.java Diff File
mod - symmetric-core/src/test/java/org/jumpmind/symmetric/service/impl/AbstractRouterServiceTest.java Diff File
mod - symmetric-server/src/main/java/org/jumpmind/symmetric/web/PullUriHandler.java Diff File

Issue History

Date Modified Username Field Change
2015-06-24 23:45 chenson New Issue
2015-06-24 23:45 chenson Status new => assigned
2015-06-24 23:45 chenson Assigned To => chenson
2015-07-06 17:00 chenson Changeset attached => SymmetricDS trunk r9546
2015-07-07 19:00 chenson Changeset attached => SymmetricDS trunk r9550
2015-07-08 13:00 chenson Changeset attached => SymmetricDS trunk r9551
2015-07-08 20:00 chenson Changeset attached => SymmetricDS trunk r9555
2015-07-09 00:00 chenson Changeset attached => SymmetricDS trunk r9557
2015-07-31 01:49 chenson Changeset attached => SymmetricDS master d4c04fc0
2015-07-31 01:49 chenson Changeset attached => SymmetricDS master ba668607
2015-07-31 01:49 chenson Changeset attached => SymmetricDS master 1f2dd7ce
2015-07-31 01:49 chenson Changeset attached => SymmetricDS master a18f2fbc
2015-07-31 01:49 chenson Changeset attached => SymmetricDS master df48a906
2016-04-28 14:01 chenson Changeset attached => SymmetricDS 3.8 fa7950d8
2016-04-28 14:01 Changeset attached => SymmetricDS 3.8 d35512ac
2016-04-28 14:01 Changeset attached => SymmetricDS 3.8 d74c121c
2016-04-28 14:01 Changeset attached => SymmetricDS 3.8 4e0e3478
2016-04-28 14:01 Changeset attached => SymmetricDS 3.8 d9ef280f
2016-04-28 18:00 josh-a-hicks Changeset attached => SymmetricDS 3.8 32466bb3
2016-04-28 18:00 josh-a-hicks Changeset attached => SymmetricDS 3.8 c4535ea9
2018-11-19 21:35 hanes Assigned To chenson =>
2018-11-19 21:35 hanes Status assigned => closed
2018-11-19 21:35 hanes Resolution open => no change required
2018-11-19 21:35 hanes Fixed in Version => 3.8.0
2018-11-19 21:35 hanes Note Added: 0001349
2021-05-27 15:14 elong Relationship added related to 0005006