Fix replication task processor when converting to replication task (t…

…emporalio#385)
jleach4 · May 17, 2020 · fb986a6 · fb986a6
1 parent 031bdcf
commit fb986a6
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 2 deletions.
diff --git a/.vscode/launch.json b/.vscode/launch.json
@@ -1,6 +1,7 @@
 {
 	"version": "0.2.0",
 	"configurations": [
+
 		{
 			"name": "Debug Server",
 			"type": "go",
@@ -12,6 +13,19 @@
 				"start",
 			]
 		},
+		{
+			"name": "Debug Active Server",
+			"type": "go",
+			"request": "launch",
+			"mode": "debug",
+			"program": "${workspaceFolder}/cmd/server",
+			"cwd": "${workspaceFolder}",
+			"args": [
+				"--env",
+				"development_active",
+				"start",
+			]
+		},
 		{
 			"name": "Debug CLI Namespace Describe",
 			"type": "go",

diff --git a/common/persistence/dataInterfaces.go b/common/persistence/dataInterfaces.go
@@ -1540,7 +1540,7 @@ func (d *DecisionTask) SetTaskID(id int64) {
 }
 
 // GetVisibilityTimestamp get the visibility timestamp
-func (d ReplicationTaskInfoWrapper) GetVisibilityTimestamp() *types.Timestamp {
+func (d *ReplicationTaskInfoWrapper) GetVisibilityTimestamp() *types.Timestamp {
 	return &types.Timestamp{}
 }
 

diff --git a/service/history/replicatorQueueProcessor.go b/service/history/replicatorQueueProcessor.go
@@ -213,7 +213,7 @@ func (p *replicatorQueueProcessorImpl) processSyncActivityTask(
 func (p *replicatorQueueProcessorImpl) processHistoryReplicationTask(
 	task *persistenceblobs.ReplicationTaskInfo,
 ) error {
-	replicationTask, err := p.toReplicationTask(context.Background(), persistence.ReplicationTaskInfoWrapper{task})
+	replicationTask, err := p.toReplicationTask(context.Background(), &persistence.ReplicationTaskInfoWrapper{task})
 	if err != nil || replicationTask == nil {
 		return err
 	}