public interface AmqpReceiverFactory extends MessageReceiverFactory
Modifier and Type | Method and Description |
---|---|
AmqpReceiver<?> |
build() |
AmqpMessageDecoder<?> |
getDecoder() |
AmqpReceiverFactory |
setAddress(java.lang.String address) |
AmqpReceiverFactory |
setAttachProperty(java.lang.String key,
java.lang.Object value) |
AmqpReceiverFactory |
setDecoder(AmqpMessageDecoder<?> decoder) |
AmqpReceiverFactory |
setPrefetch(int prefetch) |
AmqpReceiverFactory |
setSourceProperty(java.lang.String key,
java.lang.Object value) |
AmqpReceiverFactory |
setTargetProperty(java.lang.String key,
java.lang.Object value) |
getAddress, getDistributionMode, getListener, getMessageDecoder, getPrefetch, getSettleMode, getSettleTime, setDistributionMode, setListener, setMessageDecoder, setSettleMode, setSettleTime
AmqpReceiverFactory setAddress(java.lang.String address)
setAddress
in interface MessageReceiverFactory
AmqpReceiverFactory setAttachProperty(java.lang.String key, java.lang.Object value)
AmqpReceiverFactory setSourceProperty(java.lang.String key, java.lang.Object value)
AmqpReceiverFactory setTargetProperty(java.lang.String key, java.lang.Object value)
AmqpReceiverFactory setPrefetch(int prefetch)
setPrefetch
in interface MessageReceiverFactory
AmqpReceiverFactory setDecoder(AmqpMessageDecoder<?> decoder)
AmqpMessageDecoder<?> getDecoder()
AmqpReceiver<?> build()
build
in interface MessageReceiverFactory