@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;
	}
@ 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 ) ) { 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 ; }
Incoming messages