public static void main(String[] args) throws Exception {
        AmazonSQSAsync sqsClient = AmazonSQSAsyncClientBuilder.standard()
                .withCredentials(new DefaultAWSCredentialsProviderChain())
                .withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(SQSConfig.serviceEndpoint, "us-east-1"))
                .build();
        SQSConnectionFactory connectionFactory = new SQSConnectionFactory(new ProviderConfiguration(), sqsClient);

        MessageListener messageListener = new ReceiverCallback();
        DefaultMessageListenerContainer listenerContainer = new DefaultMessageListenerContainer();
        listenerContainer.setConnectionFactory(connectionFactory);
        listenerContainer.setDestinationName(SQSConfig.queueName);

        listenerContainer.setSessionTransacted(false);
        listenerContainer.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);

        listenerContainer.setMessageListener(messageListener);
        listenerContainer.setConcurrentConsumers(5); 
        listenerContainer.setAutoStartup(true);
        listenerContainer.initialize();
        listenerContainer.start();
    }

    public static class ReceiverCallback implements MessageListener {
        // Used to listen for message silence
        private final Map<String, List<String>> messageGroups = new ConcurrentHashMap<>();

        @Override
        public void onMessage(Message message) {
            try {
                String groupId = message.getStringProperty("JMSXGroupID");
                System.out.println(String.format("%s %s receive,Group ID: %s, start..",
                        Thread.currentThread().getName(),
                        System.currentTimeMillis(), groupId));
                Thread.sleep(50000);
                message.acknowledge();

                System.out.println(String.format("%s %s receive,Group ID: %s ,done",
                        Thread.currentThread().getName(),
                        System.currentTimeMillis(), groupId));
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }