com.rabbitmq.jms.client

Class SessionParams

java.lang.Object

com.rabbitmq.jms.client.SessionParams

public class SessionParams
extends java.lang.Object

Holder for RMQSession constructor arguments.

Constructor Summary

Constructors

Constructor and Description
SessionParams()

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()
ConfirmListener	getConfirmListener()
RMQConnection	getConnection()
com.rabbitmq.jms.client.DelayedMessageService	getDelayedMessageService()
int	getMode()
int	getOnMessageTimeoutMs()
ReceivingContextConsumer	getReceivingContextConsumer()
SendingContextConsumer	getSendingContextConsumer()
com.rabbitmq.jms.client.Subscriptions	getSubscriptions()
java.util.List<java.lang.String>	getTrustedPackages()
boolean	isCleanUpServerNamedQueuesForNonDurableTopics()
boolean	isKeepTextMessageType()
boolean	isTransacted()
boolean	isValidateSubscriptionNames()
SessionParams	setAmqpPropertiesCustomiser(java.util.function.BiFunction<com.rabbitmq.client.AMQP.BasicProperties.Builder,javax.jms.Message,com.rabbitmq.client.AMQP.BasicProperties.Builder> amqpPropertiesCustomiser)
SessionParams	setCleanUpServerNamedQueuesForNonDurableTopics(boolean cleanUpServerNamedQueuesForNonDurableTopics)
SessionParams	setConfirmListener(ConfirmListener confirmListener)
SessionParams	setConnection(RMQConnection connection)
SessionParams	setDelayedMessageService(com.rabbitmq.jms.client.DelayedMessageService delayedMessageService)
SessionParams	setKeepTextMessageType(boolean keepTextMessageType)
SessionParams	setMode(int mode)
SessionParams	setNackOnRollback(boolean nackOnRollback)
SessionParams	setOnMessageTimeoutMs(int onMessageTimeoutMs)
SessionParams	setPreferProducerMessageProperty(boolean preferProducerMessageProperty)
SessionParams	setReceivingContextConsumer(ReceivingContextConsumer receivingContextConsumer)
SessionParams	setRequeueOnMessageListenerException(boolean requeueOnMessageListenerException)
SessionParams	setRequeueOnTimeout(boolean requeueOnTimeout)
SessionParams	setSendingContextConsumer(SendingContextConsumer sendingContextConsumer)
SessionParams	setSubscriptions(com.rabbitmq.jms.client.Subscriptions subscriptions)
SessionParams	setTransacted(boolean transacted)
SessionParams	setTrustedPackages(java.util.List<java.lang.String> trustedPackages)
SessionParams	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

SessionParams

public SessionParams()

Method Detail

getConnection

public RMQConnection getConnection()

setConnection

public SessionParams setConnection(RMQConnection connection)

isTransacted

public boolean isTransacted()

setTransacted

public SessionParams setTransacted(boolean transacted)

getOnMessageTimeoutMs

public int getOnMessageTimeoutMs()

setOnMessageTimeoutMs

public SessionParams setOnMessageTimeoutMs(int onMessageTimeoutMs)

getMode

public int getMode()

setMode

public SessionParams setMode(int mode)

getSubscriptions

public com.rabbitmq.jms.client.Subscriptions getSubscriptions()

setSubscriptions

public SessionParams setSubscriptions(com.rabbitmq.jms.client.Subscriptions subscriptions)

willPreferProducerMessageProperty

public boolean willPreferProducerMessageProperty()

setPreferProducerMessageProperty

public SessionParams setPreferProducerMessageProperty(boolean preferProducerMessageProperty)

willRequeueOnMessageListenerException

public boolean willRequeueOnMessageListenerException()

setRequeueOnMessageListenerException

public SessionParams setRequeueOnMessageListenerException(boolean requeueOnMessageListenerException)

willNackOnRollback

public boolean willNackOnRollback()

setNackOnRollback

public SessionParams setNackOnRollback(boolean nackOnRollback)

isCleanUpServerNamedQueuesForNonDurableTopics

public boolean isCleanUpServerNamedQueuesForNonDurableTopics()

setCleanUpServerNamedQueuesForNonDurableTopics

public SessionParams setCleanUpServerNamedQueuesForNonDurableTopics(boolean cleanUpServerNamedQueuesForNonDurableTopics)

getAmqpPropertiesCustomiser

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

setAmqpPropertiesCustomiser

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

setSendingContextConsumer

public SessionParams setSendingContextConsumer(SendingContextConsumer sendingContextConsumer)

getSendingContextConsumer

public SendingContextConsumer getSendingContextConsumer()

setReceivingContextConsumer

public SessionParams setReceivingContextConsumer(ReceivingContextConsumer receivingContextConsumer)

getReceivingContextConsumer

public ReceivingContextConsumer getReceivingContextConsumer()

setConfirmListener

public SessionParams setConfirmListener(ConfirmListener confirmListener)

getConfirmListener

public ConfirmListener getConfirmListener()

setKeepTextMessageType

public SessionParams setKeepTextMessageType(boolean keepTextMessageType)

isKeepTextMessageType

public boolean isKeepTextMessageType()

setTrustedPackages

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

getTrustedPackages

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

setRequeueOnTimeout

public SessionParams setRequeueOnTimeout(boolean requeueOnTimeout)

willRequeueOnTimeout

public boolean willRequeueOnTimeout()

setValidateSubscriptionNames

public SessionParams setValidateSubscriptionNames(boolean validateSubscriptionNames)

isValidateSubscriptionNames

public boolean isValidateSubscriptionNames()

getDelayedMessageService

public com.rabbitmq.jms.client.DelayedMessageService getDelayedMessageService()

setDelayedMessageService

public SessionParams setDelayedMessageService(com.rabbitmq.jms.client.DelayedMessageService delayedMessageService)