code: @Override
  	public MessageProperties toMessageProperties(AMQP.BasicProperties source, Envelope envelope, String charset) {
  		final MessageProperties messageProperties = super.toMessageProperties(source, envelope, charset);
  
  		final TraceeFilterConfiguration filterConfiguration = backend.getConfiguration(profile);
  		if (filterConfiguration.shouldProcessContext(AsyncProcess)) {
  			// Values are stored as type of LongStringHelper.ByteArrayLongString - but it's private
  			final Map<String, String> traceeContextMap = transformToTraceeContextMap(
  				(Map<String, ?>) messageProperties.getHeaders().get(TPIC_HEADER));
  			if (traceeContextMap != null && !traceeContextMap.isEmpty()) {
  				backend.putAll(filterConfiguration.filterDeniedParams(traceeContextMap, AsyncProcess));
  			}
  		}
  
  		Utilities.generateInvocationIdIfNecessary(backend);
  		return messageProperties;
  	}
docs: Incoming messages