search

TheClimateCorporation / squeedo

clojure core.async based amazon SQS message processing
Apache License 2.0
62 stars 28 forks source link

Unable to execute HTTP request: peer not authenticated #21

Open tfendt opened 8 years ago

tfendt commented 8 years ago

We are getting the following randomly:

[async-dispatch-6] INFO  com.amazonaws.http.AmazonHttpClient - Unable to execute HTTP request: peer not authenticated
javax.net.ssl.SSLPeerUnverifiedException: peer not authenticated
        at sun.security.ssl.SSLSessionImpl.getPeerCertificates(SSLSessionImpl.java:431)
        at org.apache.http.conn.ssl.AbstractVerifier.verify(AbstractVerifier.java:128)
        at org.apache.http.conn.ssl.SSLSocketFactory.connectSocket(SSLSocketFactory.java:572)
        at org.apache.http.impl.conn.DefaultClientConnectionOperator.openConnection(DefaultClientConnectionOperator.java:180)
        at org.apache.http.impl.conn.ManagedClientConnectionImpl.open(ManagedClientConnectionImpl.java:294)
        at org.apache.http.impl.client.DefaultRequestDirector.tryConnect(DefaultRequestDirector.java:641)
        at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:480)
        at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:906)
        at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:805)
        at com.amazonaws.http.AmazonHttpClient.executeHelper(AmazonHttpClient.java:402)
        at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:245)
        at com.amazonaws.services.sqs.AmazonSQSClient.invoke(AmazonSQSClient.java:2221)
        at com.amazonaws.services.sqs.AmazonSQSClient.deleteMessage(AmazonSQSClient.java:1270)
        at cemerick.bandalore$delete.invoke(bandalore.clj:186)
        at cemerick.bandalore$delete.invoke(bandalore.clj:182)
        at com.climate.squeedo.sqs$ack.invoke(sqs.clj:251)
        at com.climate.squeedo.sqs_consumer$create_workers$fn__6056$state_machine__3971__auto____6057$fn__6059$inst_6044__6087$state_machine__3971__auto____6088$fn__6090.invoke(sqs_consumer.clj:66)
        at com.climate.squeedo.sqs_consumer$create_workers$fn__6056$state_machine__3971__auto____6057$fn__6059$inst_6044__6087$state_machine__3971__auto____6088.invoke(sqs_consumer.clj:58)
        at clojure.core.async.impl.ioc_macros$run_state_machine.invoke(ioc_macros.clj:1011)
        at clojure.core.async.impl.ioc_macros$run_state_machine_wrapped.invoke(ioc_macros.clj:1015)
        at com.climate.squeedo.sqs_consumer$create_workers$fn__6056$state_machine__3971__auto____6057$fn__6059$inst_6044__6087.invoke(sqs_consumer.clj:58)
        at clojure.lang.AFn.run(AFn.java:22)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)

Our code:

(defn -main []
  (let [environment (keyword (env :profile))
        client (sqs/create-client (config environment :amazon :amazonAccessKey) (config environment :amazon :amazonSecretKey))
        queue (config environment :audit)]
    (print-banner environment)
    (createdb environment)
    (let [consumer (start-consumer queue handle-message! :client client :max-concurrent-work 100 :num-listeners 80 )]
      (infinite-loop #(do (Thread/sleep 10000))))))

Are we using the lib correctly or are we missing something?