Interface CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder
-
- All Superinterfaces:
org.apache.camel.builder.EndpointConsumerBuilder
,org.apache.camel.EndpointConsumerResolver
- All Known Subinterfaces:
CordaEndpointBuilderFactory.AdvancedCordaEndpointBuilder
- Enclosing interface:
- CordaEndpointBuilderFactory
public static interface CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder extends org.apache.camel.builder.EndpointConsumerBuilder
Advanced builder for endpoint consumers for the Corda component.
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default CordaEndpointBuilderFactory.CordaEndpointConsumerBuilder
basic()
default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder
contractStateClass(Class<Object> contractStateClass)
A contract state (or just state) contains opaque data used by a contract program.default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder
contractStateClass(String contractStateClass)
A contract state (or just state) contains opaque data used by a contract program.default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder
exceptionHandler(String exceptionHandler)
To let the consumer use a custom ExceptionHandler.default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder
exceptionHandler(org.apache.camel.spi.ExceptionHandler exceptionHandler)
To let the consumer use a custom ExceptionHandler.default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder
exchangePattern(String exchangePattern)
Sets the exchange pattern when the consumer creates an exchange.default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder
exchangePattern(org.apache.camel.ExchangePattern exchangePattern)
Sets the exchange pattern when the consumer creates an exchange.default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder
flowLogicArguments(Object[] flowLogicArguments)
Start the given flow with the given arguments, returning an Observable with a single observation of the result of running the flow.default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder
flowLogicArguments(String flowLogicArguments)
Start the given flow with the given arguments, returning an Observable with a single observation of the result of running the flow.default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder
flowLogicClass(Class<Object> flowLogicClass)
Start the given flow with the given arguments, returning an Observable with a single observation of the result of running the flow.default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder
flowLogicClass(String flowLogicClass)
Start the given flow with the given arguments, returning an Observable with a single observation of the result of running the flow.default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder
queryCriteria(Object queryCriteria)
QueryCriteria assumes underlying schema tables are correctly indexed for performance.default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder
queryCriteria(String queryCriteria)
QueryCriteria assumes underlying schema tables are correctly indexed for performance.default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder
synchronous(boolean synchronous)
Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder
synchronous(String synchronous)
Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).
-
-
-
Method Detail
-
basic
default CordaEndpointBuilderFactory.CordaEndpointConsumerBuilder basic()
-
contractStateClass
default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder contractStateClass(Class<Object> contractStateClass)
A contract state (or just state) contains opaque data used by a contract program. It can be thought of as a disk file that the program can use to persist data across transactions. States are immutable: once created they are never updated, instead, any changes must generate a new successor state. States can be updated (consumed) only once: the notary is responsible for ensuring there is no double spending by only signing a transaction if the input states are all free. The option is a:java.lang.Class<net.corda.core.contracts.ContractState>
type. Group: consumer (advanced)
-
contractStateClass
default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder contractStateClass(String contractStateClass)
A contract state (or just state) contains opaque data used by a contract program. It can be thought of as a disk file that the program can use to persist data across transactions. States are immutable: once created they are never updated, instead, any changes must generate a new successor state. States can be updated (consumed) only once: the notary is responsible for ensuring there is no double spending by only signing a transaction if the input states are all free. The option will be converted to ajava.lang.Class<net.corda.core.contracts.ContractState>
type. Group: consumer (advanced)
-
exceptionHandler
default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder exceptionHandler(org.apache.camel.spi.ExceptionHandler exceptionHandler)
To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. The option is a:org.apache.camel.spi.ExceptionHandler
type. Group: consumer (advanced)
-
exceptionHandler
default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder exceptionHandler(String exceptionHandler)
To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. The option will be converted to aorg.apache.camel.spi.ExceptionHandler
type. Group: consumer (advanced)
-
exchangePattern
default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder exchangePattern(org.apache.camel.ExchangePattern exchangePattern)
Sets the exchange pattern when the consumer creates an exchange. The option is a:org.apache.camel.ExchangePattern
type. Group: consumer (advanced)
-
exchangePattern
default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder exchangePattern(String exchangePattern)
Sets the exchange pattern when the consumer creates an exchange. The option will be converted to aorg.apache.camel.ExchangePattern
type. Group: consumer (advanced)
-
flowLogicArguments
default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder flowLogicArguments(Object[] flowLogicArguments)
Start the given flow with the given arguments, returning an Observable with a single observation of the result of running the flow. The flowLogicClass must be annotated with net.corda.core.flows.StartableByRPC. The option is a:java.lang.Object[]
type. Group: consumer (advanced)
-
flowLogicArguments
default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder flowLogicArguments(String flowLogicArguments)
Start the given flow with the given arguments, returning an Observable with a single observation of the result of running the flow. The flowLogicClass must be annotated with net.corda.core.flows.StartableByRPC. The option will be converted to ajava.lang.Object[]
type. Group: consumer (advanced)
-
flowLogicClass
default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder flowLogicClass(Class<Object> flowLogicClass)
Start the given flow with the given arguments, returning an Observable with a single observation of the result of running the flow. The flowLogicClass must be annotated with net.corda.core.flows.StartableByRPC. The option is a:java.lang.Class<net.corda.core.flows.FlowLogic<java.lang.Object>>
type. Group: consumer (advanced)
-
flowLogicClass
default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder flowLogicClass(String flowLogicClass)
Start the given flow with the given arguments, returning an Observable with a single observation of the result of running the flow. The flowLogicClass must be annotated with net.corda.core.flows.StartableByRPC. The option will be converted to ajava.lang.Class<net.corda.core.flows.FlowLogic<java.lang.Object>>
type. Group: consumer (advanced)
-
queryCriteria
default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder queryCriteria(Object queryCriteria)
QueryCriteria assumes underlying schema tables are correctly indexed for performance. The option is a:net.corda.core.node.services.vault.QueryCriteria
type. Group: consumer (advanced)
-
queryCriteria
default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder queryCriteria(String queryCriteria)
QueryCriteria assumes underlying schema tables are correctly indexed for performance. The option will be converted to anet.corda.core.node.services.vault.QueryCriteria
type. Group: consumer (advanced)
-
synchronous
default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder synchronous(boolean synchronous)
Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). The option is a:boolean
type. Default: false Group: advanced
-
synchronous
default CordaEndpointBuilderFactory.AdvancedCordaEndpointConsumerBuilder synchronous(String synchronous)
Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). The option will be converted to aboolean
type. Default: false Group: advanced
-
-