Class KnativeConfiguration
- java.lang.Object
-
- org.apache.camel.component.knative.KnativeConfiguration
-
-
Constructor Summary
Constructors Constructor Description KnativeConfiguration()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addTransportOptions(String key, Object value)
Add a transport option.KnativeConfiguration
copy()
String
getApiVersion()
Map<String,Object>
getCeOverride()
String
getCloudEventsSpecVersion()
String
getCloudEventsType()
KnativeEnvironment
getEnvironment()
Map<String,Object>
getFilters()
String
getKind()
Boolean
getReply()
String
getServiceName()
Map<String,Object>
getTransportOptions()
boolean
isReplyWithCloudEvent()
void
setApiVersion(String apiVersion)
The version of the k8s resource referenced by the endpoint.void
setCeOverride(Map<String,Object> ceOverride)
CloudEvent headers to overridevoid
setCloudEventsSpecVersion(String cloudEventsSpecVersion)
Set the version of the cloudevents spec.void
setCloudEventsType(String cloudEventsType)
Set the event-type information of the produced events.void
setEnvironment(KnativeEnvironment environment)
The environmentvoid
setFilters(Map<String,Object> filters)
Set the filters.void
setKind(String kind)
The type of the k8s resource referenced by the endpoint.void
setReply(Boolean reply)
If the consumer should construct a full reply to knative request.void
setReplyWithCloudEvent(boolean replyWithCloudEvent)
Transforms the reply into a cloud event that will be processed by the caller.void
setServiceName(String serviceName)
The name of the service to lookup from theKnativeEnvironment
.void
setTransportOptions(Map<String,Object> transportOptions)
Set the transport options.
-
-
-
Method Detail
-
getEnvironment
public KnativeEnvironment getEnvironment()
-
setEnvironment
public void setEnvironment(KnativeEnvironment environment)
The environment
-
getServiceName
public String getServiceName()
-
setServiceName
public void setServiceName(String serviceName)
The name of the service to lookup from theKnativeEnvironment
.
-
isReplyWithCloudEvent
public boolean isReplyWithCloudEvent()
-
setReplyWithCloudEvent
public void setReplyWithCloudEvent(boolean replyWithCloudEvent)
Transforms the reply into a cloud event that will be processed by the caller. When listening to events from a Knative Broker, if this flag is enabled, replies will be published to the same Broker where the request comes from (beware that if you don't change the "type" of the received message, you may create a loop and receive your same reply). When this flag is disabled, CloudEvent headers are removed from the reply.
-
getCloudEventsSpecVersion
public String getCloudEventsSpecVersion()
-
setCloudEventsSpecVersion
public void setCloudEventsSpecVersion(String cloudEventsSpecVersion)
Set the version of the cloudevents spec.
-
getCloudEventsType
public String getCloudEventsType()
-
setCloudEventsType
public void setCloudEventsType(String cloudEventsType)
Set the event-type information of the produced events.
-
setTransportOptions
public void setTransportOptions(Map<String,Object> transportOptions)
Set the transport options.
-
addTransportOptions
public void addTransportOptions(String key, Object value)
Add a transport option.
-
setCeOverride
public void setCeOverride(Map<String,Object> ceOverride)
CloudEvent headers to override
-
getApiVersion
public String getApiVersion()
-
setApiVersion
public void setApiVersion(String apiVersion)
The version of the k8s resource referenced by the endpoint.
-
getKind
public String getKind()
-
setKind
public void setKind(String kind)
The type of the k8s resource referenced by the endpoint.
-
getReply
public Boolean getReply()
-
setReply
public void setReply(Boolean reply)
If the consumer should construct a full reply to knative request.
-
copy
public KnativeConfiguration copy()
-
-