public class RabbitSourceOptionsMetadata
extends java.lang.Object
rabbit
source module.Constructor and Description |
---|
RabbitSourceOptionsMetadata() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getAckMode() |
int |
getConcurrency() |
java.lang.String |
getConverterClass() |
int |
getMaxConcurrency() |
int |
getPrefetch() |
java.lang.String |
getQueues() |
int |
getTxSize() |
boolean |
isRequeue() |
boolean |
isTransacted() |
void |
setAckMode(java.lang.String ackMode) |
void |
setConcurrency(int concurrency) |
void |
setConverterClass(java.lang.String converterClass) |
void |
setMaxConcurrency(int maxConcurrency) |
void |
setPrefetch(int prefetch) |
void |
setQueues(java.lang.String queues) |
void |
setRequeue(boolean requeue) |
void |
setTransacted(boolean transacted) |
void |
setTxSize(int txSize) |
@NotBlank public java.lang.String getQueues()
public void setQueues(java.lang.String queues)
@NotBlank public java.lang.String getAckMode()
public void setAckMode(java.lang.String ackMode)
public boolean isTransacted()
public void setTransacted(boolean transacted)
public int getConcurrency()
public void setConcurrency(int concurrency)
public boolean isRequeue()
public void setRequeue(boolean requeue)
public int getMaxConcurrency()
public void setMaxConcurrency(int maxConcurrency)
public int getPrefetch()
public void setPrefetch(int prefetch)
public int getTxSize()
public void setTxSize(int txSize)
public java.lang.String getConverterClass()
public void setConverterClass(java.lang.String converterClass)