diff --git a/src/main/java/org/gcube/event/publisher/AbstractHTTPWithJWTTokenAuthEventSender.java b/src/main/java/org/gcube/event/publisher/AbstractHTTPWithJWTTokenAuthEventSender.java index 121ecc1..08266ec 100644 --- a/src/main/java/org/gcube/event/publisher/AbstractHTTPWithJWTTokenAuthEventSender.java +++ b/src/main/java/org/gcube/event/publisher/AbstractHTTPWithJWTTokenAuthEventSender.java @@ -35,18 +35,34 @@ public abstract class AbstractHTTPWithJWTTokenAuthEventSender implements EventSe this.clientId = clientId; this.clientSecret = clientSecret; this.tokenURL = tokenURL; - connectionTimeout = getConnectionTimeout(); - readTimeout = getReadTimeout(); + connectionTimeout = getDefaultConnectionTimeout(); + readTimeout = getDefaultReadTimeout(); } - protected int getReadTimeout() { + protected int getDefaultReadTimeout() { return HTTPVerb.DEFAULT_READ_TIMEOUT; } - protected int getConnectionTimeout() { + protected int getDefaultConnectionTimeout() { return HTTPVerb.DEFAULT_CONNECTION_TIMEOUT; } + public int getReadTimeout() { + return readTimeout; + } + + public void setReadTimeout(int readTimeout) { + this.readTimeout = readTimeout; + } + + public int getConnectionTimeout() { + return connectionTimeout; + } + + public void setConnectionTimeout(int connectionTimeout) { + this.connectionTimeout = connectionTimeout; + } + @Override public void send(Event event) { log.debug("Starting HTTP POST thread to: {}", baseEndpointURL);