Getting Exception: The following exception when I am trying to create workflow stub within an Activity.
I did start the workflow and Worker.
Please help…
java.lang.IllegalStateException: Null workflowId. Was workflow started?
at io.temporal.internal.sync.WorkflowStubImpl.checkStarted(WorkflowStubImpl.java:370)
at io.temporal.internal.sync.WorkflowStubImpl.signal(WorkflowStubImpl.java:88)
at io.temporal.internal.sync.WorkflowInvocationHandler$SyncWorkflowInvocationHandler.signalWorkflow(WorkflowInvocationHandler.java:297)
at io.temporal.internal.sync.WorkflowInvocationHandler$SyncWorkflowInvocationHandler.invoke(WorkflowInvocationHandler.java:274)
at io.temporal.internal.sync.WorkflowInvocationHandler.invoke(WorkflowInvocationHandler.java:178)
at com.sun.proxy.$Proxy12.setCustomActivityId(Unknown Source)
at io.workshop.c1intro.AccountActivitiesImpl.notify(AccountActivitiesImpl.java:53)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
Activity Code:
public class AccountActivitiesImpl implements AccountActivities {
public static final WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
public static final WorkflowClient client = WorkflowClient.newInstance(service);
public static final String taskQueue = "myTaskQueue";
NotifyUserAccounts workflow;
@Override
public String notify(String accountId) throws Exception{
// try {
// // simulate some time…
// Thread.sleep(2 * 1000);
// } catch (Exception e) {
// e.printStackTrace();
// }
workflow = client.newWorkflowStub(
NotifyUserAccounts.class,
WorkflowOptions.newBuilder()
.setWorkflowId(Activity.getExecutionContext().getInfo().getWorkflowId())
.setTaskQueue(taskQueue)
.build());
workflow.setCustomActivityId("someName","someId");
return "notified...";
}
}