com.rabbitmq.jms.client

Class ConnectionParams

java.lang.Object

com.rabbitmq.jms.client.ConnectionParams

public class ConnectionParams
extends java.lang.Object

Holder for RMQConnection constructor arguments.

Constructor Summary

Constructors

Constructor and Description
ConnectionParams()

Method Summary

Modifier and Type	Method and Description
java.util.function.BiFunction<com.rabbitmq.client.AMQP.BasicProperties.Builder,javax.jms.Message,com.rabbitmq.client.AMQP.BasicProperties.Builder>	getAmqpPropertiesCustomiser()
int	getChannelsQos()
ConfirmListener	getConfirmListener()
int	getOnMessageTimeoutMs()
int	getQueueBrowserReadMax()
com.rabbitmq.client.Connection	getRabbitConnection()
ReceivingContextConsumer	getReceivingContextConsumer()
ReplyToStrategy	getReplyToStrategy()
SendingContextConsumer	getSendingContextConsumer()
long	getTerminationTimeout()
java.util.List<java.lang.String>	getTrustedPackages()
boolean	isCleanUpServerNamedQueuesForNonDurableTopicsOnSessionClose()
boolean	isKeepTextMessageType()
boolean	isValidateSubscriptionNames()
ConnectionParams	setAmqpPropertiesCustomiser(java.util.function.BiFunction<com.rabbitmq.client.AMQP.BasicProperties.Builder,javax.jms.Message,com.rabbitmq.client.AMQP.BasicProperties.Builder> amqpPropertiesCustomiser)
ConnectionParams	setChannelsQos(int channelsQos)
ConnectionParams	setCleanUpServerNamedQueuesForNonDurableTopicsOnSessionClose(boolean cleanUpServerNamedQueuesForNonDurableTopicsOnSessionClose)
ConnectionParams	setConfirmListener(ConfirmListener confirmListener)
ConnectionParams	setKeepTextMessageType(boolean keepTextMessageType)
ConnectionParams	setNackOnRollback(boolean nackOnRollback)
ConnectionParams	setOnMessageTimeoutMs(int onMessageTimeoutMs)
ConnectionParams	setPreferProducerMessageProperty(boolean preferProducerMessageProperty)
ConnectionParams	setQueueBrowserReadMax(int queueBrowserReadMax)
ConnectionParams	setRabbitConnection(com.rabbitmq.client.Connection rabbitConnection)
ConnectionParams	setReceivingContextConsumer(ReceivingContextConsumer receivingContextConsumer)
ConnectionParams	setReplyToStrategy(ReplyToStrategy replyToStrategy)
ConnectionParams	setRequeueOnMessageListenerException(boolean requeueOnMessageListenerException)
ConnectionParams	setRequeueOnTimeout(boolean requeueOnTimeout)
ConnectionParams	setSendingContextConsumer(SendingContextConsumer sendingContextConsumer)
ConnectionParams	setTerminationTimeout(long terminationTimeout)
ConnectionParams	setTrustedPackages(java.util.List<java.lang.String> trustedPackages)
ConnectionParams	setValidateSubscriptionNames(boolean validateSubscriptionNames)
boolean	willNackOnRollback()
boolean	willPreferProducerMessageProperty()
boolean	willRequeueOnMessageListenerException()
boolean	willRequeueOnTimeout()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionParams

public ConnectionParams()

Method Detail

getRabbitConnection

public com.rabbitmq.client.Connection getRabbitConnection()

setRabbitConnection

public ConnectionParams setRabbitConnection(com.rabbitmq.client.Connection rabbitConnection)

getTerminationTimeout

public long getTerminationTimeout()

setTerminationTimeout

public ConnectionParams setTerminationTimeout(long terminationTimeout)

getQueueBrowserReadMax

public int getQueueBrowserReadMax()

setQueueBrowserReadMax

public ConnectionParams setQueueBrowserReadMax(int queueBrowserReadMax)

getOnMessageTimeoutMs

public int getOnMessageTimeoutMs()

setOnMessageTimeoutMs

public ConnectionParams setOnMessageTimeoutMs(int onMessageTimeoutMs)

getChannelsQos

public int getChannelsQos()

setChannelsQos

public ConnectionParams setChannelsQos(int channelsQos)

willPreferProducerMessageProperty

public boolean willPreferProducerMessageProperty()

setPreferProducerMessageProperty

public ConnectionParams setPreferProducerMessageProperty(boolean preferProducerMessageProperty)

willRequeueOnMessageListenerException

public boolean willRequeueOnMessageListenerException()

setRequeueOnMessageListenerException

public ConnectionParams setRequeueOnMessageListenerException(boolean requeueOnMessageListenerException)

willNackOnRollback

public boolean willNackOnRollback()

setNackOnRollback

public ConnectionParams setNackOnRollback(boolean nackOnRollback)

isCleanUpServerNamedQueuesForNonDurableTopicsOnSessionClose

public boolean isCleanUpServerNamedQueuesForNonDurableTopicsOnSessionClose()

setCleanUpServerNamedQueuesForNonDurableTopicsOnSessionClose

public ConnectionParams setCleanUpServerNamedQueuesForNonDurableTopicsOnSessionClose(boolean cleanUpServerNamedQueuesForNonDurableTopicsOnSessionClose)

getAmqpPropertiesCustomiser

public java.util.function.BiFunction<com.rabbitmq.client.AMQP.BasicProperties.Builder,javax.jms.Message,com.rabbitmq.client.AMQP.BasicProperties.Builder> getAmqpPropertiesCustomiser()

setAmqpPropertiesCustomiser

public ConnectionParams setAmqpPropertiesCustomiser(java.util.function.BiFunction<com.rabbitmq.client.AMQP.BasicProperties.Builder,javax.jms.Message,com.rabbitmq.client.AMQP.BasicProperties.Builder> amqpPropertiesCustomiser)

getSendingContextConsumer

public SendingContextConsumer getSendingContextConsumer()

setSendingContextConsumer

public ConnectionParams setSendingContextConsumer(SendingContextConsumer sendingContextConsumer)

getReceivingContextConsumer

public ReceivingContextConsumer getReceivingContextConsumer()

setReceivingContextConsumer

public ConnectionParams setReceivingContextConsumer(ReceivingContextConsumer receivingContextConsumer)

setConfirmListener

public ConnectionParams setConfirmListener(ConfirmListener confirmListener)

getConfirmListener

public ConfirmListener getConfirmListener()

setKeepTextMessageType

public ConnectionParams setKeepTextMessageType(boolean keepTextMessageType)

isKeepTextMessageType

public boolean isKeepTextMessageType()

setTrustedPackages

public ConnectionParams setTrustedPackages(java.util.List<java.lang.String> trustedPackages)

getTrustedPackages

public java.util.List<java.lang.String> getTrustedPackages()

setRequeueOnTimeout

public ConnectionParams setRequeueOnTimeout(boolean requeueOnTimeout)

willRequeueOnTimeout

public boolean willRequeueOnTimeout()

setValidateSubscriptionNames

public ConnectionParams setValidateSubscriptionNames(boolean validateSubscriptionNames)

isValidateSubscriptionNames

public boolean isValidateSubscriptionNames()

setReplyToStrategy

public ConnectionParams setReplyToStrategy(ReplyToStrategy replyToStrategy)

getReplyToStrategy

public ReplyToStrategy getReplyToStrategy()