0002330: Make channels push and pull asynchronously - SymmetricDS

ID	Project	Category	View Status	Date Submitted	Last Update

0002330	SymmetricDS	Improvement	public	2015-06-24 23:45	2021-05-27 15:14

Reporter	chenson	Assigned To
Priority	normal
Status	closed	Resolution	no change required
Target Version	3.8.0	Fixed in Version	3.8.0

Summary	0002330: Make channels push and pull asynchronously
Description	Make channels push and pull asynchronously
Tags	No tags attached.

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

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

View Issue Details

Relationships

Activities

Related Changesets

Issue History

hanes 2018-11-19 21:35 developer ~0001349	Believed to have been done as part of 3.8