# mulesoft Salesforce Pub/Sub Connector - Full Documentation --- product: Salesforce Pub/Sub Connector version: 1.0 --- # Salesforce Pub/Sub Connector > For the full documentation index, see: https://docs.mulesoft.com/llms.txt Anypoint Connector for Salesforce Pub/Sub (Salesforce Pub/Sub Connector) enables you to connect to the Pub/Sub API, which provides a single interface for publishing and subscribing to platform events, including real-time event monitoring events and change data capture events. This connector complements Anypoint Connector for Salesforce (Salesforce Connector) and provides additional ways to interface with Salesforce’s ecosystem. The Salesforce Pub/Sub API enables you to publish and subscribe to events and request schemas and topic information with one API. For information about compatibility and fixed issues, refer to the Salesforce Pub/Sub Connector Release Notes. ## Before You Begin To use this connector, you must be familiar with: - The Salesforce Pub/Sub Connector’s API - Anypoint Connectors - Mule runtime engine (Mule) - Elements and global elements in a Mule flow - How to create a Mule app using Anypoint Studio Before creating an app, you must have: - Credentials to access the Salesforce Pub/Sub target resource - Anypoint Platform - Anypoint Studio or Anypoint Code Builder ## Common Use Cases For the Connector These are some common use cases for Salesforce Pub/Sub Connector: - Subscribe to event monitoring real-time events - Subscribe to a standard or high volume platform event, such as `AppointmentSchedulingEvent` - Publish a platform event (high volume only) back into Salesforce to restrict a user’s profile when they log in to Salesforce after working hours - Subscribe to change data capture events and syn order data in an external inventory system For examples of these use cases, refer to [Salesforce Pub/Sub Connector Examples](https://docs.mulesoft.com/salesforce-pubsub-connector/1.0/salesforce-pubsub-connector-examples). ## Connection Types Salesforce Pub/Sub connections use the following authentication types: - Basic Authentication Uses a username and a password for authentication - OAuth v2.0 Delegates user authentication to the service hosting the user account - OAuth JWT Uses OAuth 2.0 with a JSON Web Token (JWT) request for user authentication - OAuth Username Password Uses OAuth 2.0 with a username and a password for authentication - OAuth SAML Uses OAuth 2.0 with a signed SAML 2.0 assertion to request an access token For information about configuring authentication types, refer to [Configure a Global Element for the Connector](https://docs.mulesoft.com/salesforce-pubsub-connector/1.0/salesforce-pubsub-connector-studio#configure-global-element). ## Next Step After you complete the prerequisites, you are ready to create an app and configure the connector using [Anypoint Studio](https://docs.mulesoft.com/salesforce-pubsub-connector/1.0/salesforce-pubsub-connector-studio). ## See Also - [Introduction to Anypoint Connectors](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [Use Exchange to Discover Connectors, Templates, and Examples](https://docs.mulesoft.com/connectors/introduction/intro-use-exchange) - [Salesforce Pub/Sub Connector Reference](https://docs.mulesoft.com/salesforce-pubsub-connector/1.0/salesforce-pubsub-connector-reference) - [Salesforce Help](https://help.salesforce.com) --- product: Salesforce Pub/Sub Connector version: 1.0 --- # Salesforce Pub/Sub Connector 1.0 - Tracking Salesforce Platform Events Example > For the full documentation index, see: https://docs.mulesoft.com/llms.txt One way to use Salesforce Pub/Sub Connector is to track whether a Salesforce platform event is received from MuleSoft and processed. You can keep track of processed messages using a combination of Salesforce and Mule runtime engine (Mule). For a detailed example of one approach to message tracking, see [Keeping Track of the Processed and Received Messages](/mulesoft/current/en-us/salesforce-pubsub-connector/1.0/_attachments/salesforce-pubsub-whitepaper.pdf). ## Replay ID and MuleSoft Object Store To implement message tracking, it’s important to understand the core concepts of the Salesforce Streaming API, the Replay ID attribute, and MuleSoft object store. ### Replay ID On the Salesforce Event Bus, each published event message is assigned an opaque ID, which is contained in the Replay (`replay_id`) attribute. The system populates the Replay ID field value when the event message is delivered to subscribers and refers to the position of the event message within the event stream. The event stream has a message durability of 72 hours for high-volume platform events so, using the Replay ID, it’s possible to receive event messages from the event stream that fall within that period. The MuleSoft subscriber must carefully track the processed Replay IDs to ensure it doesn’t miss or duplicate process events in case of downtime or restart (either intentional or unintentional). To enable advanced Replay ID tracking to ensure that the event message is received and processed correctly, you are given control over the replay behavior with the Salesforce Pub/Sub Connector in the connector configuration UI. This example configuration uses the **Replay id from object store** option for the **Replay option** property and specifies a dedicated object store in the **Object Store Name** field:  The following table shows the Replay ID options:
| Replay Option | Description | Usage |
|---|---|---|
| The Subscriber receives all stored events after the event specified by its replay ID value, and new events. | Catch up on missed events after a certain event message, for example, after a connection failure. To subscribe with a specific replay ID, save the replay ID of the event message to retrieve stored events after, and then use it when you resubscribe. |
| If no replay option is specified, this is the default. The Subscriber receives new events that are broadcast after the client subscribes. | It is best to subscribe with the |
| The Subscriber receives all events, including past events that are within the 72-hour retention window. | Catch up on missed events and retrieve all stored events, for example, after a connection failure. Using this option can slow performance if a large number of event messages are stored. |
| The Subscriber receives only events with a replay ID higher than the specified value in object store. If no value is found, it defaults to | For more information on how to use |
| Field | Value |
|---|---|
Topic | Name of the topic used for message publishing, for example, |
Job Id |
|
| Field | Value |
|---|---|
Channel name | Name of the streaming channel to subscribe to, for example, |
Replay option | One of the given implementations, for example, |
Batch events size | Total number of events included in a server batch. Lower values indicate small memory footprint with more server calls, while bigger values indicate bigger memory footprint with fewer API calls. A new batch of events is requested by the connector after the flow consumes the existing events, for example, |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Name | String | Name for this configuration. Connectors reference the configuration with this name. | x | |
Connection | Connection types for this configuration. | x | ||
Name | String | ID used to reference this configuration. | x | |
Expiration Policy | Configures the minimum amount of time that a dynamic configuration instance can remain idle before Mule considers it eligible for expiration. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Username | String | Username used to initialize the session. | x | |
Password | String | Password used to authenticate the user. | x | |
Security Token | String | User’s security token. The security token can be omitted if your IP has been added to the allowlist on Salesforce. | ||
Authorization URL | String | Web service URL responsible for user authentication. The URL for the endpoint that is configured to handle SOAP authentication requests. | ||
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. | |||
Consumer Key | String | OAuth consumer key, as registered with the service provider. | x | |
Consumer Secret | String | OAuth consumer secret, as registered with the service provider. | x | |
Authorization Url | String | URL of the service provider’s authorization endpoint. |
| |
Access Token Url | String | URL of the service provider’s access token endpoint. |
| |
Scopes | String | OAuth scopes to request during the OAuth dance. This value defaults to the scopes in the annotation. | ||
Resource Owner Id | String | Resource owner ID to use with the authorization code grant type. | ||
Before | String | Name of the flow to execute immediately before starting the OAuth dance. | ||
After | String | Name of the flow to execute immediately after receiving an access token. | ||
Listener Config | String | Configuration for the HTTP listener that listens for requests on the access token callback endpoint. | x | |
Callback Path | String | Path of the access token callback endpoint. | x | |
Authorize Path | String | Path of the local HTTP endpoint that triggers the OAuth dance. | x | |
External Callback Url | String | URL that the OAuth provider uses to access the callback endpoint if the endpoint is behind a proxy or accessed through an indirect URL. | ||
Object Store | String | Configures the object store that stores data for each resource owner. If not configured, Mule uses the default object store. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
Consumer Key | String | Consumer key for the Salesforce connected app. | x | |
Key Store | String | Path to the keystore used to sign data during authentication. | x | |
Store Password | String | Password of the keystore. | x | |
Certificate Alias | String | Alias of the certificate. | ||
Principal | String | Username of the desired Salesforce user to take action on behalf of. | x | |
Token Endpoint | String | URL pointing to the server responsible for providing the authentication token. According to Salesforce, the Token Endpoint field is |
| |
Audience Url | String | Audience identifies the authorization server as an intended audience. The authorization server must verify that the authorization server is an intended audience for the token. Use the authorization server’s URL for the audience value: | ||
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
Consumer Key | String | Consumer key for the Salesforce connected app. | x | |
Consumer Secret | String | Your application’s client secret (consumer secret in Remote Access Detail). | x | |
Username | String | Username used to initialize the session. | x | |
Password | String | Password used to authenticate the user. | x | |
Security Token | String | User’s security token. The security token can be omitted if your IP has been added to the allowlist on Salesforce. | ||
Token Endpoint | String | URL pointing to the server responsible for providing the authentication token. According to Salesforce, the Token Endpoint field is |
| |
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
Consumer Key | String | Consumer key for the Salesforce connected app. | x | |
Key Store | String | Path to the keystore used to sign data during authentication. | x | |
Store Password | String | Password of the keystore. | x | |
Certificate Alias | String | Alias of the certificate. | ||
Principal | String | Username of the desired Salesforce user to take action on behalf of. | x | |
Token Endpoint | String | URL pointing to the server responsible for providing the authentication token. According to Salesforce, the Token Endpoint field is |
| |
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Configuration | String | Name of the configuration to use. | x | |
Channel Name | String | Name of the streaming channel to subscribe to. | x | |
Replay Option | One of:
| Interface with the following implementations:
| x | |
Batch events size | Number | Total number of events included in a server batch. Lower values indicate small memory footprint with more server calls, while higher values indicate bigger memory footprint with less API calls. A new batch of events is requested by the connector after the flow consumes the existing events. The maximum value is |
| |
Config Ref | ConfigurationProvider | Name of the configuration used to execute this component. | x | |
Primary Node Only | Boolean | Determines whether to execute this source on only the primary node when running Mule instances in a cluster. |
| |
Streaming Strategy |
| Configures how Mule processes streams. Repeatable streams are the default behavior. | ||
Redelivery Policy | Defines a policy for processing the redelivery of the same message. | |||
Reconnection Strategy | Retry strategy in case of connectivity errors. |
Type | Any |
Attributes Type | Any |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Configuration | String | Name of the configuration to use. | x | |
Topic | String | Name of the topic used for message publishing. You can select the topic name from the list of available topics. Sample topic formats:
For more information, refer to the Salesforce documentation. | x | |
Events | Array of Object | List of events to publish that match the schema of the current topic. |
| |
Config Ref | ConfigurationProvider | Name of the configuration used to execute this component. | x | |
Target Variable | String | Name of the variable that stores the operation’s output. | ||
Target Value | String | Expression that evaluates the operation’s output. The outcome of the expression is stored in the Target Variable field. |
| |
Reconnection Strategy | Retry strategy in case of connectivity errors. |
Type | Array of Object |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Configuration | String | Name of the configuration to use. | x | |
Resource Owner Id | String | ID of the resource owner for whom to invalidate access. | ||
Config Ref | ConfigurationProvider | Name of the configuration used to execute this component. | x |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Path | String | Path to the CRL file. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Url | String | URL of the OCSP responder. | ||
Cert Alias | String | Alias of the signing certificate for the OCSP response. If specified, the alias must be in the truststore. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Replay Id | Number | Subscriber receives all events after the event specified by its Replay Id value. The value is ignored if the replay option is set on | x |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Max Idle Time | Number | Configures the maximum amount of time that a dynamic configuration instance can remain idle before Mule considers it eligible for expiration. | ||
Time Unit | Enumeration, one of:
| Time unit for the Max Idle Time field. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Path | String | Path to the keystore. Mule resolves the path relative to the current classpath and file system. | ||
Type | String | Type of keystore. | ||
Alias | String | Alias of the key to use when the keystore contains multiple private keys. By default, Mule uses the first key in the file. | ||
Key Password | String | Password used to protect the private key. | ||
Password | String | Password used to protect the keystore. | ||
Algorithm | String | Encryption algorithm that the keystore uses. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Host | String | Host in which the proxy requests are sent. | x | |
Port | Number | Port in which the proxy requests are sent. | x | |
Username | String | Username to authenticate against the proxy. | ||
Password | String | Password to authenticate against the proxy. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Frequency | Number | How often to attempt to reconnect, in milliseconds. | ||
Blocking | Boolean | If | ||
Count | Number | How many reconnection attempts the Mule app can make. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Frequency | Number | How often to attempt to reconnect, in milliseconds. | ||
Blocking | Boolean | If |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Fails Deployment | Boolean | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. | ||
Reconnection Strategy | Reconnection strategy to use. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Max Redelivery Count | Number | Maximum number of times that a redelivered request can be processed unsuccessfully before returning a | ||
Message Digest Algorithm | String | Secure hashing algorithm to use if the Use Secure Hash field is | ||
Message Identifier | One or more expressions that determine if a message was redelivered. This property can be set only if the Use Secure Hash field is | |||
Object Store | ObjectStore | Configures the object store that stores the redelivery counter for each message. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Use Secure Hash | Boolean | If | ||
Id Expression | String | One or more expressions that determine when a message was redelivered. You can set this property only if the Use Secure Hash field is |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
In Memory Size | Number | Maximum amount of memory that the stream can use for data. If the amount of memory exceeds this value, Mule buffers the content to disk. To optimize performance:
| ||
Buffer Unit | Enumeration, one of:
| Unit for the In Memory Size field. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Initial Buffer Size | Number | Initial amount of memory to allocate to the data stream. If the streamed data exceeds this value, the buffer expands by Buffer Size Increment, with an upper limit of Max In Memory Size value. | ||
Buffer Size Increment | Number | This is by how much the buffer size expands if it exceeds its initial size. Setting a value of zero or lower means that the buffer should not expand, meaning that a | ||
Max Buffer Size | Number | Maximum size of the buffer. If the buffer size exceeds this value, Mule raises a | ||
Buffer Unit | Enumeration, one of:
| Unit for the Initial Buffer Size, Buffer Size Increment, and Buffer Unit fields. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Os Name | String | Name of the object store from where to get the latest replay ID. The value is ignored if the replay option is set on | x | |
Os Key | String | Name of the key that contains the latest replay ID. The value is ignored if the replay option is set on | x |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Only End Entities | Boolean | Which elements to verify in the certificate chain:
| ||
Prefer Crls | Boolean | How to check certificate validity:
| ||
No Fallback | Boolean | Whether to use the secondary method to check certificate validity:
| ||
Soft Fail | Boolean | What to do if the revocation server can’t be reached or is busy:
|
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Enabled Protocols | String | Comma-separated list of protocols enabled for this context. | ||
Enabled Cipher Suites | String | Comma-separated list of cipher suites enabled for this context. | ||
Trust Store | Configures the TLS truststore. | |||
Key Store | Configures the TLS keystore. | |||
Revocation Check | Configures a revocation checking mechanism. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Path | String | Path to the truststore. Mule resolves the path relative to the current classpath and file system. | ||
Password | String | Password used to protect the truststore. | ||
Type | String | Type of truststore. | ||
Algorithm | String | Encryption algorithm that the truststore uses. | ||
Insecure | Boolean | If |
| Replay Option | Description | Usage |
|---|---|---|
| The Subscriber receives all stored events after the event specified by its replay ID value, and new events. | Catch up on missed events after a certain event message, for example, after a connection failure. To subscribe with a specific replay ID, save the replay ID of the event message to retrieve stored events after, and then use it when you resubscribe. |
| If no replay option is specified, this is the default. The Subscriber receives new events that are broadcast after the client subscribes. | It is best to subscribe with the |
| The Subscriber receives all events, including past events that are within the 72-hour retention window. | Catch up on missed events and retrieve all stored events, for example, after a connection failure. Using this option can slow performance if a large number of event messages are stored. |
| The Subscriber receives only events with a replay ID higher than the specified value in object store. If no value is found, it defaults to | For more information on how to use |
| Field | Value |
|---|---|
Topic | Name of the topic used for message publishing, for example, |
Job Id |
|
| Field | Value |
|---|---|
Publish Request Timeout |
|
Publish Request Time Unit |
|
| Field | Value |
|---|---|
Channel name | Name of the streaming channel to subscribe to, for example, |
Replay option | One of the given implementations, for example, |
Batch events size | Total number of events included in a server batch. Lower values indicate small memory footprint with more server calls, while bigger values indicate bigger memory footprint with fewer API calls. A new batch of events is requested by the connector after the flow consumes the existing events, for example, |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Name | String | Name for this configuration. Connectors reference the configuration with this name. | x | |
Connection | Connection types for this configuration. | x | ||
Name | String | ID used to reference this configuration. | x | |
Expiration Policy | Configures the minimum amount of time that a dynamic configuration instance can remain idle before Mule considers it eligible for expiration. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Username | String | Username used to initialize the session. | x | |
Password | String | Password used to authenticate the user. | x | |
Security Token | String | User’s security token. The security token can be omitted if your IP has been added to the allowlist on Salesforce. | ||
Authorization URL | String | Web service URL responsible for user authentication. The URL for the endpoint that is configured to handle SOAP authentication requests. | ||
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. | |||
Consumer Key | String | OAuth consumer key, as registered with the service provider. | x | |
Consumer Secret | String | OAuth consumer secret, as registered with the service provider. | x | |
Authorization Url | String | URL of the service provider’s authorization endpoint. |
| |
Access Token Url | String | URL of the service provider’s access token endpoint. |
| |
Scopes | String | OAuth scopes to request during the OAuth dance. This value defaults to the scopes in the annotation. | ||
Resource Owner Id | String | Resource owner ID to use with the authorization code grant type. | ||
Before | String | Name of the flow to execute immediately before starting the OAuth dance. | ||
After | String | Name of the flow to execute immediately after receiving an access token. | ||
Listener Config | String | Configuration for the HTTP listener that listens for requests on the access token callback endpoint. | x | |
Callback Path | String | Path of the access token callback endpoint. | x | |
Authorize Path | String | Path of the local HTTP endpoint that triggers the OAuth dance. | x | |
External Callback Url | String | URL that the OAuth provider uses to access the callback endpoint if the endpoint is behind a proxy or accessed through an indirect URL. | ||
Object Store | String | Configures the object store that stores data for each resource owner. If not configured, Mule uses the default object store. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
Consumer Key | String | Consumer key for the Salesforce connected app. | x | |
Key Store | String | Path to the keystore used to sign data during authentication. | x | |
Store Password | String | Password of the keystore. | x | |
Certificate Alias | String | Alias of the certificate. | ||
Principal | String | Username of the desired Salesforce user to take action on behalf of. | x | |
Token Endpoint | String | URL pointing to the server responsible for providing the authentication token. According to Salesforce, the Token Endpoint field is |
| |
Audience Url | String | Audience identifies the authorization server as an intended audience. The authorization server must verify that the authorization server is an intended audience for the token. Use the authorization server’s URL for the audience value: | ||
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
Consumer Key | String | Consumer key for the Salesforce connected app. | x | |
Consumer Secret | String | Your application’s client secret (consumer secret in Remote Access Detail). | x | |
Username | String | Username used to initialize the session. | x | |
Password | String | Password used to authenticate the user. | x | |
Security Token | String | User’s security token. The security token can be omitted if your IP has been added to the allowlist on Salesforce. | ||
Token Endpoint | String | URL pointing to the server responsible for providing the authentication token. According to Salesforce, the Token Endpoint field is |
| |
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
Consumer Key | String | Consumer key for the Salesforce connected app. | x | |
Key Store | String | Path to the keystore used to sign data during authentication. | x | |
Store Password | String | Password of the keystore. | x | |
Certificate Alias | String | Alias of the certificate. | ||
Principal | String | Username of the desired Salesforce user to take action on behalf of. | x | |
Token Endpoint | String | URL pointing to the server responsible for providing the authentication token. According to Salesforce, the Token Endpoint field is |
| |
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Configuration | String | Name of the configuration to use. | x | |
Channel Name | String | Name of the streaming channel to subscribe to. | x | |
Replay Option | One of:
| Interface with the following implementations:
| x | |
Batch events size | Number | Total number of events included in a server batch. Lower values indicate small memory footprint with more server calls, while higher values indicate bigger memory footprint with less API calls. A new batch of events is requested by the connector after the flow consumes the existing events. The maximum value is |
| |
Config Ref | ConfigurationProvider | Name of the configuration used to execute this component. | x | |
Primary Node Only | Boolean | Determines whether to execute this source on only the primary node when running Mule instances in a cluster. |
| |
Streaming Strategy |
| Configures how Mule processes streams. Repeatable streams are the default behavior. | ||
Redelivery Policy | Defines a policy for processing the redelivery of the same message. | |||
Reconnection Strategy | Retry strategy in case of connectivity errors. |
Type | Any |
Attributes Type | Any |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Configuration | String | Name of the configuration to use. | x | |
Topic | String | Name of the topic used for message publishing. You can select the topic name from the list of available topics. Sample topic formats:
For more information, refer to the Salesforce documentation. | x | |
Events | Array of Object | List of events to publish that match the schema of the current topic. |
| |
Config Ref | ConfigurationProvider | Name of the configuration used to execute this component. | x | |
Target Variable | String | Name of the variable that stores the operation’s output. | ||
Target Value | String | Expression that evaluates the operation’s output. The outcome of the expression is stored in the Target Variable field. |
| |
Reconnection Strategy | Retry strategy in case of connectivity errors. |
Type | Array of Object |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Configuration | String | Name of the configuration to use. | x | |
Resource Owner Id | String | ID of the resource owner for whom to invalidate access. | ||
Config Ref | ConfigurationProvider | Name of the configuration used to execute this component. | x |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Path | String | Path to the CRL file. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Url | String | URL of the OCSP responder. | ||
Cert Alias | String | Alias of the signing certificate for the OCSP response. If specified, the alias must be in the truststore. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Replay Id | Number | Subscriber receives all events after the event specified by its Replay Id value. The value is ignored if the replay option is set on | x |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Max Idle Time | Number | Configures the maximum amount of time that a dynamic configuration instance can remain idle before Mule considers it eligible for expiration. | ||
Time Unit | Enumeration, one of:
| Time unit for the Max Idle Time field. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Path | String | Path to the keystore. Mule resolves the path relative to the current classpath and file system. | ||
Type | String | Type of keystore. | ||
Alias | String | Alias of the key to use when the keystore contains multiple private keys. By default, Mule uses the first key in the file. | ||
Key Password | String | Password used to protect the private key. | ||
Password | String | Password used to protect the keystore. | ||
Algorithm | String | Encryption algorithm that the keystore uses. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Host | String | Host in which the proxy requests are sent. | x | |
Port | Number | Port in which the proxy requests are sent. | x | |
Username | String | Username to authenticate against the proxy. | ||
Password | String | Password to authenticate against the proxy. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Frequency | Number | How often to attempt to reconnect, in milliseconds. | ||
Blocking | Boolean | If | ||
Count | Number | How many reconnection attempts the Mule app can make. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Frequency | Number | How often to attempt to reconnect, in milliseconds. | ||
Blocking | Boolean | If |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Fails Deployment | Boolean | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. | ||
Reconnection Strategy | Reconnection strategy to use. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Max Redelivery Count | Number | Maximum number of times that a redelivered request can be processed unsuccessfully before returning a | ||
Message Digest Algorithm | String | Secure hashing algorithm to use if the Use Secure Hash field is | ||
Message Identifier | One or more expressions that determine if a message was redelivered. This property can be set only if the Use Secure Hash field is | |||
Object Store | ObjectStore | Configures the object store that stores the redelivery counter for each message. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Use Secure Hash | Boolean | If | ||
Id Expression | String | One or more expressions that determine when a message was redelivered. You can set this property only if the Use Secure Hash field is |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
In Memory Size | Number | Maximum amount of memory that the stream can use for data. If the amount of memory exceeds this value, Mule buffers the content to disk. To optimize performance:
| ||
Buffer Unit | Enumeration, one of:
| Unit for the In Memory Size field. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Initial Buffer Size | Number | Initial amount of memory to allocate to the data stream. If the streamed data exceeds this value, the buffer expands by Buffer Size Increment, with an upper limit of Max In Memory Size value. | ||
Buffer Size Increment | Number | This is by how much the buffer size expands if it exceeds its initial size. Setting a value of zero or lower means that the buffer should not expand, meaning that a | ||
Max Buffer Size | Number | Maximum size of the buffer. If the buffer size exceeds this value, Mule raises a | ||
Buffer Unit | Enumeration, one of:
| Unit for the Initial Buffer Size, Buffer Size Increment, and Buffer Unit fields. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Os Name | String | Name of the object store from where to get the latest replay ID. The value is ignored if the replay option is set on | x | |
Os Key | String | Name of the key that contains the latest replay ID. The value is ignored if the replay option is set on | x |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Only End Entities | Boolean | Which elements to verify in the certificate chain:
| ||
Prefer Crls | Boolean | How to check certificate validity:
| ||
No Fallback | Boolean | Whether to use the secondary method to check certificate validity:
| ||
Soft Fail | Boolean | What to do if the revocation server can’t be reached or is busy:
|
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Enabled Protocols | String | Comma-separated list of protocols enabled for this context. | ||
Enabled Cipher Suites | String | Comma-separated list of cipher suites enabled for this context. | ||
Trust Store | Configures the TLS truststore. | |||
Key Store | Configures the TLS keystore. | |||
Revocation Check | Configures a revocation checking mechanism. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Path | String | Path to the truststore. Mule resolves the path relative to the current classpath and file system. | ||
Password | String | Password used to protect the truststore. | ||
Type | String | Type of truststore. | ||
Algorithm | String | Encryption algorithm that the truststore uses. | ||
Insecure | Boolean | If |
| Replay Option | Description | Usage |
|---|---|---|
| The Subscriber receives all stored events after the event specified by its replay ID value, and new events. | Catch up on missed events after a certain event message, for example, after a connection failure. To subscribe with a specific replay ID, save the replay ID of the event message to retrieve stored events after, and then use it when you resubscribe. |
| If no replay option is specified, this is the default. The Subscriber receives new events that are broadcast after the client subscribes. | It is best to subscribe with the |
| The Subscriber receives all events, including past events that are within the 72-hour retention window. | Catch up on missed events and retrieve all stored events, for example, after a connection failure. Using this option can slow performance if a large number of event messages are stored. |
| The Subscriber receives only events with a replay ID higher than the specified value in object store. If no value is found, it defaults to | For more information on how to use |
| Field | Value |
|---|---|
Topic | Name of the topic used for message publishing, for example, |
Job Id |
|
| Field | Value |
|---|---|
Publish Request Timeout |
|
Publish Request Time Unit |
|
| Field | Value |
|---|---|
Channel name | Name of the streaming channel to subscribe to, for example, |
Replay option | One of the given implementations, for example, |
Batch events size | Total number of events included in a server batch. Lower values indicate small memory footprint with more server calls, while bigger values indicate bigger memory footprint with fewer API calls. A new batch of events is requested by the connector after the flow consumes the existing events, for example, |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Name | String | Name for this configuration. Connectors reference the configuration with this name. | x | |
Connection | Connection types for this configuration. Note that the | x | ||
Name | String | ID used to reference this configuration. | x | |
Expiration Policy | Configures the minimum amount of time that a dynamic configuration instance can remain idle before Mule considers it eligible for expiration. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Username | String | Username used to initialize the session. | x | |
Password | String | Password used to authenticate the user. | x | |
Security Token | String | User’s security token. The security token can be omitted if your IP has been added to the allowlist on Salesforce. | ||
Authorization URL | String | Web service URL responsible for user authentication. The URL for the endpoint that is configured to handle SOAP authentication requests. | ||
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Inactivity Watchdog Scheduler Frequency | Number | Specifies how often the inactivity watchdog scheduler checks each subscriber for activity. If the scheduler detects no activity on a subscriber’s channel since the previous check, it triggers a controlled resubscription so that the subscriber can continue receiving events. Values less than or equal to 0, including blank entries, disable the inactivity watchdog. | ||
Inactivity Watchdog Scheduler Time Unit | Enumeration, one of:
| Time unit for the Inactivity Watchdog Scheduler Frequency field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Inactivity Watchdog Scheduler Frequency | Number | Specifies how often the inactivity watchdog scheduler checks each subscriber for activity. If the scheduler detects no activity on a subscriber’s channel since the previous check, it triggers a controlled resubscription so that the subscriber can continue receiving events. Values less than or equal to 0, including blank entries, disable the inactivity watchdog. | ||
Inactivity Watchdog Scheduler Time Unit | Enumeration, one of:
| Time unit for the Inactivity Watchdog Scheduler Frequency field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. | |||
Consumer Key | String | OAuth consumer key, as registered with the service provider. | x | |
Consumer Secret | String | OAuth consumer secret, as registered with the service provider. | x | |
Authorization Url | String | URL of the service provider’s authorization endpoint. |
| |
Access Token Url | String | URL of the service provider’s access token endpoint. |
| |
Scopes | String | OAuth scopes to request during the OAuth dance. This value defaults to the scopes in the annotation. | ||
Resource Owner Id | String | Resource owner ID to use with the authorization code grant type. | ||
Before | String | Name of the flow to execute immediately before starting the OAuth dance. | ||
After | String | Name of the flow to execute immediately after receiving an access token. | ||
Listener Config | String | Configuration for the HTTP listener that listens for requests on the access token callback endpoint. | x | |
Callback Path | String | Path of the access token callback endpoint. | x | |
Authorize Path | String | Path of the local HTTP endpoint that triggers the OAuth dance. | x | |
External Callback Url | String | URL that the OAuth provider uses to access the callback endpoint if the endpoint is behind a proxy or accessed through an indirect URL. | ||
Object Store | String | Configures the object store that stores data for each resource owner. If not configured, Mule uses the default object store. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
Consumer Key | String | Consumer key for the Salesforce connected app. | x | |
Key Store | String | Path to the keystore used to sign data during authentication. | x | |
Store Password | String | Password of the keystore. | x | |
Certificate Alias | String | Alias of the certificate. | ||
Principal | String | Username of the desired Salesforce user to take action on behalf of. | x | |
Token Endpoint | String | URL pointing to the server responsible for providing the authentication token. According to Salesforce, the Token Endpoint field is |
| |
Audience Url | String | Audience identifies the authorization server as an intended audience. The authorization server must verify that the authorization server is an intended audience for the token. Use the authorization server’s URL for the audience value: | ||
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Inactivity Watchdog Scheduler Frequency | Number | Specifies how often the inactivity watchdog scheduler checks each subscriber for activity. If the scheduler detects no activity on a subscriber’s channel since the previous check, it triggers a controlled resubscription so that the subscriber can continue receiving events. Values less than or equal to 0, including blank entries, disable the inactivity watchdog. | ||
Inactivity Watchdog Scheduler Time Unit | Enumeration, one of:
| Time unit for the Inactivity Watchdog Scheduler Frequency field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
Consumer Key | String | Consumer key for the Salesforce connected app. | x | |
Consumer Secret | String | Your application’s client secret (consumer secret in Remote Access Detail). | x | |
Username | String | Username used to initialize the session. | x | |
Password | String | Password used to authenticate the user. | x | |
Security Token | String | User’s security token. The security token can be omitted if your IP has been added to the allowlist on Salesforce. | ||
Token Endpoint | String | URL pointing to the server responsible for providing the authentication token. According to Salesforce, the Token Endpoint field is |
| |
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Inactivity Watchdog Scheduler Frequency | Number | Specifies how often the inactivity watchdog scheduler checks each subscriber for activity. If the scheduler detects no activity on a subscriber’s channel since the previous check, it triggers a controlled resubscription so that the subscriber can continue receiving events. Values less than or equal to 0, including blank entries, disable the inactivity watchdog. | ||
Inactivity Watchdog Scheduler Time Unit | Enumeration, one of:
| Time unit for the Inactivity Watchdog Scheduler Frequency field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
Consumer Key | String | Consumer key for the Salesforce connected app. | x | |
Key Store | String | Path to the keystore used to sign data during authentication. | x | |
Store Password | String | Password of the keystore. | x | |
Certificate Alias | String | Alias of the certificate. | ||
Principal | String | Username of the desired Salesforce user to take action on behalf of. | x | |
Token Endpoint | String | URL pointing to the server responsible for providing the authentication token. According to Salesforce, the Token Endpoint field is |
| |
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Inactivity Watchdog Scheduler Frequency | Number | Specifies how often the inactivity watchdog scheduler checks each subscriber for activity. If the scheduler detects no activity on a subscriber’s channel since the previous check, it triggers a controlled resubscription so that the subscriber can continue receiving events. Values less than or equal to 0, including blank entries, disable the inactivity watchdog. | ||
Inactivity Watchdog Scheduler Time Unit | Enumeration, one of:
| Time unit for the Inactivity Watchdog Scheduler Frequency field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Configuration | String | Name of the configuration to use. | x | |
Channel Name | String | Name of the streaming channel to subscribe to. | x | |
Replay Option | One of:
| Interface with the following implementations:
| x | |
Batch events size | Number | Total number of events included in a server batch. Lower values indicate small memory footprint with more server calls, while higher values indicate bigger memory footprint with less API calls. A new batch of events is requested by the connector after the flow consumes the existing events. The maximum value is |
| |
Config Ref | ConfigurationProvider | Name of the configuration used to execute this component. | x | |
Primary Node Only | Boolean | Determines whether to execute this source on only the primary node when running Mule instances in a cluster. |
| |
Streaming Strategy |
| Configures how Mule processes streams. Repeatable streams are the default behavior. | ||
Redelivery Policy | Defines a policy for processing the redelivery of the same message. | |||
Reconnection Strategy | Retry strategy in case of connectivity errors. |
Type | Any |
Attributes Type | Any |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Configuration | String | Name of the configuration to use. | x | |
Topic | String | Name of the topic used for message publishing. You can select the topic name from the list of available topics. Sample topic formats:
For more information, refer to the Salesforce documentation. | x | |
Events | Array of Object | List of events to publish that match the schema of the current topic. |
| |
Config Ref | ConfigurationProvider | Name of the configuration used to execute this component. | x | |
Target Variable | String | Name of the variable that stores the operation’s output. | ||
Target Value | String | Expression that evaluates the operation’s output. The outcome of the expression is stored in the Target Variable field. |
| |
Reconnection Strategy | Retry strategy in case of connectivity errors. |
Type | Array of Object |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Configuration | String | Name of the configuration to use. | x | |
Resource Owner Id | String | ID of the resource owner for whom to invalidate access. | ||
Config Ref | ConfigurationProvider | Name of the configuration used to execute this component. | x |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Path | String | Path to the CRL file. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Url | String | URL of the OCSP responder. | ||
Cert Alias | String | Alias of the signing certificate for the OCSP response. If specified, the alias must be in the truststore. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Replay Id | Number | Subscriber receives all events after the event specified by its Replay Id value. The value is ignored if the replay option is set on | x |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Max Idle Time | Number | Configures the maximum amount of time that a dynamic configuration instance can remain idle before Mule considers it eligible for expiration. | ||
Time Unit | Enumeration, one of:
| Time unit for the Max Idle Time field. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Path | String | Path to the keystore. Mule resolves the path relative to the current classpath and file system. | ||
Type | String | Type of keystore. | ||
Alias | String | Alias of the key to use when the keystore contains multiple private keys. By default, Mule uses the first key in the file. | ||
Key Password | String | Password used to protect the private key. | ||
Password | String | Password used to protect the keystore. | ||
Algorithm | String | Encryption algorithm that the keystore uses. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Host | String | Host in which the proxy requests are sent. | x | |
Port | Number | Port in which the proxy requests are sent. | x | |
Username | String | Username to authenticate against the proxy. | ||
Password | String | Password to authenticate against the proxy. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Frequency | Number | How often to attempt to reconnect, in milliseconds. | ||
Blocking | Boolean | If | ||
Count | Number | How many reconnection attempts the Mule app can make. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Frequency | Number | How often to attempt to reconnect, in milliseconds. | ||
Blocking | Boolean | If |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Fails Deployment | Boolean | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. | ||
Reconnection Strategy | Reconnection strategy to use. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Max Redelivery Count | Number | Maximum number of times that a redelivered request can be processed unsuccessfully before returning a | ||
Message Digest Algorithm | String | Secure hashing algorithm to use if the Use Secure Hash field is | ||
Message Identifier | One or more expressions that determine if a message was redelivered. This property can be set only if the Use Secure Hash field is | |||
Object Store | ObjectStore | Configures the object store that stores the redelivery counter for each message. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Use Secure Hash | Boolean | If | ||
Id Expression | String | One or more expressions that determine when a message was redelivered. You can set this property only if the Use Secure Hash field is |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
In Memory Size | Number | Maximum amount of memory that the stream can use for data. If the amount of memory exceeds this value, Mule buffers the content to disk. To optimize performance:
| ||
Buffer Unit | Enumeration, one of:
| Unit for the In Memory Size field. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Initial Buffer Size | Number | Initial amount of memory to allocate to the data stream. If the streamed data exceeds this value, the buffer expands by Buffer Size Increment, with an upper limit of Max In Memory Size value. | ||
Buffer Size Increment | Number | This is by how much the buffer size expands if it exceeds its initial size. Setting a value of zero or lower means that the buffer should not expand, meaning that a | ||
Max Buffer Size | Number | Maximum size of the buffer. If the buffer size exceeds this value, Mule raises a | ||
Buffer Unit | Enumeration, one of:
| Unit for the Initial Buffer Size, Buffer Size Increment, and Buffer Unit fields. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Os Name | String | Name of the object store from where to get the latest replay ID. The value is ignored if the replay option is set on | x | |
Os Key | String | Name of the key that contains the latest replay ID. The value is ignored if the replay option is set on | x |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Only End Entities | Boolean | Which elements to verify in the certificate chain:
| ||
Prefer Crls | Boolean | How to check certificate validity:
| ||
No Fallback | Boolean | Whether to use the secondary method to check certificate validity:
| ||
Soft Fail | Boolean | What to do if the revocation server can’t be reached or is busy:
|
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Enabled Protocols | String | Comma-separated list of protocols enabled for this context. | ||
Enabled Cipher Suites | String | Comma-separated list of cipher suites enabled for this context. | ||
Trust Store | Configures the TLS truststore. | |||
Key Store | Configures the TLS keystore. | |||
Revocation Check | Configures a revocation checking mechanism. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Path | String | Path to the truststore. Mule resolves the path relative to the current classpath and file system. | ||
Password | String | Password used to protect the truststore. | ||
Type | String | Type of truststore. | ||
Algorithm | String | Encryption algorithm that the truststore uses. | ||
Insecure | Boolean | If |
| Replay Option | Description | Usage |
|---|---|---|
| The Subscriber receives all stored events after the event specified by its replay ID value, and new events. | Catch up on missed events after a certain event message, for example, after a connection failure. To subscribe with a specific replay ID, save the replay ID of the event message to retrieve stored events after, and then use it when you resubscribe. |
| If no replay option is specified, this is the default. The Subscriber receives new events that are broadcast after the client subscribes. | It is best to subscribe with the |
| The Subscriber receives all events, including past events that are within the 72-hour retention window. | Catch up on missed events and retrieve all stored events, for example, after a connection failure. Using this option can slow performance if a large number of event messages are stored. |
| The Subscriber receives only events with a replay ID higher than the specified value in object store. If no value is found, it defaults to | For more information on how to use |
| Field | Value |
|---|---|
Topic | Name of the topic used for message publishing, for example, |
Job Id |
|
| Field | Value |
|---|---|
Publish Request Timeout |
|
Publish Request Time Unit |
|
| Field | Value |
|---|---|
Channel name | Name of the streaming channel to subscribe to, for example, |
Replay option | One of the given implementations, for example, |
Batch events size | Total number of events included in a server batch. Lower values indicate small memory footprint with more server calls, while bigger values indicate bigger memory footprint with fewer API calls. A new batch of events is requested by the connector after the flow consumes the existing events, for example, |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Name | String | Name for this configuration. Connectors reference the configuration with this name. | x | |
Connection | Connection types for this configuration. Note that the | x | ||
Name | String | ID used to reference this configuration. | x | |
Expiration Policy | Configures the minimum amount of time that a dynamic configuration instance can remain idle before Mule considers it eligible for expiration. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Username | String | Username used to initialize the session. | x | |
Password | String | Password used to authenticate the user. | x | |
Security Token | String | User’s security token. The security token can be omitted if your IP has been added to the allowlist on Salesforce. | ||
Authorization URL | String | Web service URL responsible for user authentication. The URL for the endpoint that is configured to handle SOAP authentication requests. | ||
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Inactivity Watchdog Scheduler Frequency | Number | Specifies how often the inactivity watchdog scheduler checks each subscriber for activity. If the scheduler detects no activity on a subscriber’s channel since the previous check, it triggers a controlled resubscription so that the subscriber can continue receiving events. Values less than or equal to 0, including blank entries, disable the inactivity watchdog. | ||
Inactivity Watchdog Scheduler Time Unit | Enumeration, one of:
| Time unit for the Inactivity Watchdog Scheduler Frequency field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Inactivity Watchdog Scheduler Frequency | Number | Specifies how often the inactivity watchdog scheduler checks each subscriber for activity. If the scheduler detects no activity on a subscriber’s channel since the previous check, it triggers a controlled resubscription so that the subscriber can continue receiving events. Values less than or equal to 0, including blank entries, disable the inactivity watchdog. | ||
Inactivity Watchdog Scheduler Time Unit | Enumeration, one of:
| Time unit for the Inactivity Watchdog Scheduler Frequency field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. | |||
Consumer Key | String | OAuth consumer key, as registered with the service provider. | x | |
Consumer Secret | String | OAuth consumer secret, as registered with the service provider. | x | |
Authorization Url | String | URL of the service provider’s authorization endpoint. |
| |
Access Token Url | String | URL of the service provider’s access token endpoint. |
| |
Scopes | String | OAuth scopes to request during the OAuth dance. This value defaults to the scopes in the annotation. | ||
Resource Owner Id | String | Resource owner ID to use with the authorization code grant type. | ||
Before | String | Name of the flow to execute immediately before starting the OAuth dance. | ||
After | String | Name of the flow to execute immediately after receiving an access token. | ||
Listener Config | String | Configuration for the HTTP listener that listens for requests on the access token callback endpoint. | x | |
Callback Path | String | Path of the access token callback endpoint. | x | |
Authorize Path | String | Path of the local HTTP endpoint that triggers the OAuth dance. | x | |
External Callback Url | String | URL that the OAuth provider uses to access the callback endpoint if the endpoint is behind a proxy or accessed through an indirect URL. | ||
Object Store | String | Configures the object store that stores data for each resource owner. If not configured, Mule uses the default object store. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
Consumer Key | String | Consumer key for the Salesforce connected app. | x | |
Key Store | String | Path to the keystore used to sign data during authentication. | x | |
Store Password | String | Password of the keystore. | x | |
Certificate Alias | String | Alias of the certificate. | ||
Principal | String | Username of the desired Salesforce user to take action on behalf of. | x | |
Token Endpoint | String | URL pointing to the server responsible for providing the authentication token. According to Salesforce, the Token Endpoint field is |
| |
Audience Url | String | Audience identifies the authorization server as an intended audience. The authorization server must verify that the authorization server is an intended audience for the token. Use the authorization server’s URL for the audience value: | ||
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Inactivity Watchdog Scheduler Frequency | Number | Specifies how often the inactivity watchdog scheduler checks each subscriber for activity. If the scheduler detects no activity on a subscriber’s channel since the previous check, it triggers a controlled resubscription so that the subscriber can continue receiving events. Values less than or equal to 0, including blank entries, disable the inactivity watchdog. | ||
Inactivity Watchdog Scheduler Time Unit | Enumeration, one of:
| Time unit for the Inactivity Watchdog Scheduler Frequency field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
Consumer Key | String | Consumer key for the Salesforce connected app. | x | |
Consumer Secret | String | Your application’s client secret (consumer secret in Remote Access Detail). | x | |
Username | String | Username used to initialize the session. | x | |
Password | String | Password used to authenticate the user. | x | |
Security Token | String | User’s security token. The security token can be omitted if your IP has been added to the allowlist on Salesforce. | ||
Token Endpoint | String | URL pointing to the server responsible for providing the authentication token. According to Salesforce, the Token Endpoint field is |
| |
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Inactivity Watchdog Scheduler Frequency | Number | Specifies how often the inactivity watchdog scheduler checks each subscriber for activity. If the scheduler detects no activity on a subscriber’s channel since the previous check, it triggers a controlled resubscription so that the subscriber can continue receiving events. Values less than or equal to 0, including blank entries, disable the inactivity watchdog. | ||
Inactivity Watchdog Scheduler Time Unit | Enumeration, one of:
| Time unit for the Inactivity Watchdog Scheduler Frequency field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
Consumer Key | String | Consumer key for the Salesforce connected app. | x | |
Key Store | String | Path to the keystore used to sign data during authentication. | x | |
Store Password | String | Password of the keystore. | x | |
Certificate Alias | String | Alias of the certificate. | ||
Principal | String | Username of the desired Salesforce user to take action on behalf of. | x | |
Token Endpoint | String | URL pointing to the server responsible for providing the authentication token. According to Salesforce, the Token Endpoint field is |
| |
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Inactivity Watchdog Scheduler Frequency | Number | Specifies how often the inactivity watchdog scheduler checks each subscriber for activity. If the scheduler detects no activity on a subscriber’s channel since the previous check, it triggers a controlled resubscription so that the subscriber can continue receiving events. Values less than or equal to 0, including blank entries, disable the inactivity watchdog. | ||
Inactivity Watchdog Scheduler Time Unit | Enumeration, one of:
| Time unit for the Inactivity Watchdog Scheduler Frequency field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Configuration | String | Name of the configuration to use. | x | |
Channel Name | String | Name of the streaming channel to subscribe to. | x | |
Replay Option | One of:
| Interface with the following implementations:
| x | |
Batch events size | Number | Total number of events included in a server batch. Lower values indicate small memory footprint with more server calls, while higher values indicate bigger memory footprint with less API calls. A new batch of events is requested by the connector after the flow consumes the existing events. The maximum value is |
| |
Config Ref | ConfigurationProvider | Name of the configuration used to execute this component. | x | |
Primary Node Only | Boolean | Determines whether to execute this source on only the primary node when running Mule instances in a cluster. |
| |
Streaming Strategy |
| Configures how Mule processes streams. Repeatable streams are the default behavior. | ||
Redelivery Policy | Defines a policy for processing the redelivery of the same message. | |||
Reconnection Strategy | Retry strategy in case of connectivity errors. |
Type | Any |
Attributes Type | Any |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Configuration | String | Name of the configuration to use. | x | |
Topic | String | Name of the topic used for message publishing. You can select the topic name from the list of available topics. Sample topic formats:
For more information, refer to the Salesforce documentation. | x | |
Events | Array of Object | List of events to publish that match the schema of the current topic. |
| |
Config Ref | ConfigurationProvider | Name of the configuration used to execute this component. | x | |
Target Variable | String | Name of the variable that stores the operation’s output. | ||
Target Value | String | Expression that evaluates the operation’s output. The outcome of the expression is stored in the Target Variable field. |
| |
Error Mappings | Array of Error Mapping | Maps error types thrown by this operation to custom error types. | ||
Reconnection Strategy | Retry strategy in case of connectivity errors. |
Type | Array of Object |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Configuration | String | Name of the configuration to use. | x | |
Resource Owner Id | String | ID of the resource owner for whom to invalidate access. | ||
Config Ref | ConfigurationProvider | Name of the configuration used to execute this component. | x |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Path | String | Path to the CRL file. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Url | String | URL of the OCSP responder. | ||
Cert Alias | String | Alias of the signing certificate for the OCSP response. If specified, the alias must be in the truststore. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Replay Id | Number | Subscriber receives all events after the event specified by its Replay Id value. The value is ignored if the replay option is set on | x |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Source | Enumeration, one of:
| Source error type to map. | ||
Target | String | Custom error type to map the source error to. | x |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Max Idle Time | Number | Configures the maximum amount of time that a dynamic configuration instance can remain idle before Mule considers it eligible for expiration. | ||
Time Unit | Enumeration, one of:
| Time unit for the Max Idle Time field. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Path | String | Path to the keystore. Mule resolves the path relative to the current classpath and file system. | ||
Type | String | Type of keystore. | ||
Alias | String | Alias of the key to use when the keystore contains multiple private keys. By default, Mule uses the first key in the file. | ||
Key Password | String | Password used to protect the private key. | ||
Password | String | Password used to protect the keystore. | ||
Algorithm | String | Encryption algorithm that the keystore uses. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Host | String | Host in which the proxy requests are sent. | x | |
Port | Number | Port in which the proxy requests are sent. | x | |
Username | String | Username to authenticate against the proxy. | ||
Password | String | Password to authenticate against the proxy. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Frequency | Number | How often to attempt to reconnect, in milliseconds. | ||
Blocking | Boolean | If | ||
Count | Number | How many reconnection attempts the Mule app can make. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Frequency | Number | How often to attempt to reconnect, in milliseconds. | ||
Blocking | Boolean | If |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Fails Deployment | Boolean | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. | ||
Reconnection Strategy | Reconnection strategy to use. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Max Redelivery Count | Number | Maximum number of times that a redelivered request can be processed unsuccessfully before returning a | ||
Message Digest Algorithm | String | Secure hashing algorithm to use if the Use Secure Hash field is | ||
Message Identifier | One or more expressions that determine if a message was redelivered. This property can be set only if the Use Secure Hash field is | |||
Object Store | ObjectStore | Configures the object store that stores the redelivery counter for each message. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Use Secure Hash | Boolean | If | ||
Id Expression | String | One or more expressions that determine when a message was redelivered. You can set this property only if the Use Secure Hash field is |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
In Memory Size | Number | Maximum amount of memory that the stream can use for data. If the amount of memory exceeds this value, Mule buffers the content to disk. To optimize performance:
| ||
Buffer Unit | Enumeration, one of:
| Unit for the In Memory Size field. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Initial Buffer Size | Number | Initial amount of memory to allocate to the data stream. If the streamed data exceeds this value, the buffer expands by Buffer Size Increment, with an upper limit of Max In Memory Size value. | ||
Buffer Size Increment | Number | This is by how much the buffer size expands if it exceeds its initial size. Setting a value of zero or lower means that the buffer should not expand, meaning that a | ||
Max Buffer Size | Number | Maximum size of the buffer. If the buffer size exceeds this value, Mule raises a | ||
Buffer Unit | Enumeration, one of:
| Unit for the Initial Buffer Size, Buffer Size Increment, and Buffer Unit fields. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Os Name | String | Name of the object store from where to get the latest replay ID. The value is ignored if the replay option is set on | x | |
Os Key | String | Name of the key that contains the latest replay ID. The value is ignored if the replay option is set on | x |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Only End Entities | Boolean | Which elements to verify in the certificate chain:
| ||
Prefer Crls | Boolean | How to check certificate validity:
| ||
No Fallback | Boolean | Whether to use the secondary method to check certificate validity:
| ||
Soft Fail | Boolean | What to do if the revocation server can’t be reached or is busy:
|
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Enabled Protocols | String | Comma-separated list of protocols enabled for this context. | ||
Enabled Cipher Suites | String | Comma-separated list of cipher suites enabled for this context. | ||
Trust Store | Configures the TLS truststore. | |||
Key Store | Configures the TLS keystore. | |||
Revocation Check | Configures a revocation checking mechanism. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Path | String | Path to the truststore. Mule resolves the path relative to the current classpath and file system. | ||
Password | String | Password used to protect the truststore. | ||
Type | String | Type of truststore. | ||
Algorithm | String | Encryption algorithm that the truststore uses. | ||
Insecure | Boolean | If |
| Replay Option | Description | Usage |
|---|---|---|
| The Subscriber receives all stored events after the event specified by its replay ID value, and new events. | Catch up on missed events after a certain event message, for example, after a connection failure. To subscribe with a specific replay ID, save the replay ID of the event message to retrieve stored events after, and then use it when you resubscribe. |
| If no replay option is specified, this is the default. The Subscriber receives new events that are broadcast after the client subscribes. | It is best to subscribe with the |
| The Subscriber receives all events, including past events that are within the 72-hour retention window. | Catch up on missed events and retrieve all stored events, for example, after a connection failure. Using this option can slow performance if a large number of event messages are stored. |
| The Subscriber receives only events with a replay ID higher than the specified value in object store. If no value is found, it defaults to | For more information on how to use |
| Field | Value |
|---|---|
Topic | Name of the topic used for message publishing, for example, |
Job Id |
|
| Field | Value |
|---|---|
Publish Request Timeout |
|
Publish Request Time Unit |
|
| Field | Value |
|---|---|
Channel name | Name of the streaming channel to subscribe to, for example, |
Replay option | One of the given implementations, for example, |
Batch events size | Total number of events included in a server batch. Lower values indicate small memory footprint with more server calls, while bigger values indicate bigger memory footprint with fewer API calls. A new batch of events is requested by the connector after the flow consumes the existing events, for example, |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Name | String | Name for this configuration. Connectors reference the configuration with this name. | x | |
Connection | Connection types for this configuration. Note that the | x | ||
Name | String | ID used to reference this configuration. | x | |
Expiration Policy | Configures the minimum amount of time that a dynamic configuration instance can remain idle before Mule considers it eligible for expiration. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Username | String | Username used to initialize the session. | x | |
Password | String | Password used to authenticate the user. | x | |
Security Token | String | User’s security token. The security token can be omitted if your IP has been added to the allowlist on Salesforce. | ||
Authorization URL | String | Web service URL responsible for user authentication. The URL for the endpoint that is configured to handle SOAP authentication requests. | ||
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Inactivity Watchdog Scheduler Frequency | Number | Specifies how often the inactivity watchdog scheduler checks each subscriber for activity. If the scheduler detects no activity on a subscriber’s channel since the previous check, it triggers a controlled resubscription so that the subscriber can continue receiving events. Values less than or equal to 0, including blank entries, disable the inactivity watchdog. | ||
Inactivity Watchdog Scheduler Time Unit | Enumeration, one of:
| Time unit for the Inactivity Watchdog Scheduler Frequency field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Inactivity Watchdog Scheduler Frequency | Number | Specifies how often the inactivity watchdog scheduler checks each subscriber for activity. If the scheduler detects no activity on a subscriber’s channel since the previous check, it triggers a controlled resubscription so that the subscriber can continue receiving events. Values less than or equal to 0, including blank entries, disable the inactivity watchdog. | ||
Inactivity Watchdog Scheduler Time Unit | Enumeration, one of:
| Time unit for the Inactivity Watchdog Scheduler Frequency field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. | |||
Consumer Key | String | OAuth consumer key, as registered with the service provider. | x | |
Consumer Secret | String | OAuth consumer secret, as registered with the service provider. | x | |
Authorization Url | String | URL of the service provider’s authorization endpoint. |
| |
Access Token Url | String | URL of the service provider’s access token endpoint. |
| |
Scopes | String | OAuth scopes to request during the OAuth dance. This value defaults to the scopes in the annotation. | ||
Resource Owner Id | String | Resource owner ID to use with the authorization code grant type. | ||
Before | String | Name of the flow to execute immediately before starting the OAuth dance. | ||
After | String | Name of the flow to execute immediately after receiving an access token. | ||
Listener Config | String | Configuration for the HTTP listener that listens for requests on the access token callback endpoint. | x | |
Callback Path | String | Path of the access token callback endpoint. | x | |
Authorize Path | String | Path of the local HTTP endpoint that triggers the OAuth dance. | x | |
External Callback Url | String | URL that the OAuth provider uses to access the callback endpoint if the endpoint is behind a proxy or accessed through an indirect URL. | ||
Object Store | String | Configures the object store that stores data for each resource owner. If not configured, Mule uses the default object store. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
Consumer Key | String | Consumer key for the Salesforce connected app. | x | |
Key Store | String | Path to the keystore used to sign data during authentication. | x | |
Store Password | String | Password of the keystore. | x | |
Certificate Alias | String | Alias of the certificate. | ||
Principal | String | Username of the desired Salesforce user to take action on behalf of. | x | |
Token Endpoint | String | URL pointing to the server responsible for providing the authentication token. According to Salesforce, the Token Endpoint field is |
| |
Audience Url | String | Audience identifies the authorization server as an intended audience. The authorization server must verify that the authorization server is an intended audience for the token. Use the authorization server’s URL for the audience value: | ||
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Inactivity Watchdog Scheduler Frequency | Number | Specifies how often the inactivity watchdog scheduler checks each subscriber for activity. If the scheduler detects no activity on a subscriber’s channel since the previous check, it triggers a controlled resubscription so that the subscriber can continue receiving events. Values less than or equal to 0, including blank entries, disable the inactivity watchdog. | ||
Inactivity Watchdog Scheduler Time Unit | Enumeration, one of:
| Time unit for the Inactivity Watchdog Scheduler Frequency field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Inactivity Watchdog Scheduler Frequency | Number | Specifies how often the inactivity watchdog scheduler checks each subscriber for activity. If the scheduler detects no activity on a subscriber’s channel since the previous check, it triggers a controlled resubscription so that the subscriber can continue receiving events. Values less than or equal to 0, including blank entries, disable the inactivity watchdog. | ||
Inactivity Watchdog Scheduler Time Unit | Enumeration, one of:
| Time unit for the Inactivity Watchdog Scheduler Frequency field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. | |||
Client Id | String | OAuth client ID, as registered with the service provider. | x | |
Client Secret | String | OAuth client secret, as registered with the service provider. | x | |
Token Url | String | URL of the service provider’s token endpoint. |
| |
Scopes | String | OAuth scopes to request during the OAuth dance. This value defaults to the scopes in the annotation. | ||
Object Store | String | Configures the object store that stores data for each resource owner. If not configured, Mule uses the default object store. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
Consumer Key | String | Consumer key for the Salesforce connected app. | x | |
Consumer Secret | String | Your application’s client secret (consumer secret in Remote Access Detail). | x | |
Username | String | Username used to initialize the session. | x | |
Password | String | Password used to authenticate the user. | x | |
Security Token | String | User’s security token. The security token can be omitted if your IP has been added to the allowlist on Salesforce. | ||
Token Endpoint | String | URL pointing to the server responsible for providing the authentication token. According to Salesforce, the Token Endpoint field is |
| |
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Inactivity Watchdog Scheduler Frequency | Number | Specifies how often the inactivity watchdog scheduler checks each subscriber for activity. If the scheduler detects no activity on a subscriber’s channel since the previous check, it triggers a controlled resubscription so that the subscriber can continue receiving events. Values less than or equal to 0, including blank entries, disable the inactivity watchdog. | ||
Inactivity Watchdog Scheduler Time Unit | Enumeration, one of:
| Time unit for the Inactivity Watchdog Scheduler Frequency field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Connection Timeout | Number | How long the connector waits before timing out when establishing a connection to the remote service. Values less than one millisecond are converted to |
| |
Time unit | Enumeration, one of:
| Time unit for the Connection Timeout field. |
| |
Login Request Timeout | Number | How long the client waits to receive the answer for the login request before timing out. Values less than one millisecond are converted to |
| |
Login Request Time unit | Enumeration, one of:
| Time unit for the Login Request Timeout field. |
| |
Proxy configuration | Configures a proxy for outbound connections. The requests to the gRPC API (towards the gRPC host and gRPC port) are proxied through the proxy server configured using this field. | |||
Api Version | Number | API version used. Defaults to the latest API version supported by the connector. | ||
Consumer Key | String | Consumer key for the Salesforce connected app. | x | |
Key Store | String | Path to the keystore used to sign data during authentication. | x | |
Store Password | String | Password of the keystore. | x | |
Certificate Alias | String | Alias of the certificate. | ||
Principal | String | Username of the desired Salesforce user to take action on behalf of. | x | |
Token Endpoint | String | URL pointing to the server responsible for providing the authentication token. According to Salesforce, the Token Endpoint field is |
| |
TLS configuration | Configures TLS. If using the HTTPS protocol, you must configure TLS. | |||
gRPC host | String | Host in which the proxy requests are sent to the gRPC API (towards the gRPC host). The proxy requests to the gRPC host go through the proxy. |
| |
gRPC port | Number | Port in which the proxy requests are sent to the gRPC API (towards the gRPC port). The proxy requests to the gRPC port go through the proxy. |
| |
Publish Request Timeout | Number | Specifies the amount of time the client waits for a publish request to complete before timing out. Values less than one millisecond are converted to 0 (no deadline). |
| |
Publish Request Time Unit | Enumeration, one of:
| Time unit for the Publish Request Timeout field. |
| |
Inactivity Watchdog Scheduler Frequency | Number | Specifies how often the inactivity watchdog scheduler checks each subscriber for activity. If the scheduler detects no activity on a subscriber’s channel since the previous check, it triggers a controlled resubscription so that the subscriber can continue receiving events. Values less than or equal to 0, including blank entries, disable the inactivity watchdog. | ||
Inactivity Watchdog Scheduler Time Unit | Enumeration, one of:
| Time unit for the Inactivity Watchdog Scheduler Frequency field. |
| |
Reconnection | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Configuration | String | Name of the configuration to use. | x | |
Channel Name | String | Name of the streaming channel to subscribe to. | x | |
Replay Option | One of:
| Interface with the following implementations:
| x | |
Batch events size | Number | Total number of events included in a server batch. Lower values indicate small memory footprint with more server calls, while higher values indicate bigger memory footprint with less API calls. A new batch of events is requested by the connector after the flow consumes the existing events. The maximum value is |
| |
Config Ref | ConfigurationProvider | Name of the configuration used to execute this component. | x | |
Primary Node Only | Boolean | Determines whether to execute this source on only the primary node when running Mule instances in a cluster. |
| |
Streaming Strategy |
| Configures how Mule processes streams. Repeatable streams are the default behavior. | ||
Redelivery Policy | Defines a policy for processing the redelivery of the same message. | |||
Reconnection Strategy | Retry strategy in case of connectivity errors. |
Type | Any |
Attributes Type | Any |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Configuration | String | Name of the configuration to use. | x | |
Topic | String | Name of the topic used for message publishing. You can select the topic name from the list of available topics. Sample topic formats:
For more information, refer to the Salesforce documentation. | x | |
Events | Array of Object | List of events to publish that match the schema of the current topic. |
| |
Config Ref | ConfigurationProvider | Name of the configuration used to execute this component. | x | |
Target Variable | String | Name of the variable that stores the operation’s output. | ||
Target Value | String | Expression that evaluates the operation’s output. The outcome of the expression is stored in the Target Variable field. |
| |
Error Mappings | Array of Error Mapping | Maps error types thrown by this operation to custom error types. | ||
Reconnection Strategy | Retry strategy in case of connectivity errors. |
Type | Array of Object |
| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
Configuration | String | Name of the configuration to use. | x | |
Resource Owner Id | String | ID of the resource owner for whom to invalidate access. | ||
Config Ref | ConfigurationProvider | Name of the configuration used to execute this component. | x |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Path | String | Path to the CRL file. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Url | String | URL of the OCSP responder. | ||
Cert Alias | String | Alias of the signing certificate for the OCSP response. If specified, the alias must be in the truststore. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Replay Id | Number | Subscriber receives all events after the event specified by its Replay Id value. The value is ignored if the replay option is set on | x |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Source | Enumeration, one of:
| Source error type to map. | ||
Target | String | Custom error type to map the source error to. | x |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Max Idle Time | Number | Configures the maximum amount of time that a dynamic configuration instance can remain idle before Mule considers it eligible for expiration. | ||
Time Unit | Enumeration, one of:
| Time unit for the Max Idle Time field. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Path | String | Path to the keystore. Mule resolves the path relative to the current classpath and file system. | ||
Type | String | Type of keystore. | ||
Alias | String | Alias of the key to use when the keystore contains multiple private keys. By default, Mule uses the first key in the file. | ||
Key Password | String | Password used to protect the private key. | ||
Password | String | Password used to protect the keystore. | ||
Algorithm | String | Encryption algorithm that the keystore uses. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Host | String | Host in which the proxy requests are sent. | x | |
Port | Number | Port in which the proxy requests are sent. | x | |
Username | String | Username to authenticate against the proxy. | ||
Password | String | Password to authenticate against the proxy. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Frequency | Number | How often to attempt to reconnect, in milliseconds. | ||
Blocking | Boolean | If | ||
Count | Number | How many reconnection attempts the Mule app can make. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Frequency | Number | How often to attempt to reconnect, in milliseconds. | ||
Blocking | Boolean | If |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Fails Deployment | Boolean | Configures a reconnection strategy to use when a connector operation fails to connect to an external server. | ||
Reconnection Strategy | Reconnection strategy to use. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Max Redelivery Count | Number | Maximum number of times that a redelivered request can be processed unsuccessfully before returning a | ||
Message Digest Algorithm | String | Secure hashing algorithm to use if the Use Secure Hash field is | ||
Message Identifier | One or more expressions that determine if a message was redelivered. This property can be set only if the Use Secure Hash field is | |||
Object Store | ObjectStore | Configures the object store that stores the redelivery counter for each message. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Use Secure Hash | Boolean | If | ||
Id Expression | String | One or more expressions that determine when a message was redelivered. You can set this property only if the Use Secure Hash field is |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
In Memory Size | Number | Maximum amount of memory that the stream can use for data. If the amount of memory exceeds this value, Mule buffers the content to disk. To optimize performance:
| ||
Buffer Unit | Enumeration, one of:
| Unit for the In Memory Size field. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Initial Buffer Size | Number | Initial amount of memory to allocate to the data stream. If the streamed data exceeds this value, the buffer expands by Buffer Size Increment, with an upper limit of Max In Memory Size value. | ||
Buffer Size Increment | Number | This is by how much the buffer size expands if it exceeds its initial size. Setting a value of zero or lower means that the buffer should not expand, meaning that a | ||
Max Buffer Size | Number | Maximum size of the buffer. If the buffer size exceeds this value, Mule raises a | ||
Buffer Unit | Enumeration, one of:
| Unit for the Initial Buffer Size, Buffer Size Increment, and Buffer Unit fields. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Os Name | String | Name of the object store from where to get the latest replay ID. The value is ignored if the replay option is set on | x | |
Os Key | String | Name of the key that contains the latest replay ID. The value is ignored if the replay option is set on | x |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Only End Entities | Boolean | Which elements to verify in the certificate chain:
| ||
Prefer Crls | Boolean | How to check certificate validity:
| ||
No Fallback | Boolean | Whether to use the secondary method to check certificate validity:
| ||
Soft Fail | Boolean | What to do if the revocation server can’t be reached or is busy:
|
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Enabled Protocols | String | Comma-separated list of protocols enabled for this context. | ||
Enabled Cipher Suites | String | Comma-separated list of cipher suites enabled for this context. | ||
Trust Store | Configures the TLS truststore. | |||
Key Store | Configures the TLS keystore. | |||
Revocation Check | Configures a revocation checking mechanism. |
| Field | Type | Description | Default Value | Required |
|---|---|---|---|---|
Path | String | Path to the truststore. Mule resolves the path relative to the current classpath and file system. | ||
Password | String | Password used to protect the truststore. | ||
Type | String | Type of truststore. | ||
Algorithm | String | Encryption algorithm that the truststore uses. | ||
Insecure | Boolean | If |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select Basic Authentication. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth v2.0. |
Consumer Key | Enter the OAuth consumer key, as registered with the service provider. |
Consumer Secret | Enter the OAuth consumer secret, as registered with the service provider. |
Listener Config | Enter the configuration for the HTTP listener that listens for requests on the access token callback endpoint. |
Callback Path | Enter the path of the access token callback endpoint. |
Authorize Path | Enter the path of the local HTTP endpoint that triggers the OAuth dance. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth JWT. |
Consumer Key | Enter the consumer key for the Salesforce connected app. |
Key Store | Enter the path to the keystore used to sign data during authentication. |
Store Password | Enter the password of the keystore. |
Principal | Enter the username of the desired Salesforce user to take action on behalf of. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth Username Password. |
Consumer Key | Enter the consumer key for the Salesforce connected app. |
Consumer Secret | Enter your application’s client secret (consumer secret in Remote Access Detail). |
Username | Enter the username used to initialize the session. |
Password | Enter the password used to authenticate the user. |
Principal | Enter the username of the desired Salesforce user to take action on behalf of. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth SAML. |
Consumer Key | Enter the consumer key for the Salesforce connected app. |
Key Store | Enter the path to the keystore used to sign data during authentication. |
Store Password | Enter the password of the keystore. |
Principal | Enter the username of the desired Salesforce user to take action on behalf of. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select Basic Authentication. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth v2.0. |
Consumer Key | Enter the OAuth consumer key, as registered with the service provider. |
Consumer Secret | Enter the OAuth consumer secret, as registered with the service provider. |
Listener Config | Enter the configuration for the HTTP listener that listens for requests on the access token callback endpoint. |
Callback Path | Enter the path of the access token callback endpoint. |
Authorize Path | Enter the path of the local HTTP endpoint that triggers the OAuth dance. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth JWT. |
Consumer Key | Enter the consumer key for the Salesforce connected app. |
Key Store | Enter the path to the keystore used to sign data during authentication. |
Store Password | Enter the password of the keystore. |
Principal | Enter the username of the desired Salesforce user to take action on behalf of. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth Username Password. |
Consumer Key | Enter the consumer key for the Salesforce connected app. |
Consumer Secret | Enter your application’s client secret (consumer secret in Remote Access Detail). |
Username | Enter the username used to initialize the session. |
Password | Enter the password used to authenticate the user. |
Principal | Enter the username of the desired Salesforce user to take action on behalf of. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth SAML. |
Consumer Key | Enter the consumer key for the Salesforce connected app. |
Key Store | Enter the path to the keystore used to sign data during authentication. |
Store Password | Enter the password of the keystore. |
Principal | Enter the username of the desired Salesforce user to take action on behalf of. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select Basic Authentication. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth v2.0. |
Consumer Key | Enter the OAuth consumer key, as registered with the service provider. |
Consumer Secret | Enter the OAuth consumer secret, as registered with the service provider. |
Listener Config | Enter the configuration for the HTTP listener that listens for requests on the access token callback endpoint. |
Callback Path | Enter the path of the access token callback endpoint. |
Authorize Path | Enter the path of the local HTTP endpoint that triggers the OAuth dance. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth JWT. |
Consumer Key | Enter the consumer key for the Salesforce connected app. |
Key Store | Enter the path to the keystore used to sign data during authentication. |
Store Password | Enter the password of the keystore. |
Principal | Enter the username of the desired Salesforce user to take action on behalf of. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth Username Password. |
Consumer Key | Enter the consumer key for the Salesforce connected app. |
Consumer Secret | Enter your application’s client secret (consumer secret in Remote Access Detail). |
Username | Enter the username used to initialize the session. |
Password | Enter the password used to authenticate the user. |
Principal | Enter the username of the desired Salesforce user to take action on behalf of. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth SAML. |
Consumer Key | Enter the consumer key for the Salesforce connected app. |
Key Store | Enter the path to the keystore used to sign data during authentication. |
Store Password | Enter the password of the keystore. |
Principal | Enter the username of the desired Salesforce user to take action on behalf of. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select Basic Authentication. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth v2.0. |
Consumer Key | Enter the OAuth consumer key, as registered with the service provider. |
Consumer Secret | Enter the OAuth consumer secret, as registered with the service provider. |
Listener Config | Enter the configuration for the HTTP listener that listens for requests on the access token callback endpoint. |
Callback Path | Enter the path of the access token callback endpoint. |
Authorize Path | Enter the path of the local HTTP endpoint that triggers the OAuth dance. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth JWT. |
Consumer Key | Enter the consumer key for the Salesforce connected app. |
Key Store | Enter the path to the keystore used to sign data during authentication. |
Store Password | Enter the password of the keystore. |
Principal | Enter the username of the desired Salesforce user to take action on behalf of. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth Username Password. |
Consumer Key | Enter the consumer key for the Salesforce connected app. |
Consumer Secret | Enter your application’s client secret (consumer secret in Remote Access Detail). |
Username | Enter the username used to initialize the session. |
Password | Enter the password used to authenticate the user. |
Principal | Enter the username of the desired Salesforce user to take action on behalf of. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth SAML. |
Consumer Key | Enter the consumer key for the Salesforce connected app. |
Key Store | Enter the path to the keystore used to sign data during authentication. |
Store Password | Enter the password of the keystore. |
Principal | Enter the username of the desired Salesforce user to take action on behalf of. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select Basic Authentication. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth v2.0. |
Consumer Key | Enter the OAuth consumer key, as registered with the service provider. |
Consumer Secret | Enter the OAuth consumer secret, as registered with the service provider. |
Listener Config | Enter the configuration for the HTTP listener that listens for requests on the access token callback endpoint. |
Callback Path | Enter the path of the access token callback endpoint. |
Authorize Path | Enter the path of the local HTTP endpoint that triggers the OAuth dance. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth JWT. |
Consumer Key | Enter the consumer key for the Salesforce connected app. |
Key Store | Enter the path to the keystore used to sign data during authentication. |
Store Password | Enter the password of the keystore. |
Principal | Enter the username of the desired Salesforce user to take action on behalf of. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth Client Credentials. |
Client Id | Enter the OAuth client ID, as registered with the service provider. |
Client Secret | Enter the OAuth client secret, as registered with the service provider. |
Token Url | Enter the URL of the service provider’s token endpoint. The token endpoint must be the org’s My-Domain endpoint. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth Username Password. |
Consumer Key | Enter the consumer key for the Salesforce connected app. |
Consumer Secret | Enter your application’s client secret (consumer secret in Remote Access Detail). |
Username | Enter the username used to initialize the session. |
Password | Enter the password used to authenticate the user. |
Principal | Enter the username of the desired Salesforce user to take action on behalf of. |
| Field | User Action |
|---|---|
Name | Enter the configuration name. |
Connection | Select OAuth SAML. |
Consumer Key | Enter the consumer key for the Salesforce connected app. |
Key Store | Enter the path to the keystore used to sign data during authentication. |
Store Password | Enter the password of the keystore. |
Principal | Enter the username of the desired Salesforce user to take action on behalf of. |