Package io.aiven.kafka.connect.amqp.common.config

Class AmqpFragment.Setter

java.lang.Object

io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter<AmqpFragment.Setter>

io.aiven.kafka.connect.amqp.common.config.AmqpFragment.Setter

Enclosing class:

AmqpFragment

public static class AmqpFragment.Setter
extends io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter<AmqpFragment.Setter>

The Setter for the AMQP fragment.

Field Summary

Fields inherited from class io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter

self

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Setter(Map<String,String> data)	Constructor.

Method Summary

Modifier and Type	Method	Description
AmqpFragment.Setter	setAddress(String address)	Sets the address for the AMQP receiver.
AmqpFragment.Setter	setHost(String host)	Sets the host value.
AmqpFragment.Setter	setPassword(String password)	Sets the user password to connect to the AMQP server.
AmqpFragment.Setter	setPort(int port)	Sets the port for the AMQP connection.
AmqpFragment.Setter	setUser(String user)	Sets the user name to connect to the AMQP server.

Methods inherited from class io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter

data, setValue, setValue, setValue, setValue, setValue, setValue

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Setter

protected Setter(Map<String,String> data)

Constructor.

Parameters:

data - the map of data items being set.

Method Details

setHost

public AmqpFragment.Setter setHost(String host)

Sets the host value.

Parameters:

host - the host for AMQP connection.

Returns:

this

setPort

public AmqpFragment.Setter setPort(int port)

Sets the port for the AMQP connection.

Parameters:

port - the port for the AMQP connection.

Returns:

this.

setAddress

public AmqpFragment.Setter setAddress(String address)

Sets the address for the AMQP receiver.

Parameters:

address - the address (topic) to listen to

Returns:

this.

setUser

public AmqpFragment.Setter setUser(String user)

Sets the user name to connect to the AMQP server.

Parameters:

user - the user name.

Returns:

this.

setPassword

public AmqpFragment.Setter setPassword(String password)

Sets the user password to connect to the AMQP server.

Parameters:

password - the password.

Returns:

this.