added WebSocketClientGoneException when client is gone

gradle.properties

@@ -1,4 +1,4 @@
-version = 1.1.0
+version = 1.1.0.1
 micronautVersion = 1.1.0
 gruVersion = 0.8.0
 druVersion = 0.6.0

micronaut-aws-sdk/src/main/groovy/com/agorapulse/micronaut/aws/apigateway/ws/DefaultMessageSender.java

@@ -63,6 +63,9 @@ public void send(String connectionId, InputStream payload) {
             .errorResponseHandler(new HttpResponseHandler<AmazonClientException>() {
                 @Override
                 public AmazonClientException handle(HttpResponse response) throws Exception {
+                    if (response.getStatusCode() == 410) {
+                        return new WebSocketClientGoneException("WebSocket client with id " + connectionId + " is already gone");
+                    }
                     return new AmazonClientException("Exception publishing messages to WS endpoint "
                         + " POST " + url + " "
                         + response.getStatusCode() + ": "

micronaut-aws-sdk/src/main/groovy/com/agorapulse/micronaut/aws/apigateway/ws/WebSocketClientGoneException.java

@@ -0,0 +1,19 @@
+package com.agorapulse.micronaut.aws.apigateway.ws;
+
+import com.amazonaws.AmazonClientException;
+
+public class WebSocketClientGoneException extends AmazonClientException {
+
+    public WebSocketClientGoneException(String message, Throwable t) {
+        super(message, t);
+    }
+
+    public WebSocketClientGoneException(String message) {
+        super(message);
+    }
+
+    public WebSocketClientGoneException(Throwable t) {
+        super(t);
+    }
+
+}

micronaut-aws-sdk/src/test/groovy/com/agorapulse/micronaut/aws/apigateway/ws/MessageSenderSpec.groovy

@@ -57,6 +57,20 @@ class MessageSenderSpec extends Specification {
             MessageSender defaultSender = ctx.getBean(MessageSender)
         when:
             defaultSender.send(CONNECTION_ID, PAYLOAD)
+        then:
+            thrown(WebSocketClientGoneException)
+    }
+
+    void 'test forbidden'() {
+        given:
+            prepareServerAndContext {
+                header('Authorization', Matchers.iterableWithSize(1))
+                called(1)
+                responds().code(403).body('Forbidden', ContentType.TEXT_PLAIN)
+            }
+            MessageSender defaultSender = ctx.getBean(MessageSender)
+        when:
+            defaultSender.send(CONNECTION_ID, PAYLOAD)
         then:
             thrown(AmazonClientException)
     }