org.springframework.xd.dirt.modules.metadata

Class RabbitSourceOptionsMetadata

java.lang.Object

org.springframework.xd.dirt.modules.metadata.RabbitSourceOptionsMetadata

All Implemented Interfaces:

ProfileNamesProvider

public class RabbitSourceOptionsMetadata
extends java.lang.Object
implements ProfileNamesProvider

Describes options to the rabbit source module.

Author:

Eric Bottard, Gary Russell, David Liu

Field Summary

Fields inherited from interface org.springframework.xd.module.options.spi.ProfileNamesProvider

NO_PROFILES

Constructor Summary

Constructors

Constructor and Description
RabbitSourceOptionsMetadata()

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	getAckMode()
int	getConcurrency()
java.lang.String	getConverterClass()
int	getInitialRetryInterval()
int	getMaxAttempts()
int	getMaxConcurrency()
int	getMaxRetryInterval()
int	getPrefetch()
java.lang.String	getQueues()
double	getRetryMultiplier()
int	getTxSize()
boolean	isEnableRetry()
boolean	isRequeue()
boolean	isTransacted()
java.lang.String[]	profilesToActivate()
void	setAckMode(java.lang.String ackMode)
void	setConcurrency(int concurrency)
void	setConverterClass(java.lang.String converterClass)
void	setEnableRetry(boolean enableRetry)
void	setInitialRetryInterval(int initialRetryInterval)
void	setMaxAttempts(int maxAttempts)
void	setMaxConcurrency(int maxConcurrency)
void	setMaxRetryInterval(int maxRetryInterval)
void	setPrefetch(int prefetch)
void	setQueues(java.lang.String queues)
void	setRequeue(boolean requeue)
void	setRetryMultiplier(double retryMultiplier)
void	setTransacted(boolean transacted)
void	setTxSize(int txSize)

Methods inherited from class java.lang.Object

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

Constructor Detail

RabbitSourceOptionsMetadata

public RabbitSourceOptionsMetadata()

Method Detail

getQueues

@NotBlank
public java.lang.String getQueues()

setQueues

public void setQueues(java.lang.String queues)

getAckMode

@NotBlank
public java.lang.String getAckMode()

setAckMode

public void setAckMode(java.lang.String ackMode)

isTransacted

public boolean isTransacted()

setTransacted

public void setTransacted(boolean transacted)

getConcurrency

public int getConcurrency()

setConcurrency

public void setConcurrency(int concurrency)

isRequeue

public boolean isRequeue()

setRequeue

public void setRequeue(boolean requeue)

getMaxConcurrency

public int getMaxConcurrency()

setMaxConcurrency

public void setMaxConcurrency(int maxConcurrency)

getPrefetch

public int getPrefetch()

setPrefetch

public void setPrefetch(int prefetch)

getTxSize

public int getTxSize()

setTxSize

public void setTxSize(int txSize)

getConverterClass

public java.lang.String getConverterClass()

setConverterClass

public void setConverterClass(java.lang.String converterClass)

getInitialRetryInterval

public int getInitialRetryInterval()

setInitialRetryInterval

public void setInitialRetryInterval(int initialRetryInterval)

getMaxRetryInterval

public int getMaxRetryInterval()

setMaxRetryInterval

public void setMaxRetryInterval(int maxRetryInterval)

getRetryMultiplier

public double getRetryMultiplier()

setRetryMultiplier

public void setRetryMultiplier(double retryMultiplier)

getMaxAttempts

public int getMaxAttempts()

setMaxAttempts

public void setMaxAttempts(int maxAttempts)

isEnableRetry

public boolean isEnableRetry()

setEnableRetry

public void setEnableRetry(boolean enableRetry)

profilesToActivate

public java.lang.String[] profilesToActivate()

Specified by:

profilesToActivate in interface ProfileNamesProvider