#vulnerable code 
                             @Override
	public boolean isRetainOuputAsMessage(Message<?> message) {
		if (message.getHeaders().containsKey("message-type") && message.getHeaders().get("message-type").equals("cloudevent")) {
			return true;
		}
		return false;
	} 
                            #location 3 
                            #vulnerability type NULL_DEREFERENCE
#fixed code
                             @Override
	public boolean isRetainOuputAsMessage(Message<?> message) {
		if (message.getHeaders().containsKey(MessageUtils.MESSAGE_TYPE)
				&& message.getHeaders().get(MessageUtils.MESSAGE_TYPE).equals(CloudEventMessageUtils.CLOUDEVENT_VALUE)) {
			return true;
		}
		return false;
	}