@Override
public long getOperationTimeoutInSeconds() {
- return context.getOperationTimeoutInSeconds();
+ return TimeUnit.MILLISECONDS.toSeconds(context.getOperationTimeoutInMillis());
}
@Override
public int getMaxShardDataStoreExecutorQueueSize() {
return context.getDataStoreProperties().getMaxDataStoreExecutorQueueSize();
}
+
+ @Override
+ public int getMaximumMessageSliceSize() {
+ return context.getMaximumMessageSliceSize();
+ }
}