Skip to content
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -98,16 +98,16 @@ public CreateQueueOptions(QueueProperties queue) {
this.duplicateDetectionHistoryTimeWindow = queue.getDuplicateDetectionHistoryTimeWindow() != null
? queue.getDuplicateDetectionHistoryTimeWindow()
: DEFAULT_DUPLICATE_DETECTION_DURATION;
this.enableBatchedOperations = queue.enableBatchedOperations();
this.enablePartitioning = queue.enablePartitioning();
this.enableBatchedOperations = queue.isBatchedOperationsEnabled();
this.enablePartitioning = queue.isPartitioningEnabled();
this.forwardTo = queue.getForwardTo();
this.forwardDeadLetteredMessagesTo = queue.getForwardDeadLetteredMessagesTo();
this.lockDuration = queue.getLockDuration();

this.maxDeliveryCount = queue.getMaxDeliveryCount();
this.maxSizeInMegabytes = queue.getMaxSizeInMegabytes();
this.requiresDuplicateDetection = queue.requiresDuplicateDetection();
this.requiresSession = queue.requiresSession();
this.requiresDuplicateDetection = queue.isDuplicateDetectionRequired();
this.requiresSession = queue.isSessionRequired();
this.status = queue.getStatus();
this.userMetadata = queue.getUserMetadata();
}
Expand Down Expand Up @@ -175,7 +175,7 @@ public CreateQueueOptions setDefaultMessageTimeToLive(Duration defaultMessageTim
*
* @return the deadLetteringOnMessageExpiration value.
*/
public boolean deadLetteringOnMessageExpiration() {
public boolean isDeadLetteringOnMessageExpiration() {
return this.deadLetteringOnMessageExpiration;
}

Expand Down Expand Up @@ -221,7 +221,7 @@ public CreateQueueOptions setDuplicateDetectionHistoryTimeWindow(Duration duplic
*
* @return the enableBatchedOperations value.
*/
public boolean enableBatchedOperations() {
public boolean isBatchedOperationsEnabled() {
return this.enableBatchedOperations;
}

Expand All @@ -244,7 +244,7 @@ public CreateQueueOptions setEnableBatchedOperations(boolean enableBatchedOperat
*
* @return the enablePartitioning value.
*/
public boolean enablePartitioning() {
public boolean isPartitioningEnabled() {
return this.enablePartitioning;
}

Expand Down Expand Up @@ -383,7 +383,7 @@ public CreateQueueOptions setMaxSizeInMegabytes(int maxSizeInMegabytes) {
*
* @return the requiresDuplicateDetection value.
*/
public boolean requiresDuplicateDetection() {
public boolean isDuplicateDetectionRequired() {
return this.requiresDuplicateDetection;
}

Expand All @@ -404,7 +404,7 @@ public CreateQueueOptions setRequiresDuplicateDetection(boolean requiresDuplicat
*
* @return the requiresSession value.
*/
public boolean requiresSession() {
public boolean isSessionRequired() {
return this.requiresSession;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -76,15 +76,15 @@ public CreateSubscriptionOptions(SubscriptionProperties subscription) {
Objects.requireNonNull(subscription, "'subscription' cannot be null.");

this.autoDeleteOnIdle = subscription.getAutoDeleteOnIdle();
this.deadLetteringOnMessageExpiration = subscription.deadLetteringOnMessageExpiration();
this.deadLetteringOnFilterEvaluationExceptions = subscription.enableDeadLetteringOnFilterEvaluationExceptions();
this.deadLetteringOnMessageExpiration = subscription.isDeadLetteringOnMessageExpiration();
this.deadLetteringOnFilterEvaluationExceptions = subscription.isDeadLetteringOnFilterEvaluationExceptions();
this.defaultMessageTimeToLive = subscription.getDefaultMessageTimeToLive();
this.enableBatchedOperations = subscription.enableBatchedOperations();
this.enableBatchedOperations = subscription.isBatchedOperationsEnabled();
this.forwardTo = subscription.getForwardTo();
this.forwardDeadLetteredMessagesTo = subscription.getForwardDeadLetteredMessagesTo();
this.lockDuration = subscription.getLockDuration();
this.maxDeliveryCount = subscription.getMaxDeliveryCount();
this.requiresSession = subscription.requiresSession();
this.requiresSession = subscription.isSessionRequired();
this.status = subscription.getStatus();
this.userMetadata = subscription.getUserMetadata();
}
Expand Down Expand Up @@ -119,7 +119,7 @@ public CreateSubscriptionOptions setLockDuration(Duration lockDuration) {
*
* @return the requiresSession value.
*/
public boolean requiresSession() {
public boolean isSessionRequired() {
return this.requiresSession;
}

Expand Down Expand Up @@ -166,7 +166,7 @@ public CreateSubscriptionOptions setDefaultMessageTimeToLive(Duration defaultMes
*
* @return the deadLetteringOnMessageExpiration value.
*/
public boolean deadLetteringOnMessageExpiration() {
public boolean isDeadLetteringOnMessageExpiration() {
return this.deadLetteringOnMessageExpiration;
}

Expand All @@ -189,7 +189,7 @@ public CreateSubscriptionOptions setDeadLetteringOnMessageExpiration(boolean dea
*
* @return the deadLetteringOnFilterEvaluationExceptions value.
*/
public boolean enableDeadLetteringOnFilterEvaluationExceptions() {
public boolean isDeadLetteringOnFilterEvaluationExceptions() {
return this.deadLetteringOnFilterEvaluationExceptions;
}

Expand Down Expand Up @@ -236,7 +236,7 @@ public CreateSubscriptionOptions setMaxDeliveryCount(int maxDeliveryCount) {
*
* @return the enableBatchedOperations value.
*/
public boolean enableBatchedOperations() {
public boolean isBatchedOperationsEnabled() {
return this.enableBatchedOperations;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -89,11 +89,11 @@ public CreateTopicOptions(TopicProperties topic) {
this.autoDeleteOnIdle = topic.getAutoDeleteOnIdle();
this.defaultMessageTimeToLive = topic.getDefaultMessageTimeToLive();
this.duplicateDetectionHistoryTimeWindow = topic.getDuplicateDetectionHistoryTimeWindow();
this.enableBatchedOperations = topic.enableBatchedOperations();
this.enablePartitioning = topic.enablePartitioning();
this.enableBatchedOperations = topic.isBatchedOperationsEnabled();
this.enablePartitioning = topic.isPartitioningEnabled();
this.maxSizeInMegabytes = topic.getMaxSizeInMegabytes();
this.requiresDuplicateDetection = topic.requiresDuplicateDetection();
this.supportOrdering = topic.supportOrdering();
this.requiresDuplicateDetection = topic.isDuplicateDetectionRequired();
this.supportOrdering = topic.isOrderingSupported();
this.status = topic.getStatus();
this.userMetadata = topic.getUserMetadata();
}
Expand Down Expand Up @@ -184,7 +184,7 @@ public CreateTopicOptions setDuplicateDetectionHistoryTimeWindow(Duration duplic
*
* @return the enableBatchedOperations value.
*/
public Boolean enableBatchedOperations() {
public Boolean isBatchedOperationsEnabled() {
return this.enableBatchedOperations;
}

Expand All @@ -207,7 +207,7 @@ public CreateTopicOptions setEnableBatchedOperations(boolean enableBatchedOperat
*
* @return the enablePartitioning value.
*/
public Boolean enablePartitioning() {
public Boolean isPartitioningEnabled() {
return this.enablePartitioning;
}

Expand Down Expand Up @@ -344,7 +344,7 @@ public CreateTopicOptions setMaxSizeInMegabytes(long maxSizeInMegabytes) {
*
* @return the requiresDuplicateDetection value.
*/
public Boolean requiresDuplicateDetection() {
public Boolean isDuplicateDetectionRequired() {
return this.requiresDuplicateDetection;
}

Expand All @@ -365,7 +365,7 @@ public CreateTopicOptions setRequiresDuplicateDetection(boolean requiresDuplicat
*
* @return the requiresSession value.
*/
public Boolean requiresSession() {
public Boolean isSessionRequired() {
return this.requiresSession;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@ public QueueDescription toImplementation(QueueProperties queue, List<Authorizati
.setDeadLetteringOnMessageExpiration(queue.isDeadLetteringOnMessageExpiration())
.setDefaultMessageTimeToLive(queue.getDefaultMessageTimeToLive())
.setDuplicateDetectionHistoryTimeWindow(queue.getDuplicateDetectionHistoryTimeWindow())
.setEnablePartitioning(queue.enablePartitioning())
.setEnablePartitioning(queue.isPartitioningEnabled())
.setEnableExpress(queue.enableExpress)
.setEnableBatchedOperations(queue.enableBatchedOperations)
.setEntityAvailabilityStatus(queue.entityAvailabilityStatus)
Expand All @@ -79,8 +79,8 @@ public QueueDescription toImplementation(QueueProperties queue, List<Authorizati
.setSupportOrdering(queue.supportOrdering)
.setStatus(queue.getStatus())
.setSizeInBytes(queue.getSizeInBytes())
.setRequiresSession(queue.requiresSession())
.setRequiresDuplicateDetection(queue.requiresDuplicateDetection())
.setRequiresSession(queue.isSessionRequired())
.setRequiresDuplicateDetection(queue.isDuplicateDetectionRequired())
.setUpdatedAt(queue.getUpdatedAt())
.setUserMetadata(queue.getUserMetadata());

Expand Down Expand Up @@ -261,7 +261,7 @@ public QueueProperties setDuplicateDetectionHistoryTimeWindow(Duration duplicate
*
* @return the enableBatchedOperations value.
*/
public boolean enableBatchedOperations() {
public boolean isBatchedOperationsEnabled() {
return this.enableBatchedOperations;
}

Expand All @@ -284,7 +284,7 @@ public QueueProperties setEnableBatchedOperations(boolean enableBatchedOperation
*
* @return the enablePartitioning value.
*/
public boolean enablePartitioning() {
public boolean isPartitioningEnabled() {
return this.enablePartitioning;
}

Expand Down Expand Up @@ -409,7 +409,7 @@ public QueueProperties setMaxSizeInMegabytes(Integer maxSizeInMegabytes) {
*
* @return the requiresDuplicateDetection value.
*/
public boolean requiresDuplicateDetection() {
public boolean isDuplicateDetectionRequired() {
return this.requiresDuplicateDetection;
}

Expand All @@ -418,7 +418,7 @@ public boolean requiresDuplicateDetection() {
*
* @return the requiresSession value.
*/
public boolean requiresSession() {
public boolean isSessionRequired() {
return this.requiresSession;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -132,7 +132,7 @@ public RuleActionImpl toImplementation(RuleAction model) {
final SqlRuleActionImpl returned = new SqlRuleActionImpl()
.setSqlExpression(action.getSqlExpression())
.setCompatibilityLevel(action.getCompatibilityLevel())
.setRequiresPreprocessing(action.getRequiresPreprocessing());
.setRequiresPreprocessing(action.isPreprocessingRequired());

if (!action.getProperties().isEmpty()) {
final List<KeyValueImpl> parameters = action.getProperties().entrySet().stream()
Expand Down Expand Up @@ -183,7 +183,7 @@ public RuleFilterImpl toImplementation(RuleFilter model) {
final SqlFilterImpl returned = new SqlFilterImpl()
.setSqlExpression(filter.getSqlExpression())
.setCompatibilityLevel(filter.getCompatibilityLevel())
.setRequiresPreprocessing(filter.getRequiresPreprocessing());
.setRequiresPreprocessing(filter.isPreprocessingRequired());

if (!filter.getProperties().isEmpty()) {
final List<KeyValueImpl> parameters = filter.getProperties().entrySet()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ String getCompatibilityLevel() {
*
* @return Whether or not requires preprocessing.
*/
Boolean getRequiresPreprocessing() {
Boolean isPreprocessingRequired() {
return requiresPreprocessing;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ String getCompatibilityLevel() {
*
* @return Whether or not requires preprocessing.
*/
Boolean getRequiresPreprocessing() {
Boolean isPreprocessingRequired() {
return requiresPreprocessing;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,8 +53,8 @@ public SubscriptionDescription toImplementation(SubscriptionProperties subscript
.setAutoDeleteOnIdle(subscription.getAutoDeleteOnIdle())
.setCreatedAt(subscription.getCreatedAt())
.setDeadLetteringOnFilterEvaluationExceptions(
subscription.enableDeadLetteringOnFilterEvaluationExceptions())
.setDeadLetteringOnMessageExpiration(subscription.deadLetteringOnMessageExpiration())
subscription.isDeadLetteringOnFilterEvaluationExceptions())
.setDeadLetteringOnMessageExpiration(subscription.isDeadLetteringOnMessageExpiration())
.setDefaultMessageTimeToLive(subscription.getDefaultMessageTimeToLive())
.setEnableBatchedOperations(subscription.enableBatchedOperations)
.setEntityAvailabilityStatus(subscription.entityAvailabilityStatus)
Expand All @@ -65,7 +65,7 @@ public SubscriptionDescription toImplementation(SubscriptionProperties subscript
.setMessageCount(subscription.messageCount)
.setMessageCountDetails(subscription.getMessageCountDetails())
.setStatus(subscription.getStatus())
.setRequiresSession(subscription.requiresSession())
.setRequiresSession(subscription.isSessionRequired())
.setUpdatedAt(subscription.getUpdatedAt())
.setUserMetadata(subscription.getUserMetadata());
}
Expand Down Expand Up @@ -181,7 +181,7 @@ public SubscriptionProperties setLockDuration(Duration lockDuration) {
*
* @return the requiresSession value.
*/
public boolean requiresSession() {
public boolean isSessionRequired() {
return this.requiresSession;
}

Expand Down Expand Up @@ -215,7 +215,7 @@ public SubscriptionProperties setDefaultMessageTimeToLive(Duration defaultMessag
*
* @return the deadLetteringOnMessageExpiration value.
*/
public boolean deadLetteringOnMessageExpiration() {
public boolean isDeadLetteringOnMessageExpiration() {
return this.deadLetteringOnMessageExpiration;
}

Expand All @@ -237,7 +237,7 @@ public SubscriptionProperties setDeadLetteringOnMessageExpiration(boolean deadLe
*
* @return the deadLetteringOnFilterEvaluationExceptions value.
*/
public boolean enableDeadLetteringOnFilterEvaluationExceptions() {
public boolean isDeadLetteringOnFilterEvaluationExceptions() {
return this.deadLetteringOnFilterEvaluationExceptions;
}

Expand Down Expand Up @@ -302,7 +302,7 @@ public SubscriptionProperties setMaxDeliveryCount(int maxDeliveryCount) {
*
* @return the enableBatchedOperations value.
*/
public boolean enableBatchedOperations() {
public boolean isBatchedOperationsEnabled() {
return this.enableBatchedOperations;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ public TopicDescription toImplementation(TopicProperties topic, List<Authorizati
.setCreatedAt(topic.getCreatedAt())
.setDefaultMessageTimeToLive(topic.getDefaultMessageTimeToLive())
.setDuplicateDetectionHistoryTimeWindow(topic.getDuplicateDetectionHistoryTimeWindow())
.setEnablePartitioning(topic.enablePartitioning())
.setEnablePartitioning(topic.isPartitioningEnabled())
.setEnableSubscriptionPartitioning(topic.isEnableSubscriptionPartitioning())
.setEnableExpress(topic.enableExpress)
.setEnableBatchedOperations(topic.enableBatchedOperations)
Expand All @@ -76,7 +76,7 @@ public TopicDescription toImplementation(TopicProperties topic, List<Authorizati
.setSubscriptionCount(topic.getSubscriptionCount())
.setStatus(topic.getStatus())
.setSizeInBytes(topic.getSizeInBytes())
.setRequiresDuplicateDetection(topic.requiresDuplicateDetection())
.setRequiresDuplicateDetection(topic.isDuplicateDetectionRequired())
.setUpdatedAt(topic.getUpdatedAt())
.setUserMetadata(topic.getUserMetadata());

Expand Down Expand Up @@ -199,7 +199,7 @@ public TopicProperties setMaxSizeInMegabytes(long maxSizeInMegabytes) {
*
* @return the requiresDuplicateDetection value.
*/
public boolean requiresDuplicateDetection() {
public boolean isDuplicateDetectionRequired() {
return this.requiresDuplicateDetection;
}

Expand Down Expand Up @@ -242,7 +242,7 @@ public TopicProperties setDuplicateDetectionHistoryTimeWindow(Duration duplicate
*
* @return the enableBatchedOperations value.
*/
public boolean enableBatchedOperations() {
public boolean isBatchedOperationsEnabled() {
return this.enableBatchedOperations;
}

Expand Down Expand Up @@ -280,7 +280,7 @@ public TopicProperties setStatus(EntityStatus status) {
*
* @return the supportOrdering value.
*/
public boolean supportOrdering() {
public boolean isOrderingSupported() {
return this.supportOrdering;
}

Expand Down Expand Up @@ -323,7 +323,7 @@ public TopicProperties setAutoDeleteOnIdle(Duration autoDeleteOnIdle) {
*
* @return the enablePartitioning value.
*/
public boolean enablePartitioning() {
public boolean isPartitioningEnabled() {
return this.enablePartitioning;
}

Expand Down
Loading