ConnectionParams |
ConnectionParams.setAmqpPropertiesCustomiser(java.util.function.BiFunction<com.rabbitmq.client.AMQP.BasicProperties.Builder,javax.jms.Message,com.rabbitmq.client.AMQP.BasicProperties.Builder> amqpPropertiesCustomiser) |
ConnectionParams |
ConnectionParams.setChannelsQos(int channelsQos) |
ConnectionParams |
ConnectionParams.setCleanUpServerNamedQueuesForNonDurableTopicsOnSessionClose(boolean cleanUpServerNamedQueuesForNonDurableTopicsOnSessionClose) |
ConnectionParams |
ConnectionParams.setConfirmListener(ConfirmListener confirmListener) |
ConnectionParams |
ConnectionParams.setKeepTextMessageType(boolean keepTextMessageType) |
ConnectionParams |
ConnectionParams.setNackOnRollback(boolean nackOnRollback) |
ConnectionParams |
ConnectionParams.setOnMessageTimeoutMs(int onMessageTimeoutMs) |
ConnectionParams |
ConnectionParams.setPreferProducerMessageProperty(boolean preferProducerMessageProperty) |
ConnectionParams |
ConnectionParams.setQueueBrowserReadMax(int queueBrowserReadMax) |
ConnectionParams |
ConnectionParams.setRabbitConnection(com.rabbitmq.client.Connection rabbitConnection) |
ConnectionParams |
ConnectionParams.setReceivingContextConsumer(ReceivingContextConsumer receivingContextConsumer) |
ConnectionParams |
ConnectionParams.setRequeueOnMessageListenerException(boolean requeueOnMessageListenerException) |
ConnectionParams |
ConnectionParams.setRequeueOnTimeout(boolean requeueOnTimeout) |
ConnectionParams |
ConnectionParams.setSendingContextConsumer(SendingContextConsumer sendingContextConsumer) |
ConnectionParams |
ConnectionParams.setTerminationTimeout(long terminationTimeout) |
ConnectionParams |
ConnectionParams.setTrustedPackages(java.util.List<java.lang.String> trustedPackages) |
ConnectionParams |
ConnectionParams.setValidateSubscriptionNames(boolean validateSubscriptionNames) |