@ProviderType
public static interface SolaceProperties.PublisherProperties
MessagePublisher
instances.
The properties are for use with implementation of MessagePublisherBuilder.fromProperties(Properties)
.
Example usage:
final Properties publisherProperties = new Properties();
publisherProperties.setProperty(PublisherProperties.PUBLISHER_BACK_PRESSURE_STRATEGY, PublisherConstants.PUBLISHER_BACK_PRESSURE_STRATEGY_ELASTIC);
publisherProperties.setProperty(PublisherProperties.PUBLISHER_BACK_PRESSURE_BUFFER_CAPACITY, "1000");
final MessagingService service = new MessagingServiceClientBuilder(ConfigurationProfile.V1).build();
final DirectMessagePublisherBuilder messagePublisherBuilder = service.createDirectMessagePublisherBuilder();
final MessagePublisher publisher = messagePublisherBuilder.fromProperties(publisherProperties).build();
MessagePublisherBuilder.fromProperties(Properties)
Modifier and Type | Field and Description |
---|---|
static String |
PUBLISHER_BACK_PRESSURE_BUFFER_CAPACITY
A property key to define back pressure buffer capacity measured in messages.
|
static String |
PUBLISHER_BACK_PRESSURE_STRATEGY
A property key to define a back-pressure strategy.
|
@PropertiesKey(target=MessagePublisher.class, valueType=int.class) static final String PUBLISHER_BACK_PRESSURE_BUFFER_CAPACITY
SolaceConstants.PublisherConstants.PUBLISHER_BACK_PRESSURE_STRATEGY_BUFFER_REJECT_WHEN_FULL
and
SolaceConstants.PublisherConstants.PUBLISHER_BACK_PRESSURE_STRATEGY_BUFFER_WAIT_WHEN_FULL
.@PropertiesKey(target=MessagePublisher.class, valueType=java.lang.String.class) static final String PUBLISHER_BACK_PRESSURE_STRATEGY
SolaceConstants.PublisherConstants.PUBLISHER_BACK_PRESSURE_STRATEGY_ELASTIC
,
SolaceConstants.PublisherConstants.PUBLISHER_BACK_PRESSURE_STRATEGY_BUFFER_REJECT_WHEN_FULL
,
and SolaceConstants.PublisherConstants.PUBLISHER_BACK_PRESSURE_STRATEGY_BUFFER_WAIT_WHEN_FULL
.Copyright 2019-2024 Solace Corporation. All rights reserved.