Interface RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder

  • All Superinterfaces:
    org.apache.camel.builder.EndpointProducerBuilder, org.apache.camel.EndpointProducerResolver
    All Known Subinterfaces:
    RabbitMQEndpointBuilderFactory.RabbitMQEndpointBuilder
    Enclosing interface:
    RabbitMQEndpointBuilderFactory

    public static interface RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder
    extends org.apache.camel.builder.EndpointProducerBuilder
    Builder for endpoint producers for the RabbitMQ component.
    • Method Detail

      • addresses

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder addresses​(String addresses)
        If this option is set, camel-rabbitmq will try to create connection based on the setting of option addresses. The addresses value is a string which looks like server1:12345, server2:12345. The option is a: java.lang.String type. Group: common
      • automaticRecoveryEnabled

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder automaticRecoveryEnabled​(Boolean automaticRecoveryEnabled)
        Enables connection automatic recovery (uses connection implementation that performs automatic recovery when existing connection has failures). The option is a: java.lang.Boolean type. Default: true Group: common
      • automaticRecoveryEnabled

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder automaticRecoveryEnabled​(String automaticRecoveryEnabled)
        Enables connection automatic recovery (uses connection implementation that performs automatic recovery when existing connection has failures). The option will be converted to a java.lang.Boolean type. Default: true Group: common
      • connectionFactory

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder connectionFactory​(Object connectionFactory)
        To use a custom RabbitMQ connection factory. When this option is set, all connection options (connectionTimeout, requestedChannelMax...) set on URI are not used. The option is a: com.rabbitmq.client.ConnectionFactory type. Group: common
      • connectionFactory

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder connectionFactory​(String connectionFactory)
        To use a custom RabbitMQ connection factory. When this option is set, all connection options (connectionTimeout, requestedChannelMax...) set on URI are not used. The option will be converted to a com.rabbitmq.client.ConnectionFactory type. Group: common
      • declare

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder declare​(boolean declare)
        If the option is true, camel declare the exchange and queue name and bind them together. If the option is false, camel won't declare the exchange and queue name on the server. The option is a: boolean type. Default: true Group: common
      • declare

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder declare​(String declare)
        If the option is true, camel declare the exchange and queue name and bind them together. If the option is false, camel won't declare the exchange and queue name on the server. The option will be converted to a boolean type. Default: true Group: common
      • skipDlqDeclare

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder skipDlqDeclare​(boolean skipDlqDeclare)
        If true the producer will not declare and bind a dead letter queue. This can be used if you have also DLQ rabbitmq consumer and you want to avoid argument clashing between Producer and Consumer. This option have no effect, if DLQ configured (deadLetterExchange option is not set). The option is a: boolean type. Default: false Group: common
      • skipDlqDeclare

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder skipDlqDeclare​(String skipDlqDeclare)
        If true the producer will not declare and bind a dead letter queue. This can be used if you have also DLQ rabbitmq consumer and you want to avoid argument clashing between Producer and Consumer. This option have no effect, if DLQ configured (deadLetterExchange option is not set). The option will be converted to a boolean type. Default: false Group: common
      • skipQueueDeclare

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder skipQueueDeclare​(boolean skipQueueDeclare)
        If true the producer will not declare and bind a queue. This can be used for directing messages via an existing routing key. The option is a: boolean type. Default: false Group: common
      • additionalHeaders

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder additionalHeaders​(String additionalHeaders)
        Map of additional headers. These headers will be set only when the 'allowCustomHeaders' is set to true. The option will be converted to a java.util.Map<java.lang.String, java.lang.Object> type. Group: producer
      • additionalProperties

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder additionalProperties​(Map<String,​Object> additionalProperties)
        Map of additional properties. These are standard RabbitMQ properties as defined in com.rabbitmq.client.AMQP.BasicProperties. The map keys should be from org.apache.camel.component.rabbitmq.RabbitMQConstants. Any other keys will be ignored. The option is a: java.util.Map<java.lang.String, java.lang.Object> type. Group: producer
      • additionalProperties

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder additionalProperties​(String additionalProperties)
        Map of additional properties. These are standard RabbitMQ properties as defined in com.rabbitmq.client.AMQP.BasicProperties. The map keys should be from org.apache.camel.component.rabbitmq.RabbitMQConstants. Any other keys will be ignored. The option will be converted to a java.util.Map<java.lang.String, java.lang.Object> type. Group: producer
      • bridgeEndpoint

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder bridgeEndpoint​(boolean bridgeEndpoint)
        If the bridgeEndpoint is true, the producer will ignore the message header of rabbitmq.EXCHANGE_NAME and rabbitmq.ROUTING_KEY. The option is a: boolean type. Default: false Group: producer
      • guaranteedDeliveries

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder guaranteedDeliveries​(boolean guaranteedDeliveries)
        When true, an exception will be thrown when the message cannot be delivered (basic.return) and the message is marked as mandatory. PublisherAcknowledgement will also be activated in this case. See also publisher acknowledgements - When will messages be confirmed. The option is a: boolean type. Default: false Group: producer
      • guaranteedDeliveries

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder guaranteedDeliveries​(String guaranteedDeliveries)
        When true, an exception will be thrown when the message cannot be delivered (basic.return) and the message is marked as mandatory. PublisherAcknowledgement will also be activated in this case. See also publisher acknowledgements - When will messages be confirmed. The option will be converted to a boolean type. Default: false Group: producer
      • immediate

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder immediate​(boolean immediate)
        This flag tells the server how to react if the message cannot be routed to a queue consumer immediately. If this flag is set, the server will return an undeliverable message with a Return method. If this flag is zero, the server will queue the message, but with no guarantee that it will ever be consumed. If the header is present rabbitmq.IMMEDIATE it will override this option. The option is a: boolean type. Default: false Group: producer
      • immediate

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder immediate​(String immediate)
        This flag tells the server how to react if the message cannot be routed to a queue consumer immediately. If this flag is set, the server will return an undeliverable message with a Return method. If this flag is zero, the server will queue the message, but with no guarantee that it will ever be consumed. If the header is present rabbitmq.IMMEDIATE it will override this option. The option will be converted to a boolean type. Default: false Group: producer
      • lazyStartProducer

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder lazyStartProducer​(boolean lazyStartProducer)
        Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing. The option is a: boolean type. Default: false Group: producer
      • lazyStartProducer

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder lazyStartProducer​(String lazyStartProducer)
        Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing. The option will be converted to a boolean type. Default: false Group: producer
      • mandatory

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder mandatory​(boolean mandatory)
        This flag tells the server how to react if the message cannot be routed to a queue. If this flag is set, the server will return an unroutable message with a Return method. If this flag is zero, the server silently drops the message. If the header is present rabbitmq.MANDATORY it will override this option. The option is a: boolean type. Default: false Group: producer
      • mandatory

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder mandatory​(String mandatory)
        This flag tells the server how to react if the message cannot be routed to a queue. If this flag is set, the server will return an unroutable message with a Return method. If this flag is zero, the server silently drops the message. If the header is present rabbitmq.MANDATORY it will override this option. The option will be converted to a boolean type. Default: false Group: producer
      • publisherAcknowledgements

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder publisherAcknowledgements​(boolean publisherAcknowledgements)
        When true, the message will be published with publisher acknowledgements turned on. The option is a: boolean type. Default: false Group: producer
      • publisherAcknowledgementsTimeout

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder publisherAcknowledgementsTimeout​(long publisherAcknowledgementsTimeout)
        The amount of time in milliseconds to wait for a basic.ack response from RabbitMQ server. The option is a: long type. Group: producer
      • allowMessageBodySerialization

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder allowMessageBodySerialization​(boolean allowMessageBodySerialization)
        Whether to allow Java serialization of the message body or not. If this value is true, the message body will be serialized on the producer side using Java serialization, if no type converter can handle the message body. On the consumer side, it will deserialize the message body if this value is true and the message contains a CamelSerialize header. Setting this value to true may introduce a security vulnerability as it allows an attacker to attempt to deserialize to a gadget object which could result in a RCE or other security vulnerability. The option is a: boolean type. Default: false Group: allowMessageBodySerialization
      • allowMessageBodySerialization

        default RabbitMQEndpointBuilderFactory.RabbitMQEndpointProducerBuilder allowMessageBodySerialization​(String allowMessageBodySerialization)
        Whether to allow Java serialization of the message body or not. If this value is true, the message body will be serialized on the producer side using Java serialization, if no type converter can handle the message body. On the consumer side, it will deserialize the message body if this value is true and the message contains a CamelSerialize header. Setting this value to true may introduce a security vulnerability as it allows an attacker to attempt to deserialize to a gadget object which could result in a RCE or other security vulnerability. The option will be converted to a boolean type. Default: false Group: allowMessageBodySerialization