Package org.apache.camel.builder.endpoint.dsl

Interface DaprEndpointBuilderFactory.DaprEndpointProducerBuilder

All Superinterfaces:
org.apache.camel.builder.EndpointProducerBuilder, org.apache.camel.EndpointProducerResolver
All Known Subinterfaces:
DaprEndpointBuilderFactory.DaprEndpointBuilder
Enclosing interface:
DaprEndpointBuilderFactory
public static interface DaprEndpointBuilderFactory.DaprEndpointProducerBuilder extends org.apache.camel.builder.EndpointProducerBuilder
Builder for endpoint producers for the Dapr component.

  • Method Details

    • advanced

      default DaprEndpointBuilderFactory.AdvancedDaprEndpointProducerBuilder advanced()

    • client

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder client(io.dapr.client.DaprClient client)
      The Dapr Client. The option is a: io.dapr.client.DaprClient type. Group: common
      Parameters:
      client - the value to set
      Returns:
      the dsl builder

    • client

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder client(String client)
      The Dapr Client. The option will be converted to a io.dapr.client.DaprClient type. Group: common
      Parameters:
      client - the value to set
      Returns:
      the dsl builder

    • configKeys

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder configKeys(String configKeys)
      List of keys for configuration operation. The option is a: java.lang.String type. Group: common
      Parameters:
      configKeys - the value to set
      Returns:
      the dsl builder

    • configStore

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder configStore(String configStore)
      The name of the Dapr configuration store to interact with, defined in statestore.yaml config. The option is a: java.lang.String type. Group: common
      Parameters:
      configStore - the value to set
      Returns:
      the dsl builder

    • contentType

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder contentType(String contentType)
      The contentType for the Pub/Sub component to use. The option is a: java.lang.String type. Group: common
      Parameters:
      contentType - the value to set
      Returns:
      the dsl builder

    • previewClient

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder previewClient(io.dapr.client.DaprPreviewClient previewClient)
      The Dapr Preview Client. The option is a: io.dapr.client.DaprPreviewClient type. Group: common
      Parameters:
      previewClient - the value to set
      Returns:
      the dsl builder

    • previewClient

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder previewClient(String previewClient)
      The Dapr Preview Client. The option will be converted to a io.dapr.client.DaprPreviewClient type. Group: common
      Parameters:
      previewClient - the value to set
      Returns:
      the dsl builder

    • pubSubName

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder pubSubName(String pubSubName)
      The name of the Dapr Pub/Sub component to use. This identifies which underlying messaging system Dapr will interact with for publishing or subscribing to events. The option is a: java.lang.String type. Group: common
      Parameters:
      pubSubName - the value to set
      Returns:
      the dsl builder

    • topic

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder topic(String topic)
      The name of the topic to subscribe to. The topic must exist in the Pub/Sub component configured under the given pubsubName. The option is a: java.lang.String type. Group: common
      Parameters:
      topic - the value to set
      Returns:
      the dsl builder

    • bindingName

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder bindingName(String bindingName)
      The name of the Dapr binding to invoke. The option is a: java.lang.String type. Group: producer
      Parameters:
      bindingName - the value to set
      Returns:
      the dsl builder

    • bindingOperation

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder bindingOperation(String bindingOperation)
      The operation to perform on the binding. The option is a: java.lang.String type. Group: producer
      Parameters:
      bindingOperation - the value to set
      Returns:
      the dsl builder

    • concurrency

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder concurrency(io.dapr.client.domain.StateOptions.Concurrency concurrency)
      Concurrency mode to use with state operations. The option is a: io.dapr.client.domain.StateOptions.Concurrency type. Group: producer
      Parameters:
      concurrency - the value to set
      Returns:
      the dsl builder

    • concurrency

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder concurrency(String concurrency)
      Concurrency mode to use with state operations. The option will be converted to a io.dapr.client.domain.StateOptions.Concurrency type. Group: producer
      Parameters:
      concurrency - the value to set
      Returns:
      the dsl builder

    • consistency

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder consistency(io.dapr.client.domain.StateOptions.Consistency consistency)
      Consistency level to use with state operations. The option is a: io.dapr.client.domain.StateOptions.Consistency type. Group: producer
      Parameters:
      consistency - the value to set
      Returns:
      the dsl builder

    • consistency

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder consistency(String consistency)
      Consistency level to use with state operations. The option will be converted to a io.dapr.client.domain.StateOptions.Consistency type. Group: producer
      Parameters:
      consistency - the value to set
      Returns:
      the dsl builder

    • eTag

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder eTag(String eTag)
      The eTag for optimistic concurrency during state save or delete operations. The option is a: java.lang.String type. Group: producer
      Parameters:
      eTag - the value to set
      Returns:
      the dsl builder

    • eventName

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder eventName(String eventName)
      The name of the event. Event names are case-insensitive. The option is a: java.lang.String type. Group: producer
      Parameters:
      eventName - the value to set
      Returns:
      the dsl builder

    • expiryInSeconds

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder expiryInSeconds(Integer expiryInSeconds)
      The expiry time in seconds for the lock. The option is a: java.lang.Integer type. Group: producer
      Parameters:
      expiryInSeconds - the value to set
      Returns:
      the dsl builder

    • expiryInSeconds

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder expiryInSeconds(String expiryInSeconds)
      The expiry time in seconds for the lock. The option will be converted to a java.lang.Integer type. Group: producer
      Parameters:
      expiryInSeconds - the value to set
      Returns:
      the dsl builder

    • getWorkflowIO

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder getWorkflowIO(boolean getWorkflowIO)
      Set true to fetch the workflow instance's inputs, outputs, and custom status, or false to omit. The option is a: boolean type. Default: false Group: producer
      Parameters:
      getWorkflowIO - the value to set
      Returns:
      the dsl builder

    • getWorkflowIO

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder getWorkflowIO(String getWorkflowIO)
      Set true to fetch the workflow instance's inputs, outputs, and custom status, or false to omit. The option will be converted to a boolean type. Default: false Group: producer
      Parameters:
      getWorkflowIO - the value to set
      Returns:
      the dsl builder

    • httpExtension

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder httpExtension(io.dapr.client.domain.HttpExtension httpExtension)
      HTTP method to use when invoking the service. Accepts verbs like GET, POST, PUT, DELETE, etc. Creates a minimal HttpExtension with no headers or query params. Takes precedence over verb. The option is a: io.dapr.client.domain.HttpExtension type. Group: producer
      Parameters:
      httpExtension - the value to set
      Returns:
      the dsl builder

    • httpExtension

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder httpExtension(String httpExtension)
      HTTP method to use when invoking the service. Accepts verbs like GET, POST, PUT, DELETE, etc. Creates a minimal HttpExtension with no headers or query params. Takes precedence over verb. The option will be converted to a io.dapr.client.domain.HttpExtension type. Group: producer
      Parameters:
      httpExtension - the value to set
      Returns:
      the dsl builder

    • key

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder key(String key)
      The key used to identify the state/secret object within the specified state/secret store. The option is a: java.lang.String type. Group: producer
      Parameters:
      key - the value to set
      Returns:
      the dsl builder

    • lockOperation

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder lockOperation(org.apache.camel.component.dapr.LockOperation lockOperation)
      The lock operation to perform on the store. Required for DaprOperation.lock operation. The option is a: org.apache.camel.component.dapr.LockOperation type. Default: tryLock Group: producer
      Parameters:
      lockOperation - the value to set
      Returns:
      the dsl builder

    • lockOperation

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder lockOperation(String lockOperation)
      The lock operation to perform on the store. Required for DaprOperation.lock operation. The option will be converted to a org.apache.camel.component.dapr.LockOperation type. Default: tryLock Group: producer
      Parameters:
      lockOperation - the value to set
      Returns:
      the dsl builder

    • lockOwner

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder lockOwner(String lockOwner)
      The lock owner identifier for the lock. The option is a: java.lang.String type. Group: producer
      Parameters:
      lockOwner - the value to set
      Returns:
      the dsl builder

    • methodToInvoke

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder methodToInvoke(String methodToInvoke)
      The name of the method or route to invoke on the target service. The option is a: java.lang.String type. Group: producer
      Parameters:
      methodToInvoke - the value to set
      Returns:
      the dsl builder

    • reason

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder reason(String reason)
      Reason for suspending/resuming the workflow instance. The option is a: java.lang.String type. Group: producer
      Parameters:
      reason - the value to set
      Returns:
      the dsl builder

    • resourceId

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder resourceId(String resourceId)
      The resource Id for the lock. The option is a: java.lang.String type. Group: producer
      Parameters:
      resourceId - the value to set
      Returns:
      the dsl builder

    • secretStore

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder secretStore(String secretStore)
      The name of the Dapr secret store to interact with, defined in local-secret-store.yaml config. The option is a: java.lang.String type. Group: producer
      Parameters:
      secretStore - the value to set
      Returns:
      the dsl builder

    • serviceToInvoke

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder serviceToInvoke(String serviceToInvoke)
      Target service to invoke. Can be a Dapr App ID, a named HTTPEndpoint, or a FQDN/public URL. The option is a: java.lang.String type. Group: producer
      Parameters:
      serviceToInvoke - the value to set
      Returns:
      the dsl builder

    • stateOperation

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder stateOperation(org.apache.camel.component.dapr.StateOperation stateOperation)
      The state operation to perform on the state store. Required for DaprOperation.state operation. The option is a: org.apache.camel.component.dapr.StateOperation type. Default: get Group: producer
      Parameters:
      stateOperation - the value to set
      Returns:
      the dsl builder

    • stateOperation

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder stateOperation(String stateOperation)
      The state operation to perform on the state store. Required for DaprOperation.state operation. The option will be converted to a org.apache.camel.component.dapr.StateOperation type. Default: get Group: producer
      Parameters:
      stateOperation - the value to set
      Returns:
      the dsl builder

    • stateStore

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder stateStore(String stateStore)
      The name of the Dapr state store to interact with, defined in statestore.yaml config. The option is a: java.lang.String type. Group: producer
      Parameters:
      stateStore - the value to set
      Returns:
      the dsl builder

    • storeName

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder storeName(String storeName)
      The lock store name. The option is a: java.lang.String type. Group: producer
      Parameters:
      storeName - the value to set
      Returns:
      the dsl builder

    • timeout

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder timeout(Duration timeout)
      The amount of time to wait for the workflow instance to start/complete. The option is a: java.time.Duration type. Group: producer
      Parameters:
      timeout - the value to set
      Returns:
      the dsl builder

    • timeout

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder timeout(String timeout)
      The amount of time to wait for the workflow instance to start/complete. The option will be converted to a java.time.Duration type. Group: producer
      Parameters:
      timeout - the value to set
      Returns:
      the dsl builder

    • verb

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder verb(String verb)
      The HTTP verb to use for invoking the method. The option is a: java.lang.String type. Default: POST Group: producer
      Parameters:
      verb - the value to set
      Returns:
      the dsl builder

    • workflowClass

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder workflowClass(String workflowClass)
      The FQCN of the class which implements io.dapr.workflows.Workflow. The option is a: java.lang.String type. Group: producer
      Parameters:
      workflowClass - the value to set
      Returns:
      the dsl builder

    • workflowClient

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder workflowClient(io.dapr.workflows.client.DaprWorkflowClient workflowClient)
      The Dapr Workflow Client. The option is a: io.dapr.workflows.client.DaprWorkflowClient type. Group: producer
      Parameters:
      workflowClient - the value to set
      Returns:
      the dsl builder

    • workflowClient

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder workflowClient(String workflowClient)
      The Dapr Workflow Client. The option will be converted to a io.dapr.workflows.client.DaprWorkflowClient type. Group: producer
      Parameters:
      workflowClient - the value to set
      Returns:
      the dsl builder

    • workflowInstanceId

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder workflowInstanceId(String workflowInstanceId)
      The instance ID of the workflow. The option is a: java.lang.String type. Group: producer
      Parameters:
      workflowInstanceId - the value to set
      Returns:
      the dsl builder

    • workflowOperation

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder workflowOperation(org.apache.camel.component.dapr.WorkflowOperation workflowOperation)
      The workflow operation to perform. Required for DaprOperation.workflow operation. The option is a: org.apache.camel.component.dapr.WorkflowOperation type. Default: scheduleNew Group: producer
      Parameters:
      workflowOperation - the value to set
      Returns:
      the dsl builder

    • workflowOperation

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder workflowOperation(String workflowOperation)
      The workflow operation to perform. Required for DaprOperation.workflow operation. The option will be converted to a org.apache.camel.component.dapr.WorkflowOperation type. Default: scheduleNew Group: producer
      Parameters:
      workflowOperation - the value to set
      Returns:
      the dsl builder

    • workflowStartTime

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder workflowStartTime(Instant workflowStartTime)
      The start time of the new workflow. The option is a: java.time.Instant type. Group: producer
      Parameters:
      workflowStartTime - the value to set
      Returns:
      the dsl builder

    • workflowStartTime

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder workflowStartTime(String workflowStartTime)
      The start time of the new workflow. The option will be converted to a java.time.Instant type. Group: producer
      Parameters:
      workflowStartTime - the value to set
      Returns:
      the dsl builder

    • workflowVersion

      default DaprEndpointBuilderFactory.DaprEndpointProducerBuilder workflowVersion(String workflowVersion)
      The version of the workflow to start. The option is a: java.lang.String type. Group: producer
      Parameters:
      workflowVersion - the value to set
      Returns:
      the dsl builder