Skip to content

Commit 7dac313

Browse files
committed
fix test
1 parent 5aee0d1 commit 7dac313

File tree

2 files changed

+98
-100
lines changed

2 files changed

+98
-100
lines changed

src/main/java/com/uber/cadence/internal/compatibility/proto/mappers/TypeMapper.java

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,6 @@
3636

3737
import com.google.common.base.Strings;
3838
import com.uber.cadence.api.v1.*;
39-
import java.nio.ByteBuffer;
4039
import java.util.ArrayList;
4140
import java.util.Collections;
4241
import java.util.HashMap;
@@ -254,13 +253,13 @@ static StatusFilter statusFilter(com.uber.cadence.entities.WorkflowExecutionClos
254253
return StatusFilter.newBuilder().setStatus(workflowExecutionCloseStatus(t)).build();
255254
}
256255

257-
static Map<String, Payload> payloadByteBufferMap(Map<String, ByteBuffer> t) {
256+
static Map<String, Payload> payloadByteBufferMap(Map<String, byte[]> t) {
258257
if (t == null) {
259258
return Collections.emptyMap();
260259
}
261260
Map<String, Payload> v = new HashMap<>();
262261
for (String key : t.keySet()) {
263-
v.put(key, payload(t.get(key).array()));
262+
v.put(key, payload(t.get(key)));
264263
}
265264
return v;
266265
}
@@ -467,13 +466,13 @@ static com.uber.cadence.entities.WorkflowQuery workflowQuery(WorkflowQuery t) {
467466
return res;
468467
}
469468

470-
static Map<String, ByteBuffer> payloadMap(Map<String, Payload> t) {
469+
static Map<String, byte[]> payloadMap(Map<String, Payload> t) {
471470
if (t == null) {
472471
return null;
473472
}
474-
Map<String, ByteBuffer> v = new HashMap<>();
473+
Map<String, byte[]> v = new HashMap<>();
475474
for (String key : t.keySet()) {
476-
v.put(key, ByteBuffer.wrap(payload(t.get(key))));
475+
v.put(key, payload(t.get(key)));
477476
}
478477
return v;
479478
}

0 commit comments

Comments
 (0)