in src/main/java/com/uber/cadence/internal/compatibility/proto/RequestMapper.java [420:465]
public static SignalWithStartWorkflowExecutionRequest signalWithStartWorkflowExecutionRequest(
com.uber.cadence.SignalWithStartWorkflowExecutionRequest t) {
if (t == null) {
return null;
}
StartWorkflowExecutionRequest.Builder builder =
StartWorkflowExecutionRequest.newBuilder()
.setDomain(t.getDomain())
.setWorkflowId(t.getWorkflowId())
.setWorkflowType(workflowType(t.getWorkflowType()))
.setTaskList(taskList(t.getTaskList()))
.setInput(payload(t.getInput()))
.setExecutionStartToCloseTimeout(
secondsToDuration(t.getExecutionStartToCloseTimeoutSeconds()))
.setTaskStartToCloseTimeout(secondsToDuration(t.getTaskStartToCloseTimeoutSeconds()))
.setRequestId(t.getRequestId())
.setMemo(memo(t.getMemo()))
.setSearchAttributes(searchAttributes(t.getSearchAttributes()))
.setHeader(header(t.getHeader()));
if (t.getRetryPolicy() != null) {
builder.setRetryPolicy(retryPolicy(t.getRetryPolicy()));
}
builder.setWorkflowIdReusePolicy(workflowIdReusePolicy(t.getWorkflowIdReusePolicy()));
if (t.getWorkflowIdReusePolicy() != null) {
builder.setWorkflowIdReusePolicy(workflowIdReusePolicy(t.getWorkflowIdReusePolicy()));
}
if (t.getCronSchedule() != null) {
builder.setCronSchedule(t.getCronSchedule());
}
if (t.getDelayStartSeconds() > 0) {
builder.setDelayStart(secondsToDuration(t.getDelayStartSeconds()));
}
;
if (t.getIdentity() != null) {
builder.setIdentity(t.getIdentity());
}
SignalWithStartWorkflowExecutionRequest.Builder sb =
SignalWithStartWorkflowExecutionRequest.newBuilder()
.setStartRequest(builder.build())
.setSignalName(t.getSignalName())
.setSignalInput(payload(t.getSignalInput()));
if (t.getControl() != null) {
sb.setControl(arrayToByteString(t.getControl()));
}
return sb.build();
}