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
↓ 66 callers
Method
get
Get the Shipment object/record from DynamoDB @param id @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:276
↓ 60 callers
Method
toJSON
Convert an Object to JSON (Object should be properly annotated)
src/main/java/com/awsblog/queueing/utils/Utils.java:23
↓ 51 callers
Method
checkIfNullObject
Check if the object is NULL @param o @return
src/main/java/com/awsblog/queueing/utils/Utils.java:86
↓ 27 callers
Method
setReturnValue
@param status the status to set
src/main/java/com/awsblog/queueing/model/ReturnResult.java:91
↓ 25 callers
Method
build
Create a QueueSDK @return QueueSdkClient
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1187
↓ 25 callers
Method
put
Put the new object into DynamoDB - replaces values, if there is already data with the same primary key @param shipment
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:292
↓ 24 callers
Method
getQueueStats
Get the queue depth statistics @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:154
↓ 23 callers
Method
getId
@return the id
src/main/java/com/awsblog/queueing/appdata/Shipment.java:52
↓ 20 callers
Method
getSystemInfo
@return the systemInfo
src/main/java/com/awsblog/queueing/appdata/Shipment.java:96
↓ 19 callers
Method
toString
toString
src/main/java/com/awsblog/queueing/model/DLQResult.java:68
↓ 14 callers
Method
withRegion
Specify AWS region If not used, default value is 'us-east-1'. @param region Proper AWS Region string @return Builder
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1221
↓ 13 callers
Method
checkIfNullOrEmptyString
Check if the string is Null or Empty @param strToValidate @return
src/main/java/com/awsblog/queueing/utils/Utils.java:76
↓ 10 callers
Method
throwIfNullOrEmptyString
Throw exception if this an empty String @param strToValidate @param exceptionMessage
src/main/java/com/awsblog/queueing/utils/Utils.java:146
↓ 9 callers
Method
peek
Peek the record from the queue @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:527
↓ 9 callers
Method
setStatus
@param status the status to set
src/main/java/com/awsblog/queueing/model/SystemInfo.java:186
↓ 8 callers
Method
enqueue
enqueue() the record into the queue @param id @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:435
↓ 8 callers
Method
getAttributeType
@return the attributeType
src/main/java/com/awsblog/queueing/config/ConfigField.java:40
↓ 8 callers
Method
getSortKey
@return the sortKey
src/main/java/com/awsblog/queueing/config/ConfigIndex.java:81
↓ 8 callers
Method
getVersion
@return the version
src/main/java/com/awsblog/queueing/model/SystemInfo.java:84
↓ 8 callers
Method
setData
@param data the data to set
src/main/java/com/awsblog/queueing/appdata/Shipment.java:146
↓ 8 callers
Method
setData1
@param data1 the data1 to set
src/main/java/com/awsblog/queueing/appdata/ShipmentData.java:70
↓ 8 callers
Method
setData2
@param data2 the data2 to set
src/main/java/com/awsblog/queueing/appdata/ShipmentData.java:85
↓ 8 callers
Method
setData3
@param data3 the data3 to set
src/main/java/com/awsblog/queueing/appdata/ShipmentData.java:100
↓ 8 callers
Method
setItems
@param items the items to set
src/main/java/com/awsblog/queueing/appdata/ShipmentData.java:115
↓ 8 callers
Method
updateStatus
Method for changing the status of the record This call should not be used unless there are operational issues and there are live issues that needs to
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:353
↓ 8 callers
Method
withCredentialsProfileName
Specify local credential profile @param profile This is the name of the local AWS Credential profile @return Builder
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1233
↓ 7 callers
Method
checkIfNotNullAndNotEmptyString
Check if not NULL and not Empty string @param strToValidate @return
src/main/java/com/awsblog/queueing/utils/Utils.java:136
↓ 7 callers
Method
delete
Delete the shipment record from DynamoDB by shipment ID @param ID
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1019
↓ 7 callers
Method
getPeekedShipmentId
Get the peeked shipment id @return
src/main/java/com/awsblog/queueing/model/PeekResult.java:68
↓ 6 callers
Method
getLambdaDeploymentName
@return the lambdaDeploymentName
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:38
↓ 6 callers
Method
getLogicalName
@return the logicalName
src/main/java/com/awsblog/queueing/config/ConfigTable.java:28
↓ 6 callers
Method
getStatus
@return the status
src/main/java/com/awsblog/queueing/model/SystemInfo.java:177
↓ 6 callers
Method
isSuccessful
Was it successful? @return
src/main/java/com/awsblog/queueing/model/ReturnResult.java:47
↓ 6 callers
Method
setLastUpdatedTimestamp
@param lastUpdatedTimestamp the lastUpdatedTimestamp to set
src/main/java/com/awsblog/queueing/model/ReturnResult.java:70
↓ 6 callers
Method
setStatus
@param status the status to set
src/main/java/com/awsblog/queueing/model/ReturnResult.java:105
↓ 6 callers
Method
setVersion
@param version the version to set
src/main/java/com/awsblog/queueing/model/ReturnResult.java:118
↓ 6 callers
Method
withCredentials
Provide the AWS Credentials @param awsCredentials User's provided AWSCredential @return Builder
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1271
↓ 5 callers
Method
getTableName
@return the tableName
src/main/java/com/awsblog/queueing/config/ConfigTable.java:40
↓ 5 callers
Method
setVersion
@param version the version to set
src/main/java/com/awsblog/queueing/model/SystemInfo.java:224
↓ 5 callers
Method
throwIfNullObject
Throw exception if the object is NULL @param o @param exceptionMessage
src/main/java/com/awsblog/queueing/utils/Utils.java:106
↓ 4 callers
Method
checkIfNotNullObject
Check if the object is NOT NULL @param o @return
src/main/java/com/awsblog/queueing/utils/Utils.java:96
↓ 4 callers
Method
createTestData
Create the test data @param ID @return Shipment
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:1032
↓ 4 callers
Method
getAttributeName
@return the attributeName
src/main/java/com/awsblog/queueing/config/ConfigField.java:26
↓ 4 callers
Method
getLambdas
@return the lambdas
src/main/java/com/awsblog/queueing/config/Configuration.java:163
↓ 4 callers
Method
getPartitionKey
@return the partitionKey
src/main/java/com/awsblog/queueing/config/ConfigTable.java:81
↓ 4 callers
Method
getReadCapacity
@return the readCapacity
src/main/java/com/awsblog/queueing/config/ConfigIndex.java:39
↓ 4 callers
Method
getWriteCapacity
@return the writeCapacity
src/main/java/com/awsblog/queueing/config/ConfigIndex.java:53
↓ 4 callers
Method
throwIfConditionIsTrue
Throw exception if the passed condition is TRUE @param condition @param exceptionMessage
src/main/java/com/awsblog/queueing/utils/Utils.java:156
↓ 3 callers
Method
fromJSON
Create a Configuration object from JSON @param jsonPayload @return
src/main/java/com/awsblog/queueing/config/Configuration.java:47
↓ 3 callers
Method
getFileFromResourcesAsString
Retrieve the resource content as a String with provided resource name @param resourceFileName resource file name for the file content to be retrieved
src/main/java/com/awsblog/queueing/utils/FileUtils.java:116
↓ 3 callers
Method
getHashKey
@return the hashKey
src/main/java/com/awsblog/queueing/config/ConfigIndex.java:67
↓ 3 callers
Method
getId
@return the ID
src/main/java/com/awsblog/queueing/model/SystemInfo.java:215
↓ 3 callers
Method
getItems
@return the items
src/main/java/com/awsblog/queueing/appdata/ShipmentData.java:107
↓ 3 callers
Method
getLocalJarPath
@return the localJarPath
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:74
↓ 3 callers
Method
getPeekedShipmentObject
@return the peekedShipmentObject
src/main/java/com/awsblog/queueing/model/PeekResult.java:38
↓ 3 callers
Method
getS3CodeBucket
@return the s3CodeBucket
src/main/java/com/awsblog/queueing/config/Configuration.java:135
↓ 3 callers
Method
getTables
@return the tables
src/main/java/com/awsblog/queueing/config/Configuration.java:121
↓ 3 callers
Method
getTablesMap
@return the tablesMap
src/main/java/com/awsblog/queueing/config/Configuration.java:149
↓ 3 callers
Method
remove
Acknowledge that the account is processed and that can be removed from the queue queued = 0 (and REMOVE), queue_selected = false @param id @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:709
↓ 3 callers
Method
resetSystemInfo
Reset the data inside the Shipment's system info object
src/main/java/com/awsblog/queueing/appdata/Shipment.java:130
↓ 3 callers
Method
setId
@param id the id to set
src/main/java/com/awsblog/queueing/appdata/Shipment.java:61
↓ 3 callers
Method
setLastUpdatedTimestamp
@param lastUpdatedTimestamp the lastUpdatedTimestamp to set
src/main/java/com/awsblog/queueing/appdata/Shipment.java:123
↓ 3 callers
Method
toString
toString()
src/main/java/com/awsblog/queueing/utils/CommandLineUtils.java:133
↓ 2 callers
Method
checkIfNotNullAndNotEmptyCollection
Check if collection exists and it is not empty @param c @return
src/main/java/com/awsblog/queueing/utils/Utils.java:185
↓ 2 callers
Method
containsOption
Check if the options map contains provided option key @param optionKey @return
src/main/java/com/awsblog/queueing/utils/CommandLineUtils.java:79
↓ 2 callers
Method
fromReturnResult
Get the values from ReturnResult object @param result @return
src/main/java/com/awsblog/queueing/model/DequeueResult.java:43
↓ 2 callers
Method
getClassName
@return the className
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:26
↓ 2 callers
Method
getJarNameFromLocalPath
Get the JAR name @param localJarPath @return
src/main/java/com/awsblog/queueing/cdk/LambdaStack.java:105
↓ 2 callers
Method
getLastUpdatedTimestamp
@return the lastUpdatedTimestamp
src/main/java/com/awsblog/queueing/appdata/Shipment.java:115
↓ 2 callers
Method
getName
@return the name
src/main/java/com/awsblog/queueing/config/ConfigIndex.java:26
↓ 2 callers
Method
getOptionValue
Get the option's value from the Options Map @param optionKey @return options's value
src/main/java/com/awsblog/queueing/utils/CommandLineUtils.java:92
↓ 2 callers
Method
getShipment
@return the shipment
src/main/java/com/awsblog/queueing/model/EnqueueResult.java:36
↓ 2 callers
Method
loadConfiguration
Load the Configuration from JSON definition @return
src/main/java/com/awsblog/queueing/config/Configuration.java:81
↓ 2 callers
Method
nullOrEmpty
Check if NULL or EMPTY string @param strToValidate @return
src/main/java/com/awsblog/queueing/utils/Utils.java:66
↓ 2 callers
Method
putImpl
Put/Replace the new object into DynamoDB @param shipment
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:312
↓ 2 callers
Method
removeLeadingDashes
Remove the leading dashes @param s @return
src/main/java/com/awsblog/queueing/utils/CommandLineUtils.java:105
↓ 2 callers
Method
setLastUpdatedTimestamp
@param lastUpdatedTimestamp the lastUpdatedTimestamp to set
src/main/java/com/awsblog/queueing/model/SystemInfo.java:77
↓ 1 callers
Method
getDLQStats
Retrieve DLQ information @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:222
↓ 1 callers
Method
getData
@return the data
src/main/java/com/awsblog/queueing/appdata/Shipment.java:138
↓ 1 callers
Method
getDescription
@return the description
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:86
↓ 1 callers
Method
getHandler
@return the handler
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:62
↓ 1 callers
Method
getIndexes
@return the indexes
src/main/java/com/awsblog/queueing/config/ConfigTable.java:109
↓ 1 callers
Method
getLambdaRuntime
Get the proper Lambda Runtime environment @param runtime @return
src/main/java/com/awsblog/queueing/cdk/LambdaStack.java:121
↓ 1 callers
Method
getLambdasMap
@return the lambdasMap
src/main/java/com/awsblog/queueing/config/Configuration.java:156
↓ 1 callers
Method
getLastUpdatedTimestamp
@return the lastUpdatedTimestamp
src/main/java/com/awsblog/queueing/model/SystemInfo.java:70
↓ 1 callers
Method
getMemoryInMegabytes
@return the memoryInMegabytes
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:98
↓ 1 callers
Method
getReturnValue
@return the status
src/main/java/com/awsblog/queueing/model/ReturnResult.java:84
↓ 1 callers
Method
getRuntime
@return the runtime
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:50
↓ 1 callers
Method
getTimeoutInSeconds
@return the timeoutInSeconds
src/main/java/com/awsblog/queueing/config/ConfigLambda.java:125
↓ 1 callers
Method
getTotalRecordsInProcessing
@return the totalRecordsInProcessing
src/main/java/com/awsblog/queueing/model/QueueStats.java:54
↓ 1 callers
Method
getTotalRecordsInQueue
@return the totalRecordsInQueue
src/main/java/com/awsblog/queueing/model/QueueStats.java:42
↓ 1 callers
Method
getTotalRecordsNotStarted
@return the totalRecordsNotStarted
src/main/java/com/awsblog/queueing/model/QueueStats.java:66
↓ 1 callers
Method
initialize
Part of the fluid API chaining. Once all parameters are set with .with(...) methods, build() method needs to be called. No other client call can be us
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:88
↓ 1 callers
Method
isInQueue
@return the inQueue
src/main/java/com/awsblog/queueing/model/SystemInfo.java:93
↓ 1 callers
Method
listExtendedIDs
Get the first 'size' items form the Shipment table @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:996
↓ 1 callers
Method
listIDs
Get the first 'size' items form the Shipment table @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:973
↓ 1 callers
Method
markAsReadyForShipment
Mark the object as read for Show
src/main/java/com/awsblog/queueing/appdata/Shipment.java:81
↓ 1 callers
Method
parse
Parse the command line arguments @param argv
src/main/java/com/awsblog/queueing/utils/CommandLineUtils.java:32
↓ 1 callers
Method
restore
Put back the record in the queue @param id @return
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:775
↓ 1 callers
Method
sendToDLQ
Send the problematic record to DLQ @param id @return ReturnResult
src/main/java/com/awsblog/queueing/sdk/QueueSdkClient.java:844
next →
1–100 of 261, ranked by callers