Package org.apache.camel.component.avro
Class AvroConfiguration
- java.lang.Object
-
- org.apache.camel.component.avro.AvroConfiguration
-
-
Constructor Summary
Constructors Constructor Description AvroConfiguration()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description AvroConfiguration
copy()
String
getHost()
String
getMessageName()
int
getPort()
org.apache.avro.Protocol
getProtocol()
String
getProtocolClassName()
String
getProtocolLocation()
AvroTransport
getTransport()
String
getUriAuthority()
boolean
isReflectionProtocol()
boolean
isSingleParameter()
void
parseURI(URI uri)
void
setHost(String host)
Hostname to usevoid
setMessageName(String messageName)
The name of the message to send.void
setPort(int port)
Port number to usevoid
setProtocol(org.apache.avro.Protocol protocol)
Avro protocol to usevoid
setProtocolClassName(String protocolClassName)
Avro protocol to use defined by the FQN class namevoid
setProtocolLocation(String protocolLocation)
Avro protocol locationvoid
setReflectionProtocol(boolean isReflectionProtocol)
If protocol object provided is reflection protocol.void
setSingleParameter(boolean singleParameter)
If true, consumer parameter won't be wrapped into array.void
setTransport(String transport)
Transport to use, can be either http or nettyvoid
setTransport(AvroTransport transport)
Transport to use, can be either http or nettyvoid
setUriAuthority(String uriAuthority)
Authority to use (username and password)
-
-
-
Method Detail
-
copy
public AvroConfiguration copy()
-
getHost
public String getHost()
-
setHost
public void setHost(String host)
Hostname to use
-
getPort
public int getPort()
-
setPort
public void setPort(int port)
Port number to use
-
getProtocol
public org.apache.avro.Protocol getProtocol()
-
setProtocol
public void setProtocol(org.apache.avro.Protocol protocol)
Avro protocol to use
-
getTransport
public AvroTransport getTransport()
-
setTransport
public void setTransport(String transport)
Transport to use, can be either http or netty
-
setTransport
public void setTransport(AvroTransport transport)
Transport to use, can be either http or netty
-
getProtocolLocation
public String getProtocolLocation()
-
setProtocolLocation
public void setProtocolLocation(String protocolLocation)
Avro protocol location
-
getProtocolClassName
public String getProtocolClassName()
-
setProtocolClassName
public void setProtocolClassName(String protocolClassName)
Avro protocol to use defined by the FQN class name
-
getMessageName
public String getMessageName()
-
setMessageName
public void setMessageName(String messageName)
The name of the message to send.
-
getUriAuthority
public String getUriAuthority()
-
setUriAuthority
public void setUriAuthority(String uriAuthority)
Authority to use (username and password)
-
isReflectionProtocol
public boolean isReflectionProtocol()
-
setReflectionProtocol
public void setReflectionProtocol(boolean isReflectionProtocol)
If protocol object provided is reflection protocol. Should be used only with protocol parameter because for protocolClassName protocol type will be auto detected
-
isSingleParameter
public boolean isSingleParameter()
-
setSingleParameter
public void setSingleParameter(boolean singleParameter)
If true, consumer parameter won't be wrapped into array. Will fail if protocol specifies more then 1 parameter for the message
-
-