@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class PipeSourceRabbitMQBrokerParameters extends Object implements Serializable, Cloneable, StructuredPojo
The parameters for using a Rabbit MQ broker as a source.
Constructor and Description |
---|
PipeSourceRabbitMQBrokerParameters() |
Modifier and Type | Method and Description |
---|---|
PipeSourceRabbitMQBrokerParameters |
clone() |
boolean |
equals(Object obj) |
Integer |
getBatchSize()
The maximum number of records to include in each batch.
|
MQBrokerAccessCredentials |
getCredentials()
The credentials needed to access the resource.
|
Integer |
getMaximumBatchingWindowInSeconds()
The maximum length of a time to wait for events.
|
String |
getQueueName()
The name of the destination queue to consume.
|
String |
getVirtualHost()
The name of the virtual host associated with the source broker.
|
int |
hashCode() |
void |
marshall(ProtocolMarshaller protocolMarshaller)
Marshalls this structured data using the given
ProtocolMarshaller . |
void |
setBatchSize(Integer batchSize)
The maximum number of records to include in each batch.
|
void |
setCredentials(MQBrokerAccessCredentials credentials)
The credentials needed to access the resource.
|
void |
setMaximumBatchingWindowInSeconds(Integer maximumBatchingWindowInSeconds)
The maximum length of a time to wait for events.
|
void |
setQueueName(String queueName)
The name of the destination queue to consume.
|
void |
setVirtualHost(String virtualHost)
The name of the virtual host associated with the source broker.
|
String |
toString()
Returns a string representation of this object.
|
PipeSourceRabbitMQBrokerParameters |
withBatchSize(Integer batchSize)
The maximum number of records to include in each batch.
|
PipeSourceRabbitMQBrokerParameters |
withCredentials(MQBrokerAccessCredentials credentials)
The credentials needed to access the resource.
|
PipeSourceRabbitMQBrokerParameters |
withMaximumBatchingWindowInSeconds(Integer maximumBatchingWindowInSeconds)
The maximum length of a time to wait for events.
|
PipeSourceRabbitMQBrokerParameters |
withQueueName(String queueName)
The name of the destination queue to consume.
|
PipeSourceRabbitMQBrokerParameters |
withVirtualHost(String virtualHost)
The name of the virtual host associated with the source broker.
|
public void setCredentials(MQBrokerAccessCredentials credentials)
The credentials needed to access the resource.
credentials
- The credentials needed to access the resource.public MQBrokerAccessCredentials getCredentials()
The credentials needed to access the resource.
public PipeSourceRabbitMQBrokerParameters withCredentials(MQBrokerAccessCredentials credentials)
The credentials needed to access the resource.
credentials
- The credentials needed to access the resource.public void setQueueName(String queueName)
The name of the destination queue to consume.
queueName
- The name of the destination queue to consume.public String getQueueName()
The name of the destination queue to consume.
public PipeSourceRabbitMQBrokerParameters withQueueName(String queueName)
The name of the destination queue to consume.
queueName
- The name of the destination queue to consume.public void setVirtualHost(String virtualHost)
The name of the virtual host associated with the source broker.
virtualHost
- The name of the virtual host associated with the source broker.public String getVirtualHost()
The name of the virtual host associated with the source broker.
public PipeSourceRabbitMQBrokerParameters withVirtualHost(String virtualHost)
The name of the virtual host associated with the source broker.
virtualHost
- The name of the virtual host associated with the source broker.public void setBatchSize(Integer batchSize)
The maximum number of records to include in each batch.
batchSize
- The maximum number of records to include in each batch.public Integer getBatchSize()
The maximum number of records to include in each batch.
public PipeSourceRabbitMQBrokerParameters withBatchSize(Integer batchSize)
The maximum number of records to include in each batch.
batchSize
- The maximum number of records to include in each batch.public void setMaximumBatchingWindowInSeconds(Integer maximumBatchingWindowInSeconds)
The maximum length of a time to wait for events.
maximumBatchingWindowInSeconds
- The maximum length of a time to wait for events.public Integer getMaximumBatchingWindowInSeconds()
The maximum length of a time to wait for events.
public PipeSourceRabbitMQBrokerParameters withMaximumBatchingWindowInSeconds(Integer maximumBatchingWindowInSeconds)
The maximum length of a time to wait for events.
maximumBatchingWindowInSeconds
- The maximum length of a time to wait for events.public String toString()
toString
in class Object
Object.toString()
public PipeSourceRabbitMQBrokerParameters clone()
public void marshall(ProtocolMarshaller protocolMarshaller)
StructuredPojo
ProtocolMarshaller
.marshall
in interface StructuredPojo
protocolMarshaller
- Implementation of ProtocolMarshaller
used to marshall this object's data.