Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/aws-samples/amazon-dynamodb-implementing-priority-queuing
/ functions
Functions
261 in github.com/aws-samples/amazon-dynamodb-implementing-priority-queuing
⨍
Functions
261
◇
Types & classes
35
↓ 1 callers
Method
setCreationTimestamp
@param creationTimestamp the creationTimestamp to set
src/main/java/com/awsblog/queueing/model/SystemInfo.java:64
↓ 1 callers
Method
setDequeuedShipmentObject
@param dequeuedShipmentObject the dequeuedShipmentObject to set
src/main/java/com/awsblog/queueing/model/DequeueResult.java:66
↓ 1 callers
Method
setFirst100IDsInQueue
@param first100iDsInQueue the first100IDsInQueue to set
src/main/java/com/awsblog/queueing/model/DLQResult.java:61
↓ 1 callers
Method
setFirst100IDsInQueue
@param first100iDsInQueue the first100IDsInQueue to set
src/main/java/com/awsblog/queueing/model/QueueStats.java:86
↓ 1 callers
Method
setFirst100SelectedIDsInQueue
@param first100SelectedIDsInQueue the first100SelectedIDsInQueue to set
src/main/java/com/awsblog/queueing/model/QueueStats.java:100
↓ 1 callers
Method
setInQueue
@param inQueue the inQueue to set
src/main/java/com/awsblog/queueing/model/SystemInfo.java:101
↓ 1 callers
Method
setPeekedShipmentObject
@param peekedShipmentObject the peekedShipmentObject to set
src/main/java/com/awsblog/queueing/model/PeekResult.java:45
↓ 1 callers
Method
setSelectedFromQueue
@param selectedFromQueue the selectedFromQueue to set
src/main/java/com/awsblog/queueing/model/SystemInfo.java:117
↓ 1 callers
Method
setShipment
@param shipment the shipment to set
src/main/java/com/awsblog/queueing/model/EnqueueResult.java:43
↓ 1 callers
Method
setSystemInfo
@param systemInfo the systemInfo to set
src/main/java/com/awsblog/queueing/appdata/Shipment.java:89
↓ 1 callers
Method
setTimestampMillisUTC
@param timestampMillisUTC the timestampMillisUTC to set
src/main/java/com/awsblog/queueing/model/PeekResult.java:59
↓ 1 callers
Method
setTotalRecordsInProcessing
@param totalRecordsInProcessing the totalRecordsInProcessing to set
src/main/java/com/awsblog/queueing/model/QueueStats.java:60
↓ 1 callers
Method
setTotalRecordsInQueue
@param totalRecordsInDLQ the totalRecordsInDLQ to set
src/main/java/com/awsblog/queueing/model/DLQResult.java:47
↓ 1 callers
Method
setTotalRecordsInQueue
@param totalRecordsInQueue the totalRecordsInQueue to set
src/main/java/com/awsblog/queueing/model/QueueStats.java:48
↓ 1 callers
Method
setTotalRecordsNotStarted
@param totalRecordsNotStarted the totalRecordsNotStarted to set
src/main/java/com/awsblog/queueing/model/QueueStats.java:72
↓ 1 callers
Method
shutdown
This method should be called at the end of the SDK usage
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1119
↓ 1 callers
Method
sleep
Sleep (parameter - sleep time in milliseconds) @param seconds
src/main/java/com/awsblog/queueing/utils/Utils.java:344
↓ 1 callers
Method
sleepInSeconds
Sleep (parameter - sleep time in seconds) @param seconds
src/main/java/com/awsblog/queueing/utils/Utils.java:361
Method
Builder
Default constructor
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1178
Method
CommandLineUtils
C-tor @param argv
src/main/java/com/awsblog/queueing/utils/CommandLineUtils.java:20
Method
ConfigField
C-tor
src/main/java/com/awsblog/queueing/config/ConfigField.java:19
Method
ConfigIndex
C-tor
src/main/java/com/awsblog/queueing/config/ConfigIndex.java:19
Method
ConfigLambda
C-tor
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:19
Method
ConfigTable
C-tor
src/main/java/com/awsblog/queueing/config/ConfigTable.java:21
Method
Configuration
C-tor
src/main/java/com/awsblog/queueing/config/Configuration.java:33
Method
Constants
()
src/main/java/com/awsblog/queueing/Constants.java:12
Method
DLQResult
C-tor @param BAN
src/main/java/com/awsblog/queueing/model/DLQResult.java:25
Method
DequeueResult
Default empty c-tor
src/main/java/com/awsblog/queueing/model/DequeueResult.java:22
Method
DynamoStack
C-tor @param parent @param id @param jsonMetaLocation @param jsonConfigLocation
src/main/java/com/awsblog/queueing/cdk/DynamoStack.java:37
Method
EnqueueResult
Default empty c-tor
src/main/java/com/awsblog/queueing/model/EnqueueResult.java:20
Method
FileUtils
Hide constructor
src/main/java/com/awsblog/queueing/utils/FileUtils.java:24
Method
LambdaStack
C-tor @param parent @param id @param jsonMetaLocation @param jsonConfigLocation
src/main/java/com/awsblog/queueing/cdk/LambdaStack.java:39
Method
PeekResult
Default empty c-tor
src/main/java/com/awsblog/queueing/model/PeekResult.java:22
Method
QueueSdkClient
Private constructor using Builder @param builder Builder object reference
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:73
Method
QueueStats
C-tor @param id
src/main/java/com/awsblog/queueing/model/QueueStats.java:25
Method
ReturnResult
Default empty c-tor @param id
src/main/java/com/awsblog/queueing/model/ReturnResult.java:21
Method
RoleStack
C-tor @param parent @param id @param props @param config @param roles
src/main/java/com/awsblog/queueing/cdk/RoleStack.java:37
Method
Shipment
C-tor
src/main/java/com/awsblog/queueing/appdata/Shipment.java:28
Method
ShipmentData
C-tor
src/main/java/com/awsblog/queueing/appdata/ShipmentData.java:26
Method
ShipmentItem
C-tor
src/main/java/com/awsblog/queueing/appdata/ShipmentItem.java:25
Method
SystemInfo
Default C-tor
src/main/java/com/awsblog/queueing/model/SystemInfo.java:29
Method
assertValue
Assert on the value @param condition @param exceptionMessage
src/main/java/com/awsblog/queueing/utils/Utils.java:176
Method
checkIfNullOrEmptyCollection
Check if collection is NULL or empty @param c @return
src/main/java/com/awsblog/queueing/utils/Utils.java:196
Method
cleanUFT8_BOM
Remove special characters due to UTF8 BOM @param s @return
src/main/java/com/awsblog/queueing/utils/Utils.java:207
Method
compareValues
Compare the values @param val1 @param val2 @param percentAllowed @return
src/main/java/com/awsblog/queueing/utils/Utils.java:48
Method
copyJARsToS3
Copy the JAR file to S3 @param s3 @param config
src/main/java/com/awsblog/queueing/cdk/CDK_App.java:115
Method
createObjectFromJson
Create a RFM_QueueDepthResult object from JSON
src/main/java/com/awsblog/queueing/model/DLQResult.java:32
Method
createObjectFromJson
Create a RFM_QueueDepthResult object from JSON
src/main/java/com/awsblog/queueing/model/QueueStats.java:33
Method
dequeue
dequeue() logic It peeks the record from the queue, it locks it for the short time and removes from the queue @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:676
Method
doesFileExists
Check if the file exists @param filePath @return
src/main/java/com/awsblog/queueing/utils/FileUtils.java:34
Method
getAWSCredentials
Get the AWSCredentials object reference @return AWSCredentials
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1097
Method
getActualTableName
@return the actualTableName
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1105
Method
getAddToDlqTimestamp
@return the addToDlqTimestamp
src/main/java/com/awsblog/queueing/model/SystemInfo.java:200
Method
getAddToQueueTimestamp
@return the addToQueueTimestamp
src/main/java/com/awsblog/queueing/model/SystemInfo.java:125
Method
getAwsCredentialsProfileName
Get the AWS Credential's Profile name @return the awsCredentialsProfileName
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1087
Method
getAwsRegion
Get the AWS Region @return the awsRegion
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1077
Method
getConfig
@return the config
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1112
Method
getConfigLambdaInfoByDeploymentName
Get the Lambda config info by the deployment name @param lambdaName @return
src/main/java/com/awsblog/queueing/config/Configuration.java:231
Method
getConfigLambdaInfoByLogicalName
Get configuration lambda info Lambda's full Java class name has to be provided. @param lambdaClassName @return ConfigLambdaInfo
src/main/java/com/awsblog/queueing/config/Configuration.java:218
Method
getConfigTableInfo
Retrieve the DynamoDB configuration info by provided domain object name @param domainObjectName @return ConfigTableInfo
src/main/java/com/awsblog/queueing/config/Configuration.java:204
Method
getCreationTimestamp
@return the creationTimestamp
src/main/java/com/awsblog/queueing/model/SystemInfo.java:57
Method
getData1
@return the data1
src/main/java/com/awsblog/queueing/appdata/ShipmentData.java:62
Method
getData2
@return the data2
src/main/java/com/awsblog/queueing/appdata/ShipmentData.java:77
Method
getData3
@return the data3
src/main/java/com/awsblog/queueing/appdata/ShipmentData.java:92
Method
getDeploymentLambdaNames
Get the deployment lambda names @return
src/main/java/com/awsblog/queueing/config/Configuration.java:191
Method
getDequeuedShipmentObject
@return the dequeuedShipmentObject
src/main/java/com/awsblog/queueing/model/DequeueResult.java:59
Method
getDynamoDB
@return the dynamoDB
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1054
Method
getErrorMessage
Get the error message @return
src/main/java/com/awsblog/queueing/model/ReturnStatusEnum.java:30
Method
getErrorMessage
Get the error message @return
src/main/java/com/awsblog/queueing/model/ReturnResult.java:56
Method
getFileContentAsByteArray
Retrieve file content as a String with provided file name @param fileName file name for the file content to be retrieved from @return content of the
src/main/java/com/awsblog/queueing/utils/FileUtils.java:82
Method
getFileContentAsString
Retrieve file content as a String with provided file name @param fileName file name for the file content to be retrieved from @return content of the
src/main/java/com/awsblog/queueing/utils/FileUtils.java:49
Method
getFirst100IDsInQueue
@return the first100IDsInQueue
src/main/java/com/awsblog/queueing/model/DLQResult.java:54
Method
getFirst100IDsInQueue
@return the first100IDsInQueue
src/main/java/com/awsblog/queueing/model/QueueStats.java:79
Method
getFirst100SelectedIDsInQueue
@return the first100SelectedIDsInQueue
src/main/java/com/awsblog/queueing/model/QueueStats.java:93
Method
getId
@return the id
src/main/java/com/awsblog/queueing/appdata/ShipmentData.java:46
Method
getId
@return the Id
src/main/java/com/awsblog/queueing/model/ReturnResult.java:77
Method
getLastUpdatedDate
@return the lastUpdatedDate
src/main/java/com/awsblog/queueing/config/Configuration.java:107
Method
getLastUpdatedTimestamp
@return the lastUpdatedTimestamp
src/main/java/com/awsblog/queueing/model/ReturnResult.java:64
Method
getLocalDateTimeInUTC
Get the UTC time as LocalDateTime @return
src/main/java/com/awsblog/queueing/utils/Utils.java:333
Method
getLogicalLambdaNames
Get the logical lambda names @return
src/main/java/com/awsblog/queueing/config/Configuration.java:179
Method
getLogicalName
@return the logicalName
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:111
Method
getPeekFromQueueTimestamp
@return the peekFromQueueTimestamp
src/main/java/com/awsblog/queueing/model/SystemInfo.java:140
Method
getPeekedShipmentId
Get the peeked shipment id @return
src/main/java/com/awsblog/queueing/model/DequeueResult.java:75
Method
getReadCapacity
@return the readCapacity
src/main/java/com/awsblog/queueing/config/ConfigTable.java:53
Method
getRemoveFromQueueTimestamp
@return the removeFromQueueTimestamp
src/main/java/com/awsblog/queueing/model/SystemInfo.java:155
Method
getS3
@return the s3
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1068
Method
getSKU
@return the sKU
src/main/java/com/awsblog/queueing/appdata/ShipmentItem.java:44
Method
getSns
@return the SNS
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1061
Method
getSortKey
@return the sortKey
src/main/java/com/awsblog/queueing/config/ConfigTable.java:95
Method
getStatus
@return the status
src/main/java/com/awsblog/queueing/model/ReturnResult.java:98
Method
getTimestampMillisUTC
@return the timestampMillisUTC
src/main/java/com/awsblog/queueing/model/PeekResult.java:52
Method
getTotalRecordsInDLQ
@return the totalRecordsInDLQ
src/main/java/com/awsblog/queueing/model/DLQResult.java:41
Method
getVersion
@return the version
src/main/java/com/awsblog/queueing/model/ReturnResult.java:112
Method
getVersion
@return the version
src/main/java/com/awsblog/queueing/config/Configuration.java:93
Method
getWriteCapacity
@return the writeCapacity
src/main/java/com/awsblog/queueing/config/ConfigTable.java:67
Method
isGsi
@return the gsi
src/main/java/com/awsblog/queueing/config/ConfigIndex.java:95
Method
isPacked
@return the packed
src/main/java/com/awsblog/queueing/appdata/ShipmentItem.java:60
Method
isQueued
@return the isQueued
src/main/java/com/awsblog/queueing/appdata/Shipment.java:104
Method
isSelectedFromQueue
@return the selectedFromQueue
src/main/java/com/awsblog/queueing/model/SystemInfo.java:108
Method
main
Main method @param args
src/main/java/com/awsblog/queueing/cli/CLI.java:39
← previous
next →
101–200 of 261, ranked by callers