--- schema_version: "1" id: bae3be3d504545e227be17ed328ffb4f5b8ed37d09c6b135ed5fd5c104f26baa title: gRPC Connector 1.0 Reference collection: mulesoft version: current locale: en-us portal_url: https://docs.salesforce.com/mulesoft/current/en-us/grpc-connector/latest/grpc-connector-reference.md canonical_url: https://docs.mulesoft.com/grpc-connector/latest/grpc-connector-reference source_site: docs.mulesoft.com content_type: documentation content_hash: 03304b736db813a72916e9f247f23a1086e125fb42578c533dfaf0ad737dc8f1 description: MuleSoft Documentation Site release: "1.0" latest: true --- --- product: gRPC Connector version: 1.0 is-latest-version: true --- # gRPC Connector 1.0 Reference > For the full documentation index, see: https://docs.mulesoft.com/llms.txt Anypoint Connector for gRPC (gRPC Connector) enables you to connect to the gRPC API. ## Configurations --- ### Client Client configuration for connecting to gRPC services. #### Parameters

Name	Type	Description	Default Value	Required
Name	String	The name for this configuration. Connectors reference the configuration with this name.		x
Connection	Google Service Account Auth Provider No Auth Oauth Client Credentials	The connection types to provide to this configuration.		x
Deadline	Deadline	Deadline configuration for gRPC calls. This deadline applies to all operations unless overridden at the operation level.
Response Wait Time	Number	Time to wait for server response after sending each message in client streaming. Overridable at the operation level. A value of 0 means no wait (return immediately with an empty continuation response).	0
Response Wait Time Unit	Enumeration, one of: NANOSECONDS MICROSECONDS MILLISECONDS SECONDS MINUTES HOURS DAYS	Time unit for the Response Wait Time field.	MILLISECONDS
Name	String	The identifier of this element used to reference it in other components.		x
Expiration Policy	Expiration Policy	Configures the minimum amount of time that a dynamic configuration instance can remain idle before Mule considers it eligible for expiration. This doesn’t mean that the platform expires the instance at the exact moment that it becomes eligible. Mule purges the instances as appropriate.

#### Connection Types ##### Google Service Account Auth Provider Use when the gRPC server expects Google-style service account auth (such as Google Cloud). ###### Parameters

Name	Type	Description	Default Value	Required
Host	String	The host address of the gRPC server.		x
Port	Number	The port number of the gRPC server.	443
IDL Definition	One of: Single Binary Protobuf	The Interface Definition Language (IDL) definition for the gRPC service.		x
Request headers	Object	Request headers to include in gRPC requests.
Connection Timeout	Number	The timeout for establishing connections to the remote service.	30
Connection Timeout Unit	Enumeration, one of: NANOSECONDS MICROSECONDS MILLISECONDS SECONDS MINUTES HOURS DAYS	Time unit for the Connection Timeout field.	SECONDS
Connection Mode	One of: PlainText TLS	Connection mode: TLS (default, for production) or PlainText (for development). If not specified, TLS with default settings is used automatically.		x
Private key id	String	Identifier of the private key for the service account. Part of service credentials.		x
Client id	String	Identifier of the client. Part of service credentials.		x
Client email	String	Client email for the service account. Part of service credentials.		x
Private key	One of: Private Key Text Private Key File	Private key for the service account. Part of service credentials. Can be provided as text or from a file.		x
Reconnection	Reconnection	When the application is deployed, a connectivity test is performed on all connectors. If set to true, deployment fails if the test doesn’t pass after exhausting the associated reconnection strategy.

##### No Auth Use when the gRPC server does not require authentication (such as local or internal services). ###### Parameters

Name	Type	Description	Default Value	Required
Host	String	The host address of the gRPC server.		x
Port	Number	The port number of the gRPC server.	443
IDL Definition	One of: Single Binary Protobuf	The Interface Definition Language (IDL) definition for the gRPC service.		x
Request headers	Object	Custom headers to include in gRPC requests.
Connection Timeout	Number	The timeout for establishing connections to the remote service.	30
Connection Timeout Unit	Enumeration, one of: NANOSECONDS MICROSECONDS MILLISECONDS SECONDS MINUTES HOURS DAYS	Time unit for the Connection Timeout field.	SECONDS
Connection Mode	One of: PlainText TLS	Connection mode: TLS (default, for production) or PlainText (for development). If not specified, TLS with default settings is used automatically.		x
Reconnection	Reconnection	When the application is deployed, a connectivity test is performed on all connectors. If set to true, deployment fails if the test doesn’t pass after exhausting the associated reconnection strategy.

##### Oauth Client Credentials Use OAuth 2.0 to delegate user authentication to the service hosting the user account. For more information, refer to [Configuring OAuth 2.0 for Connectors](https://docs.mulesoft.com/connectors/introduction/intro-config-oauth2), [Configuring OAuth 2.0 for Connectors on CloudHub](https://docs.mulesoft.com/connectors/introduction/intro-config-oauth2-cloudhub), or [OAuth Support in the SDK](https://docs.mulesoft.com/mule-sdk/latest/oauth). Use when the gRPC server expects OAuth 2.0 client credentials. The connector obtains a token and sends it in the authorization header. ###### Parameters

Name	Type	Description	Default Value	Required
Host	String	The host address of the gRPC server.		x
Port	Number	The port number of the gRPC server.	443
IDL Definition	One of: Single Binary Protobuf	The Interface Definition Language (IDL) definition for the gRPC service.		x
Request headers	Object	Custom headers to include in gRPC requests.
Connection Timeout	Number	The timeout for establishing connections to the remote service.	30
Connection Timeout Unit	Enumeration, one of: NANOSECONDS MICROSECONDS MILLISECONDS SECONDS MINUTES HOURS DAYS	Time unit for the Connection Timeout field.	SECONDS
Connection Mode	One of: PlainText TLS	Connection mode: TLS (default, for production) or PlainText (for development). If not specified, TLS with default settings is used automatically.		x
Authorization Key	String	The header key used for authorization.	Authorization
Reconnection	Reconnection	When the application is deployed, a connectivity test is performed on all connectors. If set to true, deployment fails if the test doesn’t pass after exhausting the associated reconnection strategy.
Client Id	String	The OAuth client ID as registered with the service provider.		x
Client Secret	String	The OAuth client secret as registered with the service provider.		x
Token Url	String	The service provider’s token endpoint URL.	`https://example.com/oauth2/token`
Scopes	String	The OAuth scopes to be requested during the dance. If not provided, it defaults to those in the annotation.
Auth Server Tls Context	TLS	References a TLS config to use to do HTTP request during the OAuth dance.
Auth Server Proxy Config	Any	References the proxy configuration which through the HTTP request during the OAuth dance.
Object Store	String	A reference to the object store that should be used to store each resource owner id’s data. If not specified, runtime will automatically provision the default one.

## Supported Operations - [\[Client\] Bidirectional Stream Message](#BidirectionalStreaming) - [\[Client\] Client Streaming Call](#ClientStreaming) - [\[Client\] Server Stream Message](#ServerStreamingCallWithDelegation) - [\[Client\] Iterate Server Stream Message](#ServerStreamingCallWithResponse) - [\[Client\] Unary Message](#UnaryCall) - [Unauthorize](#Unauthorize) ## Associated Sources - [\[Client\] Bidirectional Stream Listener](#BidiStreamingListener) - [\[Client\] Server Stream Listener](#ServerStreamingDelegatedListener) - [\[Client\] Server Stream Subscriber](#ServerStreamingSubscriberSource) --- ### GRPC Server Configuration Server configuration for exposing gRPC methods. #### Parameters

Name	Type	Description	Default Value	Required
Name	String	The name for this configuration. Connectors reference the configuration with this name.		x
Connection	Grpc Server	The connection to provide to this configuration.		x
Max Inbound Message Size	Number	Maximum size of an inbound message in bytes (default: 4MB, same as gRPC-Java). Must be a positive value.	4194304
Name	String	The identifier of this element used to reference it in other components.		x

#### Connection Types ##### Grpc Server Reference an `` for the gRPC endpoint and provide the protobuf descriptor for your service. ###### Parameters

Name	Type	Description	Required
Listener Config	String	Reference to the `<http:listener-config>` used to expose the gRPC server endpoint.	x
IDL Definition	One of: Single Binary Protobuf	Protobuf descriptor definition for the gRPC service.	x
Reconnection	Reconnection	When the application is deployed, a connectivity test is performed on all connectors. If set to true, deployment fails if the test doesn’t pass after exhausting the associated reconnection strategy.

## Supported Operations - [\[Server\] End Stream](#EndStream) - [\[Server\] Respond Server Stream Message](#SendStreamMessage) ## Associated Sources - [\[Server\] Bidirectional Streaming Listener](#BidirectionalStreamingMethod) - [\[Server\] Client Stream Listener](#ClientStreamingMethod) - [\[Server\] Server Stream Listener](#ServerStreamingMethod) - [\[Server\] Unary Listener](#UnaryMethod) ## Operations ## \[Client\] Bidirectional Stream Message `` Connect to a Bidirectional Streaming RPC. This operation initiates a request, and its responses are collected by the corresponding [\[Client\] Bidirectional Stream Listener](#BidiStreamingListener). [\[Client\] Bidirectional Stream Message](#BidirectionalStreaming) and [\[Client\] Bidirectional Stream Listener](#BidiStreamingListener) are mapped to each other via **Routing ID**. This operation can be used to initiate the client up-stream, send requests, and also close the client up-stream. Each of these client steps can be mapped using a common request ID. ### Parameters

Name	Type	Description	Default Value	Required
Configuration	String	The name of the configuration to use.		x
Method	String	The gRPC method name to invoke.		x
Routing Id	String	Identifier to map this call with its corresponding listener.
Request Id	String	Identifier to map related client streaming steps.
Content	Binary	The request payload to send to the gRPC server.
End Streaming	Boolean	Indicates whether to close the client streaming.	false
Request Headers	Object	Custom headers to include in the gRPC request.
Deadline	Deadline	Configures the deadline for this specific gRPC call. Overrides the configuration-level deadline if specified.
Config Ref	ConfigurationProvider	The name of the configuration to use to execute this component.		x
Target Variable	String	Name of the variable that stores operation’s output.
Target Value	String	An expression to evaluate against the operation’s output and store the expression outcome in the target variable.	#[payload]
Error Mappings	Array of Error Mapping	Set of error mappings.
Reconnection Strategy	Reconnect Reconnect Forever	A retry strategy in case of connectivity errors.

### Output

Type

String

### For Configurations - [Client](#Client) ### Throws - GRPC:ABORTED - GRPC:ALREADY\_EXISTS - GRPC:CANCELLED - GRPC:CONNECTIVITY - GRPC:DATA\_LOSS - GRPC:DEADLINE\_EXCEEDED - GRPC:FAILED\_PRECONDITION - GRPC:GRPC\_UNKNOWN - GRPC:INTERNAL - GRPC:INVALID\_ARGUMENT - GRPC:NOT\_FOUND - GRPC:OUT\_OF\_RANGE - GRPC:PERMISSION\_DENIED - GRPC:RESOURCE\_EXHAUSTED - GRPC:RETRY\_EXHAUSTED - GRPC:TRANSFORMATION - GRPC:UNAUTHENTICATED - GRPC:UNAVAILABLE - GRPC:UNIMPLEMENTED - GRPC:VALIDATION ## \[Client\] Client Streaming Call `` Connect to a Client Streaming RPC. This single operation can be used to initiate streaming, send requests, and close the client streaming request. Each of these steps is correlated via a common request ID. ### Parameters

Name	Type	Description	Default Value	Required
Configuration	String	The name of the configuration to use.		x
Method	String	The gRPC method name to invoke.		x
Request Id	String	Identifier to map related client streaming steps.
Content	Binary	The request payload to send to the gRPC server.
End Streaming	Boolean	Indicates whether to close the client streaming.	false
Request Headers	Object	Custom headers to include in the gRPC request.
Deadline	Deadline	Configures the deadline for this specific gRPC call. Overrides the configuration-level deadline if specified.
Response Wait Time	Number	Time to wait for server response after sending each message. Overrides the configuration-level value if specified.
Response Wait Time Unit	Enumeration, one of: NANOSECONDS MICROSECONDS MILLISECONDS SECONDS MINUTES HOURS DAYS	Time unit for the Response Wait Time field.
Config Ref	ConfigurationProvider	The name of the configuration to use to execute this component.		x
Streaming Strategy	Repeatable In Memory Stream Repeatable File Store Stream non-repeatable-stream	Configures how Mule processes streams. Repeatable streams are the default behavior.
Target Variable	String	Name of the variable that stores operation’s output.
Target Value	String	An expression to evaluate against the operation’s output and store the expression outcome in the target variable.	#[payload]
Error Mappings	Array of Error Mapping	Set of error mappings.
Reconnection Strategy	Reconnect Reconnect Forever	A retry strategy in case of connectivity errors.

### Output

Type	Binary
Attributes Type	Client Streaming Attributes

### For Configurations - [Client](#Client) ### Throws - GRPC:ABORTED - GRPC:ALREADY\_EXISTS - GRPC:CANCELLED - GRPC:CONNECTIVITY - GRPC:DATA\_LOSS - GRPC:DEADLINE\_EXCEEDED - GRPC:FAILED\_PRECONDITION - GRPC:GRPC\_UNKNOWN - GRPC:INTERNAL - GRPC:INVALID\_ARGUMENT - GRPC:NOT\_FOUND - GRPC:OUT\_OF\_RANGE - GRPC:PERMISSION\_DENIED - GRPC:RESOURCE\_EXHAUSTED - GRPC:RETRY\_EXHAUSTED - GRPC:TRANSFORMATION - GRPC:UNAUTHENTICATED - GRPC:UNAVAILABLE - GRPC:UNIMPLEMENTED - GRPC:VALIDATION ## \[Client\] Server Stream Message `` Connect to a Server Streaming RPC. This operation initiates a request, and its responses are collected by the corresponding Server Streaming Delegated Listener. The Server Streaming Delegator and Server Streaming Delegated Listener are mapped to each other via the routing ID. ### Parameters

Name	Type	Description	Default Value	Required
Configuration	String	The name of the configuration to use.		x
Method	String	The gRPC method name to invoke.		x
Routing Id	String	Identifier to map this call with its corresponding listener.		x
Content	Binary	The request payload to send to the gRPC server.	#[payload]
Request Headers	Object	Custom headers to include in the gRPC request.
Deadline	Deadline	Configures the deadline for this specific gRPC call. Overrides the configuration-level deadline if specified.
Config Ref	ConfigurationProvider	The name of the configuration to use to execute this component.		x
Target Variable	String	Name of the variable that stores operation’s output.
Target Value	String	An expression to evaluate against the operation’s output and store the expression outcome in the target variable.	#[payload]
Error Mappings	Array of Error Mapping	Set of error mappings.
Reconnection Strategy	Reconnect Reconnect Forever	A retry strategy in case of connectivity errors.

### Output

Type

String

### For Configurations - [Client](#Client) ### Throws - GRPC:ABORTED - GRPC:ALREADY\_EXISTS - GRPC:CANCELLED - GRPC:CONNECTIVITY - GRPC:DATA\_LOSS - GRPC:DEADLINE\_EXCEEDED - GRPC:FAILED\_PRECONDITION - GRPC:GRPC\_UNKNOWN - GRPC:INTERNAL - GRPC:INVALID\_ARGUMENT - GRPC:NOT\_FOUND - GRPC:OUT\_OF\_RANGE - GRPC:PERMISSION\_DENIED - GRPC:RESOURCE\_EXHAUSTED - GRPC:RETRY\_EXHAUSTED - GRPC:TRANSFORMATION - GRPC:UNAUTHENTICATED - GRPC:UNAVAILABLE - GRPC:UNIMPLEMENTED - GRPC:VALIDATION ## \[Client\] Iterate Server Stream Message `` Connect to a Server Streaming RPC. This operation returns a StreamedResponseIterable to iterate over server response-stream. ### Parameters

Name	Type	Description	Default Value	Required
Configuration	String	The name of the configuration to use.		x
Method	String	The gRPC method name to invoke.		x
Content	Binary	The request payload to send to the gRPC server.	#[payload]
Request Headers	Object	Custom headers to include in the gRPC request.
Deadline	Deadline	Configures the deadline for this specific gRPC call. Overrides the configuration-level deadline if specified.
Poll Timeout (milliseconds)	Number	The timeout, in milliseconds, when polling for the next streamed response element.	500
Output Mime Type	String	The mime type of the payload that this operation outputs.
Output Encoding	String	The encoding of the payload that this operation outputs.
Config Ref	ConfigurationProvider	The name of the configuration to use to execute this component.		x
Target Variable	String	Name of the variable that stores operation’s output.
Target Value	String	An expression to evaluate against the operation’s output and store the expression outcome in the target variable.	#[payload]
Error Mappings	Array of Error Mapping	Set of error mappings.
Reconnection Strategy	Reconnect Reconnect Forever	A retry strategy in case of connectivity errors.

### Output

Type	Array of Binary

### For Configurations - [Client](#Client) ### Throws - GRPC:ABORTED - GRPC:ALREADY\_EXISTS - GRPC:CANCELLED - GRPC:CONNECTIVITY - GRPC:DATA\_LOSS - GRPC:DEADLINE\_EXCEEDED - GRPC:FAILED\_PRECONDITION - GRPC:GRPC\_UNKNOWN - GRPC:INTERNAL - GRPC:INVALID\_ARGUMENT - GRPC:NOT\_FOUND - GRPC:OUT\_OF\_RANGE - GRPC:PERMISSION\_DENIED - GRPC:RESOURCE\_EXHAUSTED - GRPC:RETRY\_EXHAUSTED - GRPC:TRANSFORMATION - GRPC:UNAUTHENTICATED - GRPC:UNAVAILABLE - GRPC:UNIMPLEMENTED - GRPC:VALIDATION ## \[Client\] Unary Message `` Invokes a standard gRPC method that accepts a single request and returns a single response. Use this operation to perform an individual, one-off gRPC call to a remote service method. ### Parameters

Name	Type	Description	Default Value	Required
Configuration	String	The name of the configuration to use.		x
Method	String	A String object.		x
Content	Binary	An InputStream object.	#[payload]
Request Headers	Object	Custom headers to include in the gRPC request.
Deadline	Deadline	Configures the deadline for this specific gRPC call. Overrides the configuration-level deadline if specified.
Config Ref	ConfigurationProvider	The name of the configuration to use to execute this component.		x
Streaming Strategy	Repeatable In Memory Stream Repeatable File Store Stream non-repeatable-stream	Configures how Mule processes streams. Repeatable streams are the default behavior.
Target Variable	String	Name of the variable that stores operation’s output.
Target Value	String	An expression to evaluate against the operation’s output and store the expression outcome in the target variable.	#[payload]
Error Mappings	Array of Error Mapping	Set of error mappings.
Reconnection Strategy	Reconnect Reconnect Forever	A retry strategy in case of connectivity errors.

### Output

Type

Binary

### For Configurations - [Client](#Client) ### Throws - GRPC:ALREADY\_EXISTS - GRPC:CONNECTIVITY - GRPC:DATA\_LOSS - GRPC:DEADLINE\_EXCEEDED - GRPC:FAILED\_PRECONDITION - GRPC:GRPC\_UNKNOWN - GRPC:INTERNAL - GRPC:INVALID\_ARGUMENT - GRPC:NOT\_FOUND - GRPC:OUT\_OF\_RANGE - GRPC:PERMISSION\_DENIED - GRPC:RESOURCE\_EXHAUSTED - GRPC:RETRY\_EXHAUSTED - GRPC:TRANSFORMATION - GRPC:UNAUTHENTICATED - GRPC:UNAVAILABLE - GRPC:UNIMPLEMENTED - GRPC:VALIDATION ## Unauthorize `` Deletes all the access token information of a given resource owner ID so that it’s impossible to execute any operation for that user without doing the authorization dance again. ### Parameters

Name	Type	Description	Default Value	Required
Configuration	String	The name of the configuration to use.		x
Config Ref	ConfigurationProvider	The name of the configuration to use to execute this component.		x

### For Configurations - [Client](#Client) ## \[Server\] End Stream `` Ends the streaming response. ### Parameters

Name	Type	Description	Required
Configuration	String	The name of the configuration to use.	x
Attributes	Server Streaming Server Attributes	Streaming attributes from the server streaming source.	x
Config Ref	ConfigurationProvider	The name of the configuration to use to execute this component.	x
Error Mappings	Array of Error Mapping	Set of error mappings.

### For Configurations - [GRPC Server Configuration](#Server) ## \[Server\] Respond Server Stream Message `` Sends a message in a streaming response. ### Parameters

Name	Type	Description	Default Value	Required
Configuration	String	The name of the configuration to use.		x
Attributes	Server Streaming Server Attributes	Streaming attributes from the server streaming source.		x
Stream Message	Any	The message content to send to the client.	#[payload]
Config Ref	ConfigurationProvider	The name of the configuration to use to execute this component.		x
Error Mappings	Array of Error Mapping	Set of error mappings.

### For Configurations - [GRPC Server Configuration](#Server) ## Sources ## \[Client\] Bidirectional Stream Listener `` Connects to a Bidirectional Streaming RPC. Server responses from the corresponding [\[Client\] Bidirectional Stream Message](#BidirectionalStreaming) are collected here. [\[Client\] Bidirectional Stream Message](#BidirectionalStreaming) and [\[Client\] Bidirectional Stream Listener](#BidiStreamingListener) are mapped to each other via **Routing ID**. ### Parameters

Name	Type	Description	Required
Configuration	String	The name of the configuration to use.	x
Routing ID	String	Identifier to map this listener with its corresponding call.	x
Primary Node Only	Boolean	Whether this source should only be executed on the primary node when running in a cluster.
Config Ref	ConfigurationProvider	The name of the configuration to use to execute this component.	x
Streaming Strategy	Repeatable In Memory Stream Repeatable File Store Stream non-repeatable-stream	Configures how Mule processes streams. Repeatable streams are the default behavior.
Redelivery Policy	Redelivery Policy	Defines a policy for processing the redelivery of the same message.
Reconnection Strategy	Reconnect Reconnect Forever	A retry strategy in case of connectivity errors.

### Output

Type	Binary
Attributes Type	Server Streaming Attributes

### For Configurations - [Client](#Client) ## \[Client\] Server Stream Listener `` Connects to a Server Streaming RPC. Server responses from the corresponding Server Streaming Delegator are collected here. The Server Streaming Delegator and Server Streaming Delegated Listener are mapped to each other via the routing ID. ### Parameters

Name	Type	Description	Required
Configuration	String	The name of the configuration to use.	x
Routing ID	String	Identifier to map this listener with its corresponding delegator.	x
Primary Node Only	Boolean	Whether this source should only be executed on the primary node when running in a cluster.
Config Ref	ConfigurationProvider	The name of the configuration to use to execute this component.	x
Streaming Strategy	Repeatable In Memory Stream Repeatable File Store Stream non-repeatable-stream	Configures how Mule processes streams. Repeatable streams are the default behavior.
Redelivery Policy	Redelivery Policy	Defines a policy for processing the redelivery of the same message.
Reconnection Strategy	Reconnect Reconnect Forever	A retry strategy in case of connectivity errors.

### Output

Type	Binary
Attributes Type	Server Streaming Attributes

### For Configurations - [Client](#Client) ## \[Client\] Server Stream Subscriber `` Connect to a Server Streaming RPC. This source acts as a subscriber by sending the request when it starts. The request is provided at design time through the payload attribute. ### Parameters

Name	Type	Description	Required
Configuration	String	The name of the configuration to use.	x
Method	String	The gRPC method name to invoke.	x
Request Headers	Object	Custom headers to include in the gRPC request.
Deadline	Deadline	Configures the deadline for this specific gRPC call. Overrides the configuration-level deadline if specified.
Primary Node Only	Boolean	Whether this source should only be executed on the primary node when running in a cluster.
Config Ref	ConfigurationProvider	The name of the configuration to use to execute this component.	x
Streaming Strategy	Repeatable In Memory Stream Repeatable File Store Stream non-repeatable-stream	Configures how Mule processes streams. Repeatable streams are the default behavior.
Redelivery Policy	Redelivery Policy	Defines a policy for processing the redelivery of the same message.
File Path	String	The path to the file containing the request payload.	x
Reconnection Strategy	Reconnect Reconnect Forever	A retry strategy in case of connectivity errors.

### Output

Type

Binary

### For Configurations - [Client](#Client) ## \[Server\] Bidirectional Streaming Listener `` This source handles multiple client requests and produces multiple server responses. In bidirectional streaming: - The client sends multiple messages (independently). - The server sends multiple responses (independently). - Both streams operate independently and can send or receive messages at any time. Flow Execution Model: - The flow executes once per client message (automatic iteration; execution might be in parallel for different messages). - A shared `streamState` map (`Map`) persists across all flow executions for the same stream. - Each flow execution returns a response as the payload and can update state via ``. - When the client completes sending messages, the flow is executed one last time with `clientStreamCompleted=true`. Example Use Cases: - Interactive Processing (such as market ticker subscriptions) - Client sends subscription requests. - Server responds with price updates as they change. - Client-controlled Streaming (such as paginated data export) - Client sends flow control tokens. - Server sends data chunks on demand. Example usage in a Mule flow: ```xml

``` ### Parameters

Name	Type	Description	Required
Configuration	String	The name of the configuration to use.	x
Method Name	String	The fully qualified gRPC method name to listen on (for example, `market.Market/SubscribeTickers`).	x
Output Mime Type	String	The mime type of the payload that this source outputs.
Output Encoding	String	The encoding of the payload that this source outputs.
Primary Node Only	Boolean	Whether this source should only be executed on the primary node when running in a cluster.
Config Ref	ConfigurationProvider	The name of the configuration to use to execute this component.	x
Streaming Strategy	Repeatable In Memory Stream Repeatable File Store Stream non-repeatable-stream	Configures how Mule processes streams. Repeatable streams are the default behavior.
Redelivery Policy	Redelivery Policy	Defines a policy for processing the redelivery of the same message.
Reconnection Strategy	Reconnect Reconnect Forever	A retry strategy in case of connectivity errors.
Stream Output	Bidi Streaming Output	Output parameter group for bidirectional streaming responses.
Status Code	String	The gRPC status the client should receive. Preferably the code name (for example, `NOT_FOUND`), which is self-documenting and validated against `io.grpc.Status.Code`. The numeric value (for example, `5`) is also accepted. When unset, unrecognized, or `OK`, the original error cause is propagated and the client receives `UNKNOWN`.
Description	String	The gRPC status description (message) the client should receive. When unset, the error’s own description is used.

### Output

Type	Any
Attributes Type	Bidi Streaming Server Attributes

### For Configurations - [GRPC Server Configuration](#Server) ## \[Server\] Client Stream Listener `` This source handles multiple client requests and produces a single response. In client streaming, the client sends a stream of requests and the server responds with a single response after processing all the requests. ### Parameters

Name	Type	Description	Required
Configuration	String	The name of the configuration to use.	x
Method Name	String	The fully qualified gRPC method name to listen on (for example, `retail.Retail/StreamItems`).	x
Output Mime Type	String	The mime type of the payload that this source outputs.
Output Encoding	String	The encoding of the payload that this source outputs.
Primary Node Only	Boolean	Whether this source should only be executed on the primary node when running in a cluster.
Config Ref	ConfigurationProvider	The name of the configuration to use to execute this component.	x
Streaming Strategy	Repeatable In Memory Stream Repeatable File Store Stream non-repeatable-stream	Configures how Mule processes streams. Repeatable streams are the default behavior.
Redelivery Policy	Redelivery Policy	Defines a policy for processing the redelivery of the same message.
Reconnection Strategy	Reconnect Reconnect Forever	A retry strategy in case of connectivity errors.
Output	Client Streaming Output	Output structure for client streaming methods.
Status Code	String	The gRPC status the client should receive. Preferably the code name (for example, `NOT_FOUND`), which is self-documenting and validated against `io.grpc.Status.Code`. The numeric value (for example, `5`) is also accepted. When unset, unrecognized, or `OK`, the original error cause is propagated and the client receives `UNKNOWN`.
Description	String	The gRPC status description (message) the client should receive. When unset, the error’s own description is used.

### Output

Type	Any
Attributes Type	Client Streaming Server Attributes

### For Configurations - [GRPC Server Configuration](#Server) ## \[Server\] Server Stream Listener `` This source handles a single client request and produces multiple responses. ### Parameters

Name	Type	Description	Default Value	Required
Configuration	String	The name of the configuration to use.		x
Method Name	String	The fully qualified gRPC method name to listen on (for example, `retail.Retail/PriceItemStream`).		x
Output Mime Type	String	The mime type of the payload that this source outputs.
Output Encoding	String	The encoding of the payload that this source outputs.
On Capacity Overload	Enumeration, one of: WAIT DROP	Strategy applied when the flow receives more messages than it has capacity to handle.	WAIT
Primary Node Only	Boolean	Whether this source should only be executed on the primary node when running in a cluster.
Config Ref	ConfigurationProvider	The name of the configuration to use to execute this component.		x
Streaming Strategy	Repeatable In Memory Stream Repeatable File Store Stream non-repeatable-stream	Configures how Mule processes streams. Repeatable streams are the default behavior.
Redelivery Policy	Redelivery Policy	Defines a policy for processing the redelivery of the same message.
Reconnection Strategy	Reconnect Reconnect Forever	A retry strategy in case of connectivity errors.
Status Code	String	The gRPC status the client should receive. Preferably the code name (for example, `NOT_FOUND`), which is self-documenting and validated against `io.grpc.Status.Code`. The numeric value (for example, `5`) is also accepted. When unset, unrecognized, or `OK`, the original error cause is propagated and the client receives `UNKNOWN`.
Description	String	The gRPC status description (message) the client should receive. When unset, the error’s own description is used.

### Output

Type	Any
Attributes Type	Server Streaming Server Attributes

### For Configurations - [GRPC Server Configuration](#Server) ## \[Server\] Unary Listener `` This source handles a single client request and produces a single response. ### Parameters

Name	Type	Description	Default Value	Required
Configuration	String	The name of the configuration to use.		x
Method Name	String	The fully qualified gRPC method name to listen on (for example, `retail.Retail/GetItem`).		x
Output Mime Type	String	The mime type of the payload that this source outputs.
Output Encoding	String	The encoding of the payload that this source outputs.
Primary Node Only	Boolean	Whether this source should only be executed on the primary node when running in a cluster.
Config Ref	ConfigurationProvider	The name of the configuration to use to execute this component.		x
Streaming Strategy	Repeatable In Memory Stream Repeatable File Store Stream non-repeatable-stream	Configures how Mule processes streams. Repeatable streams are the default behavior.
Redelivery Policy	Redelivery Policy	Defines a policy for processing the redelivery of the same message.
Reconnection Strategy	Reconnect Reconnect Forever	A retry strategy in case of connectivity errors.
Response Unary	Binary	The response content to send to the client.	#[payload]
Status Code	String	The gRPC status the client should receive. Preferably the code name (for example, `NOT_FOUND`), which is self-documenting and validated against `io.grpc.Status.Code`. The numeric value (for example, `5`) is also accepted. When unset, unrecognized, or `OK`, the original error cause is propagated and the client receives `UNKNOWN`.
Description	String	The gRPC status description (message) the client should receive. When unset, the error’s own description is used.

### Output

Type	Any
Attributes Type	Unary Server Attributes

### For Configurations - [GRPC Server Configuration](#Server) ## Types ### Reconnection Configures a reconnection strategy for an operation.

Field	Type	Description	Default Value	Required
Fails Deployment	Boolean	When the application is deployed, a connectivity test is performed on all connectors. If set to true, deployment fails if the test doesn’t pass after exhausting the associated reconnection strategy.
Reconnection Strategy	Reconnect Reconnect Forever	The reconnection strategy to use.

### Reconnect Configures a standard reconnection strategy, which specifies how often to reconnect and how many reconnection attempts the connector source or operation can make.

Field	Type	Description
Frequency	Number	How often in milliseconds to reconnect.
Blocking	Boolean	If false, the reconnection strategy will run in a separate, non-blocking thread.
Count	Number	How many reconnection attempts to make.

### Reconnect Forever Configures a forever reconnection strategy by which the connector source or operation attempts to reconnect at a specified frequency for as long as the Mule app runs.

Field	Type	Description	Default Value	Required
Frequency	Number	How often in milliseconds to reconnect.
Blocking	Boolean	If false, the reconnection strategy will run in a separate, non-blocking thread.

### TLS Configures TLS to provide secure communications for the Mule app.

Field	Type	Description
Enabled Protocols	String	A comma-separated list of protocols enabled for this context.
Enabled Cipher Suites	String	A comma-separated list of cipher suites enabled for this context.
Trust Store	Trust Store	Configuration for the trust store.
Key Store	Key Store	Configuration for the key store.
Revocation Check	Standard Revocation Check Custom OCSP Responder CRL File	Configuration for certificate revocation checking.

### Trust Store Configures the truststore for TLS.

Field	Type	Description
Path	String	The location (which will be resolved relative to the current classpath and file system, if possible) of the trust store.
Password	String	The password used to protect the trust store.
Type	String	The type of store used.
Algorithm	String	The algorithm used by the trust store.
Insecure	Boolean	If `true`, Mule stops performing certificate validations. Setting this to `true` can make connections vulnerable to attacks.

### Key Store Configures the keystore for the TLS protocol. The keystore you generate contains a private key and a public certificate.

Field	Type	Description
Path	String	The location (which will be resolved relative to the current classpath and file system, if possible) of the key store.
Type	String	The type of store used.
Alias	String	When the key store contains many private keys, this attribute indicates the alias of the key that should be used. If not defined, the first key in the file will be used by default.
Key Password	String	The password used to protect the private key.
Password	String	The password used to protect the key store.
Algorithm	String	The algorithm used by the key store.

### Standard Revocation Check Configures standard revocation checks for TLS certificates.

Field	Type	Description
Only End Entities	Boolean	Only verify the last element of the certificate chain.
Prefer Crls	Boolean	Try CRL instead of OCSP first.
No Fallback	Boolean	Do not use the secondary checking method (the one not selected before).
Soft Fail	Boolean	Avoid verification failure when the revocation server can not be reached or is busy.

### Custom OCSP Responder Configures a custom OCSP responder for certification revocation checks.

Field	Type	Description	Default Value	Required
Url	String	The URL of the OCSP responder.
Cert Alias	String	Alias of the signing certificate for the OCSP response (must be in the trust store), if present.

### CRL File Specifies the location of the certification revocation list (CRL) file.

Field	Type	Description	Default Value	Required
Path	String	The path to the CRL file.

### Deadline Configures the deadline for gRPC calls. A deadline specifies the maximum duration for a gRPC operation to complete. If the operation exceeds this deadline, it is automatically cancelled.

Field	Type	Description	Default Value	Required
Duration	Number	The duration value for the deadline.	10
Units	Enumeration, one of: NANOSECONDS MICROSECONDS MILLISECONDS SECONDS MINUTES HOURS DAYS	The time unit for the Duration field.	SECONDS

### Expiration Policy Configures the maximum amount of time that a dynamic configuration instance can remain idle before Mule considers it eligible for expiration.

Field	Type	Description	Default Value	Required
Max Idle Time	Number	A scalar time value for the maximum amount of time a dynamic configuration instance should be allowed to be idle before it’s considered eligible for expiration.
Time Unit	Enumeration, one of: NANOSECONDS MICROSECONDS MILLISECONDS SECONDS MINUTES HOURS DAYS	A time unit for the Max Idle Time field.

### Server Streaming Attributes Represents attributes or metadata for streaming operations. This class provides channel and routing information for gRPC streaming calls.

Field	Type	Description
End Of Stream	Boolean	Indicates whether the stream has ended.
Error	Boolean	Indicates whether an error occurred during streaming.
Error Message	String	The error message if an error occurred.
Request Id	String	The request identifier.
Routing Id	String	The routing identifier.

### Repeatable In Memory Stream Configures the in-memory streaming strategy by which the request fails if the data exceeds the MAX buffer size. Always run performance tests to find the optimal buffer size for your specific use case.

Field	Type	Description
Initial Buffer Size	Number	The amount of memory that will be allocated to consume the stream and provide random access to it. If the stream contains more data than can be fit into this buffer, then the buffer expands according to the bufferSizeIncrement attribute, with an upper limit of maxInMemorySize.
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 STREAM_MAXIMUM_SIZE_EXCEEDED error is raised when the buffer gets full.
Max Buffer Size	Number	The maximum amount of memory to use. If more than that is used then a STREAM_MAXIMUM_SIZE_EXCEEDED error is raised. A value lower than or equal to zero means no limit.
Buffer Unit	Enumeration, one of: BYTE KB MB GB	The unit in which all these attributes are expressed.

### Repeatable File Store Stream Configures the repeatable file-store streaming strategy by which Mule keeps a portion of the stream content in memory. If the stream content is larger than the configured buffer size, Mule backs up the buffer’s content to disk and then clears the memory.

Field	Type	Description	Default Value	Required
In Memory Size	Number	Defines the maximum memory that the stream should use to keep data in memory. If more than that is consumed content on the disk is buffered.
Buffer Unit	Enumeration, one of: BYTE KB MB GB	The unit in which In Memory Size is expressed.

### Redelivery Policy Configures the redelivery policy for executing requests that generate errors. You can add a redelivery policy to any source in a flow.

Field	Type	Description
Max Redelivery Count	Number	The maximum number of times a message can be redelivered and processed unsuccessfully before triggering process-failed-message.
Message Digest Algorithm	String	The secure hashing algorithm to use. If not set, the default is SHA-256.
Message Identifier	Redelivery Policy Message Identifier	Defines which strategy is used to identify the messages.
Object Store	ObjectStore	The object store where the redelivery counter for each message is stored.

### Redelivery Policy Message Identifier Configures how to identify a redelivered message and how to find out when the message was redelivered.

Field	Type	Description	Default Value	Required
Use Secure Hash	Boolean	Whether to use a secure hash algorithm to identify a redelivered message.
Id Expression	String	Defines one or more expressions to use to determine when a message has been redelivered. This property may only be set if useSecureHash is false.

### Error Mapping Configures the error mapping.

Field	Type	Description	Default Value	Required
Source	Enumeration, one of: ANY REDELIVERY_EXHAUSTED TRANSFORMATION EXPRESSION SECURITY CLIENT_SECURITY SERVER_SECURITY ROUTING CONNECTIVITY RETRY_EXHAUSTED TIMEOUT	The source error type to map.
Target	String	The target error type to map to.		x

### Client Streaming Attributes Represents attributes or metadata for client streaming operations. Returned with every client streaming operation response to indicate the current state of the conversation.

Field	Type	Description
End Of Stream	Boolean	Indicates whether the stream has ended.
Message Sent	Boolean	Indicates whether a message was sent in this step.
Request Id	String	The request identifier.

### Bidi Streaming Server Attributes Attributes for bidirectional streaming gRPC methods. Bidirectional streaming allows both client and server to send multiple messages independently. The client can send multiple requests while the server sends multiple responses. Key characteristics: - Flow executes once per client message (automatic iteration, parallel execution) - Flow can send 0, 1, or N responses per message using [\[Server\] Respond Server Stream Message](#SendStreamMessage). - Shared streamState map persists across all flow executions for state management - Final execution with `clientStreamCompleted=true` when client finishes sending Use cases: - Interactive processing (such as market ticker subscriptions) - Client sends subscription requests. - Server sends price updates as they change. - Client-controlled streaming (such as paginated data export) - Client sends flow control tokens. - Server sends data chunks on demand.

Field	Type	Description
Client Stream Completed	Boolean	Whether the client has finished sending (true on final execution).
Connection Id	String	Unique stream identifier.
Headers	Object	Inbound gRPC request metadata, with keys lowercased (for example, `attributes.headers.authorization`).
Message Count	Number	Total messages received so far.
Message Index	Number	Current message number (1-based).
Method Name	String	Fully qualified gRPC method name.
Stream State	Object	Shared state map across all messages (thread-safe ConcurrentHashMap).
Timestamp	DateTime	When the stream is initiated.

### Bidi Streaming Output Output parameter group for bidirectional streaming responses. This class captures both the response (body) and the updated streaming state from flow execution. The handler uses this to: 1. Send the response as the gRPC reply. 2. Update its local streamState with the returned values for the next message. Example usage in a Mule flow: ```xml

{ count: (attributes.streamState.count default 0) + payload.qty, amount: (attributes.streamState.amount default 0.0) + (payload.qty * payload.price) }

```

Field	Type	Description	Default Value	Required
Response	Binary	The response message to send to the client.	#[payload]
Stream State	Object	Updated streaming state to persist for the next message. Values set here are available in attributes.streamState for subsequent messages.	#[{}]

### Client Streaming Server Attributes Attributes for client streaming gRPC methods. Simplified to match apikit pattern: per-message execution with stream state.

Field	Type	Description
Headers	Object	Inbound gRPC request metadata, with keys lowercased (for example, `attributes.headers.authorization`).
Message Count	Number	Number of messages received so far.
Stream Completed	Boolean	Whether this is the final message in the stream. When true, the flow should return the final response.
Stream State	Object	Shared mutable state across all messages. The flow can read or update this map to maintain aggregated values.

### Client Streaming Output Output structure for client streaming methods, matching apikit pattern.

Field	Type	Description	Default Value	Required
Response	Binary	The response message to send to the client (only used on final execution when client stream completes).	#[payload]
Stream State a	Object	Updated stream state to persist across messages. Values set here are available as `attributes.streamState` in subsequent executions. For `Map<String, Object>` types, Mule SDK automatically generates corresponding XML: `<grpc:stream-states><grpc:stream-state key="…" value="…"/></grpc:stream-states>`	#[{}]

### Server Streaming Server Attributes Server-side attributes for server streaming gRPC methods. In server streaming, the client sends a single request, the Mule flow executes, and the server sends multiple responses using [\[Server\] Respond Server Stream Message](#SendStreamMessage) and [\[Server\] End Stream](#EndStream).

Field	Type	Description
Connection Id	String	Unique identifier for this streaming connection (used to route [Server] Respond Server Stream Message and [Server] End Stream).
Headers	Object	Inbound gRPC request metadata, with keys lowercased (for example, `attributes.headers.authorization`).
Method Name	String	Fully qualified gRPC method name (for example, `retail.Retail/PriceItemStream`).

### Unary Server Attributes Attributes for unary gRPC server sources. Available as `#[attributes]` in DataWeave expressions.

Field	Type	Description
Connection Id	String	Always an empty string for unary calls (no persistent stream).
Headers	Object	Inbound gRPC request metadata, with keys lowercased (for example, `attributes.headers.authorization`).
Method Name	String	Fully qualified gRPC method name (for example, `retail.Retail/GetItem`).

### Single Binary Protobuf Protobuf contract parameterization. Provides unified access to protobuf descriptors and metadata types for both client operations and server sources through the IdlDefinition interface.

Field	Type	Description	Default Value	Required
Protobuf Descriptor File	String	The path to the Protocol Buffer descriptor file.		x

### Private Key Text Private key provided as inline text.

Field	Type	Description	Default Value	Required
Key	String	The private key content.		x

### Private Key File Private key provided from a file.

Field	Type	Description	Default Value	Required
Private Key File Path	String	The path to the file containing the private key.		x