/*
(non-Javadoc)
@see es.sandbox.ui.messages.spring.MessagesConfigurationSupport#configureMessageResolverStrategy()
355145
@Override
    protected MessageResolverStrategy configureMessageResolverStrategy() {
        final MessageResolverStrategy candidate = configuredMessageResolverStrategy();
        return candidate == null ? super.configureMessageResolverStrategy() : candidate;
    }
517122
protected void configureMessageConverter(ApplicationContext context) {
        if (context.containsBean(MESSAGE_CONVERTER_BEAN_NAME)) {
            HttpMessageConverter messageConverter = context.getBean(MESSAGE_CONVERTER_BEAN_NAME, HttpMessageConverter.class);

            if (messageConverter instanceof DelegatingHttpEntityMessageConverter) {
                ((DelegatingHttpEntityMessageConverter) messageConverter).setBinaryMediaTypes(httpServer.getBinaryMediaTypes());
            }
        }
    }
1338882
public static void setFaults(Message message, KnowledgeOperation operation, Map<String, Object> contextOverrides) {
        setOutputsOrFaults(message, operation.getFaultExpressionMappings(), contextOverrides, FAULT, false);
    }
182528
@Override
    protected void configure() {
        bind(MessagingService.class).to(MessagingServiceImpl.class);

        bind(BounceProxyLifecycleMonitor.class).to(MonitoringServiceClient.class);
        bind(BounceProxyInformation.class).toProvider(BounceProxyInformationProvider.class);
    }
997947
func (s *MessageRequest) SetMessageConfiguration(v *DirectMessageConfiguration) *MessageRequest {
	s.MessageConfiguration = v
	return s
}
482706
@SuppressWarnings("unchecked")
    public MessagingConfiguration getMessagingConfiguration(ServletConfig servletConfig) {
        Assert.isTrue(JdkVersion.getMajorJavaVersion() >= JdkVersion.JAVA_15, "Spring BlazeDS Integration requires a minimum of Java 1.5");
        Assert.notNull(servletConfig, "FlexConfigurationManager requires a non-null ServletConfig - "
            + "Is it being used outside a WebApplicationContext?");

        MessagingConfiguration configuration = new MessagingConfiguration();

        configuration.getSecuritySettings().setServerInfo(servletConfig.getServletContext().getServerInfo());

        if (CollectionUtils.isEmpty(configuration.getSecuritySettings().getLoginCommands())) {
            LoginCommandSettings settings = new LoginCommandSettings();
            settings.setClassName(NoOpLoginCommand.class.getName());
            configuration.getSecuritySettings().getLoginCommands().put(LoginCommandSettings.SERVER_MATCH_OVERRIDE, settings);
        }

        if (this.parser == null) {
            this.parser = getDefaultConfigurationParser();
        }

        Assert.notNull(this.parser, "Unable to create a parser to load Flex messaging configuration.");

        this.parser.parse(this.configurationPath, new ResourceResolverAdapter(this.resourceLoader), configuration);

        return configuration;
    }
1280851
public void setConfigurationAggregators(java.util.Collection<ConfigurationAggregator> configurationAggregators) {
        if (configurationAggregators == null) {
            this.configurationAggregators = null;
            return;
        }

        this.configurationAggregators = new com.amazonaws.internal.SdkInternalList<ConfigurationAggregator>(configurationAggregators);
    }
998464
public static void setOutputs(Message message, KnowledgeOperation operation, Map<String, Object> contextOverrides) {
        try {
            setOutputsOrFaults(message, operation.getOutputExpressionMappings(), contextOverrides, RESULT, false);
        } catch (Exception e) {
            setOutputsOrFaults(message, operation.getOutputExpressionMappings(), contextOverrides, RESULT, true);
        }
    }
1238692
private void configureSessionWithTimeout(final Session session, final int sessionTimeout) {
		if (transportStrategy != null) {
			// socket timeouts handling
			final Properties sessionProperties = session.getProperties();
			sessionProperties.put(transportStrategy.propertyNameConnectionTimeout(), String.valueOf(sessionTimeout));
			sessionProperties.put(transportStrategy.propertyNameTimeout(), String.valueOf(sessionTimeout));
			sessionProperties.put(transportStrategy.propertyNameWriteTimeout(), String.valueOf(sessionTimeout));
		} else {
			LOGGER.debug("No transport strategy provided, skipping defaults for .connectiontimout, .timout and .writetimeout");
		}
	}
113451
func (s *SendUsersMessageRequest) SetMessageConfiguration(v *DirectMessageConfiguration) *SendUsersMessageRequest {
	s.MessageConfiguration = v
	return s
}
152201
@Override
  public void exitStandardMessageOptionMessageSetWireFormat(
      final StandardMessageOptionMessageSetWireFormatContext ctx) {
    verifyOptionNameUnique("messageSetWireFormat", ctx.getStart());
    scopes.getMessageOptions().setMessageSetWireFormat(
        Boolean.valueOf(ctx.BooleanLiteral().getText()));
  }
1284828
func (s *CampaignResponse) SetMessageConfiguration(v *MessageConfiguration) *CampaignResponse {
	s.MessageConfiguration = v
	return s
}
1091331
private function _addExclusionStrategy(ExclusionStrategyInterface $strategy): void
    {
        if (null === $this->exclusionStrategy) {
            $this->exclusionStrategy = $strategy;

            return;
        }

        if ($this->exclusionStrategy instanceof DisjunctExclusionStrategy) {
            $this->exclusionStrategy->addStrategy($strategy);

            return;
        }

        $this->exclusionStrategy = new DisjunctExclusionStrategy([
            $this->exclusionStrategy,
            $strategy,
        ]);
    }
1114972
public void setStrategy( double median,
                             double standardDeviation,
                             int sigma ) {
        this.bucketingStrategy = new StandardDeviationBucketingStrategy(median, standardDeviation, sigma);
        this.bucketWidth = null;
    }
137903
static Message buildMessage(PublisherConfiguration publisherConfiguration, Object event) {
        Message message = new Message(publisherConfiguration.basicProperties)
                .exchange(publisherConfiguration.exchange)
                .routingKey(publisherConfiguration.routingKey);
        if (publisherConfiguration.persistent) {
            message.persistent();
        }
        if (event instanceof ContainsData) {
            message.body(((ContainsData) event).getData());
        } else if (event instanceof ContainsContent) {
            message.body(((ContainsContent) event).getContent());
        } else if (event instanceof ContainsId) {
            message.body(((ContainsId) event).getId());
        }
        return message;
    }
13587
public UpdateEventConfigurationsRequest withEventConfigurations(java.util.Map<String, Configuration> eventConfigurations) {
        setEventConfigurations(eventConfigurations);
        return this;
    }
198628
@Override
	protected void configureMessageConverters(List<HttpMessageConverter<?>> converters)
	{
		addDefaultHttpMessageConverters(converters);
		
		converters.add(new SymmetryHttpMessageConverter<>(new HtmlComponentReflector()));
	}