public boolean sendTableSchemaToSQSQueue()

in src/main/java/software/aws/glue/tableversions/utils/SQSUtil.java [25:46]

• 22 lines of code
• 3 McCabe index (conditional complexity)

	public boolean sendTableSchemaToSQSQueue(AmazonSQS sqs, String queueURI, String message, long executionBatchId,
			String databaseName) {
		int statusCode = 400;
		boolean messageSentToSQS = false;
		Map<String, MessageAttributeValue> messageAttributes = new HashMap<>();
		messageAttributes.put("ExecutionBatchId", new MessageAttributeValue().withDataType("String.ExecutionBatchId")
				.withStringValue(Long.toString(executionBatchId)));
		SendMessageRequest req = new SendMessageRequest().withQueueUrl(queueURI).withMessageBody(message)
				.withMessageGroupId(databaseName).withMessageAttributes(messageAttributes);
		try {
			SendMessageResult sendMsgRes = sqs.sendMessage(req);
			statusCode = sendMsgRes.getSdkHttpMetadata().getHttpStatusCode();
		} catch (Exception e) {
			e.printStackTrace();
			System.out.println("Exception thrown while writing message to SQS. " + e.getLocalizedMessage());
		}
		if (statusCode == 200) {
			messageSentToSQS = true;
		} else
			System.out.printf("Cannot write Table schema %s to SQS queue. \n", message);
		return messageSentToSQS;
	}