Class DefaultMessagePropertiesConverter
java.lang.Object
org.apache.camel.component.springrabbit.DefaultMessagePropertiesConverter
- All Implemented Interfaces:
MessagePropertiesConverter
-
Constructor Summary
ConstructorsConstructorDescriptionDefaultMessagePropertiesConverter(org.apache.camel.CamelContext camelContext, org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy) -
Method Summary
Modifier and TypeMethodDescriptionfromMessageProperties(org.springframework.amqp.core.MessageProperties messageProperties, org.apache.camel.Exchange exchange) protected booleanshouldInputHeader(String headerName, Object headerValue, org.apache.camel.Exchange exchange) Strategy to allow filtering from RabbitMQ message to Camel messageprotected booleanshouldOutputHeader(String headerName, Object headerValue, org.apache.camel.Exchange exchange) Strategy to allow filtering of headers which are put on the RabbitMQ messageorg.springframework.amqp.core.MessagePropertiestoMessageProperties(org.apache.camel.Exchange exchange)
-
Constructor Details
-
DefaultMessagePropertiesConverter
public DefaultMessagePropertiesConverter(org.apache.camel.CamelContext camelContext, org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy)
-
-
Method Details
-
toMessageProperties
public org.springframework.amqp.core.MessageProperties toMessageProperties(org.apache.camel.Exchange exchange) - Specified by:
toMessagePropertiesin interfaceMessagePropertiesConverter
-
fromMessageProperties
public Map<String,Object> fromMessageProperties(org.springframework.amqp.core.MessageProperties messageProperties, org.apache.camel.Exchange exchange) - Specified by:
fromMessagePropertiesin interfaceMessagePropertiesConverter
-
shouldOutputHeader
protected boolean shouldOutputHeader(String headerName, Object headerValue, org.apache.camel.Exchange exchange) Strategy to allow filtering of headers which are put on the RabbitMQ message -
shouldInputHeader
protected boolean shouldInputHeader(String headerName, Object headerValue, org.apache.camel.Exchange exchange) Strategy to allow filtering from RabbitMQ message to Camel message
-