Constructor and Description |
---|
AvroConfiguration() |
Modifier and Type | Method and 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,
Map<String,Object> parameters,
AvroComponent component) |
void |
setHost(String host)
Hostname to use
|
void |
setMessageName(String messageName)
The name of the message to send.
|
void |
setPort(int port)
Port number to use
|
void |
setProtocol(org.apache.avro.Protocol protocol)
Avro protocol to use
|
void |
setProtocolClassName(String protocolClassName)
Avro protocol to use defined by the FQN class name
|
void |
setProtocolLocation(String protocolLocation)
Avro protocol location
|
void |
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(AvroTransport transport) |
void |
setTransport(String transport)
Transport to use
|
void |
setUriAuthority(String uriAuthority)
Authority to use (username and password)
|
public AvroConfiguration copy()
public void parseURI(URI uri, Map<String,Object> parameters, AvroComponent component) throws Exception
Exception
public String getHost()
public void setHost(String host)
public int getPort()
public void setPort(int port)
public org.apache.avro.Protocol getProtocol()
public void setProtocol(org.apache.avro.Protocol protocol)
public AvroTransport getTransport()
public void setTransport(String transport)
public void setTransport(AvroTransport transport)
public String getProtocolLocation()
public void setProtocolLocation(String protocolLocation)
public String getProtocolClassName()
public void setProtocolClassName(String protocolClassName)
public String getMessageName()
public void setMessageName(String messageName)
public String getUriAuthority()
public void setUriAuthority(String uriAuthority)
public boolean isReflectionProtocol()
public void setReflectionProtocol(boolean isReflectionProtocol)
public boolean isSingleParameter()
public void setSingleParameter(boolean singleParameter)
Apache Camel