add ssl connection test (#244)

* add ssl connection test
* add keystore

Makefile

@@ -9,6 +9,23 @@ appendonly no
 requirepass passwd
 endef
 
+# STANDALONE REDIS NODE WITH SSL
+define REDIS_STANDALONE_NODE_CONF_SSL
+daemonize yes
+port 0
+pidfile /tmp/redis_standalone_node__ssl_for_spark-redis.pid
+logfile /tmp/redis_standalone_node_ssl_for_spark-redis.log
+save ""
+appendonly no
+requirepass passwd
+tls-auth-clients no
+tls-port 6380
+tls-cert-file ./src/test/resources/tls/redis.crt
+tls-key-file ./src/test/resources/tls/redis.key
+tls-ca-cert-file ./src/test/resources/tls/ca.crt
+tls-dh-params-file ./src/test/resources/tls/redis.dh
+endef
+
 # CLUSTER REDIS NODES
 define REDIS_CLUSTER_NODE1_CONF
 daemonize yes
@@ -44,12 +61,14 @@ cluster-config-file /tmp/redis_cluster_node3_for_spark-redis.conf
 endef
 
 export REDIS_STANDALONE_NODE_CONF
+export REDIS_STANDALONE_NODE_CONF_SSL
 export REDIS_CLUSTER_NODE1_CONF
 export REDIS_CLUSTER_NODE2_CONF
 export REDIS_CLUSTER_NODE3_CONF
 
 start-standalone:
 	echo "$$REDIS_STANDALONE_NODE_CONF" | redis-server -
+	echo "$$REDIS_STANDALONE_NODE_CONF_SSL" | redis-server -
 
 
 start-cluster:
@@ -72,7 +91,8 @@ start:
 
 stop-standalone:
 	kill `cat /tmp/redis_standalone_node_for_spark-redis.pid`
-
+	kill `cat /tmp/redis_standalone_node__ssl_for_spark-redis.pid`
+
 stop-cluster:
 	kill `cat /tmp/redis_cluster_node1_for_spark-redis.pid` || true
 	kill `cat /tmp/redis_cluster_node2_for_spark-redis.pid` || true
@@ -93,7 +113,7 @@ test:
 	make start
 	# with --batch-mode maven doesn't print 'Progress: 125/150kB', the progress lines take up 90% of the log and causes
 	# Travis build to fail with 'The job exceeded the maximum log length, and has been terminated'
-	mvn clean test -B
+	mvn clean test -B  -DargLine="-Djavax.net.ssl.trustStorePassword=password -Djavax.net.ssl.trustStore=./src/test/resources/tls/clientkeystore -Djavax.net.ssl.trustStoreType=jceks"
 	make stop
 
 benchmark:

pom.xml

@@ -226,7 +226,7 @@
 					<reportsDirectory>${project.build.directory}/surefire-reports</reportsDirectory>
 					<junitxml>.</junitxml>
 					<filereports>WDF TestSuite.txt</filereports>
-					<argLine>-XX:MaxPermSize=256m -Xmx2g</argLine>
+					<argLine>-XX:MaxPermSize=256m -Xmx2g -Djavax.net.ssl.trustStorePassword=password -Djavax.net.ssl.trustStore=./src/test/resources/tls/clientkeystore -Djavax.net.ssl.trustStoreType=jceks</argLine>
 					<tagsToExclude>com.redislabs.provider.redis.util.BenchmarkTest</tagsToExclude>
 				</configuration>
 				<executions>

src/test/resources/tls/ca.crt

@@ -0,0 +1,31 @@
+-----BEGIN CERTIFICATE-----
+MIIFSzCCAzOgAwIBAgIUHs81ch3cj/DaaUu/xeRpJtCvq3MwDQYJKoZIhvcNAQEL
+BQAwNTETMBEGA1UECgwKUmVkaXMgVGVzdDEeMBwGA1UEAwwVQ2VydGlmaWNhdGUg
+QXV0aG9yaXR5MB4XDTIwMDUxNzE1MDUwMVoXDTMwMDUxNTE1MDUwMVowNTETMBEG
+A1UECgwKUmVkaXMgVGVzdDEeMBwGA1UEAwwVQ2VydGlmaWNhdGUgQXV0aG9yaXR5
+MIICIjANBgkqhkiG9w0BAQEFAAOCAg8AMIICCgKCAgEAvBUjUWX3xDaFoRtmZUiH
+hv3HBtzQAUbpOMGqBUdm6F0/X2wa+bnmSOeAZoYuI7L2N3eBNZ6Vcd/rc0nP+PoL
+M3L0fDPpNtrAgxFiLzCTLdsC4AYfSt3DOIURoMCYBdKvy62IaCanrnQElIzk41hI
+NhWV1L1MXU3uaTw3xNXMX0pKp/Td6PYTTM4pZSDnXIzltpgOx4YXg/0MrWOLR9nS
+95rv2the61zbMzf1OScOzncQcXwNAEbCvUPH5OwStNznPAxhLqhLuIJ05kKaon5U
+y9qQFQvbMNOuXy8Fi/yTL4ZV9EkUyWOM7iqmCHTU5VU92FkZB+glIfk5Y5DmDe5a
+Wsk4/BeDZdZgZShX41Dl12G5cQCErvxKmb0g41GJDwEBj4MZ3U8pJKJWj3vQC76V
+yTsHtrTJ5maM/ctGE7IrQfIJwrDIqU/tixkLuete8CWt8X96iwjBbpHQ0J1TCB11
+WDK0wTgvCOjwjvhDA7D3Bvj65BpS+BnhuC/v/julfrV5rFCiyDeWjY//od6bo1HU
+gHbJncdys5AlZs/FZpBmKC0Isa6JhNGE6SAZlmjn1euH8besA/qzResK+XOtTNr5
+pNQIA9L+Jfu66puViK8fnZb53NgG3YqbEuivUHXALbMj60JPVkwS2ZdDxY9iNvig
+W1RY6wv+cs5726AUKJqin18CAwEAAaNTMFEwHQYDVR0OBBYEFAFmv2JPj3Pkt7Gs
+ofrJ3JqLcVe5MB8GA1UdIwQYMBaAFAFmv2JPj3Pkt7GsofrJ3JqLcVe5MA8GA1Ud
+EwEB/wQFMAMBAf8wDQYJKoZIhvcNAQELBQADggIBALdXNzliM8y02M5kktG7a4U/
+3aAMGfa8+FimQPrBOSpRBoq39lf3sIcVMYe8HiSZoynVChR5pkPdR0a66X89UUNL
+EljZ7LX1oMG4hYnKq0tzu797DIAIY0fLyLbI8LnOcGFijRwtGIH/5YMLrgOwPBbD
+llWteVMywMhovon3nPM1S78T0cILZ6QeuoKrM8JpRhit4EWfAdcmRWqYfWtmY6eW
+SH4D0PQaJpDs9fsOYp0CwAMmDPQeM0EbVSe2Dl0kJh4rS2kYlCxN/ZhIv6qdgXv/
+4SAnBX5Cay+IDEuaeVn7rRuCVpouzMjA27ucZ3V56JjcL8HzB9iqzB/tnLMnzZmq
+/DlwrQTVDJEExXGtUDcI+cgNpH9jqD4akFTvVggRFjv70JWj3dXHgz4x2iAy7O/x
+d2IHI6WFVq7760EoQBTVyyJ/S2w8UVzHKAk8DMU+Y89jsUA0EPp/j7DiEeXSBWz+
+ivk35QXE16kGOmDPgF2SzCHKoTEheQQyJRd2UFNNY37X6ROMlHaeoXVZ13cMENPr
+DNbB9h6Wi3lqP3WGteAk5uKQSZq8Q+/NgElnWls71MFKxzsIysH0nxkjbTmmZxxP
+C9UH611jVgWZKth4a846lDruS9lUecz8f2vfiNZbDzXVdXxfhVA5VlGyRDlZq0xM
+zSJm5Tn0Q1Tz4b+PMEFz
+-----END CERTIFICATE-----

src/test/resources/tls/ca.key

@@ -0,0 +1,51 @@
+-----BEGIN RSA PRIVATE KEY-----
+MIIJKAIBAAKCAgEAvBUjUWX3xDaFoRtmZUiHhv3HBtzQAUbpOMGqBUdm6F0/X2wa
++bnmSOeAZoYuI7L2N3eBNZ6Vcd/rc0nP+PoLM3L0fDPpNtrAgxFiLzCTLdsC4AYf
+St3DOIURoMCYBdKvy62IaCanrnQElIzk41hINhWV1L1MXU3uaTw3xNXMX0pKp/Td
+6PYTTM4pZSDnXIzltpgOx4YXg/0MrWOLR9nS95rv2the61zbMzf1OScOzncQcXwN
+AEbCvUPH5OwStNznPAxhLqhLuIJ05kKaon5Uy9qQFQvbMNOuXy8Fi/yTL4ZV9EkU
+yWOM7iqmCHTU5VU92FkZB+glIfk5Y5DmDe5aWsk4/BeDZdZgZShX41Dl12G5cQCE
+rvxKmb0g41GJDwEBj4MZ3U8pJKJWj3vQC76VyTsHtrTJ5maM/ctGE7IrQfIJwrDI
+qU/tixkLuete8CWt8X96iwjBbpHQ0J1TCB11WDK0wTgvCOjwjvhDA7D3Bvj65BpS
++BnhuC/v/julfrV5rFCiyDeWjY//od6bo1HUgHbJncdys5AlZs/FZpBmKC0Isa6J
+hNGE6SAZlmjn1euH8besA/qzResK+XOtTNr5pNQIA9L+Jfu66puViK8fnZb53NgG
+3YqbEuivUHXALbMj60JPVkwS2ZdDxY9iNvigW1RY6wv+cs5726AUKJqin18CAwEA
+AQKCAgBq3Auj7K43wc5seXfU5b9yl+8jXAOmJhbN02J4+1dhf9FIstAkwFUxaK5Q
+Eb5XNA+l9fTodQBtoY5Rg0dxKweAJLj5dDj1nJWyIgdJzmxgqkVY6MGQtKx9CUW5
+spLtBAYzT5XnrsaoXGxZxi8pZ/gnGl51b1Pa0zM4gSkiYWJrZXdDM+F8wYq3oY5t
+UaOBtt+wvXXwMKRdrkEsphj1KrItUc8i5LoROUGlOQ7PePx1m7ow8A0m8g0koUUK
+MIJ0Vene+R2h96aF30DxrjfTSLl+1N/1xTW06R/yHnIlVcx+PPHLCFaSEUh57KtG
+tLJc1fB8YirRjjjCs6nCgwniMmEMqFNpf00YQQ9hwLl9tsc8gQKxx6EWvJt5ymOL
+jbOyHCOEu7pmEhwNo3+6UKUMpvMZGf9obsfA1aXrilobmuxGlM954C2LMlH+zuMJ
+p5sCbUvOtECcP/vKUACXkvcvseB4kfyDBEdRNYUIK9uIsdWnjJWA10WMszU6T4fH
+t8mePAatQsQhcHiT45vGBuVY9WixBECizK/eDuOtuxQGE4OycrYtSc77WOv2benx
++E6RVoQkPt9mDpk06O23vM+asu3rrGoXogZcJVQf/3mjNbyEf1s3o0nY7DTov8Is
+Il7AkDJ7XcU61mzRSz4zEZm2LFc0ydsxB/gQnSmrfwEl9+egeQKCAQEA31mkcehv
+v4tgzEuJR9s2tRD4kI4U9IV5K+mz+7E0nrgU17devVWHnnNmSiSZOCYliiAlZJJq
+Le1pxzZyLv1SWvhBML7Jxqe63+uFbd3AaOUUK3/f1+KyrgZKoHfxadDdMhve0Zeo
+xVW3pBjpNTG3Z71FGI+X8yHMlxugQrQDZDMB4sHqRBmfsQ9HiHxNjew86UbDAmbu
+5LHyovmtcYpBL07lsEIIpgnHF4B2cmvpn9TBams2L25/9WPwzCLRCZmltwyhLiHK
+Jrtjj7T3+VdxKCq/W94lCu+yVt4QiKd7R06u8VfbsLtOMdLjMsilTEI8HxnALHIC
+pRvtDlS5hrFvIwKCAQEA15OwNYARf+/DVu5vORYLpRECliDzYho9dwE6c267VF4A
+r+MasHnDLQiAbnjQ41KMxK5gVvJCz2Dxfy25Y9RAa/6Z4BN5r+rMQ4k2wvQwR0q1
+56oPT6S2L016rlQN35vNA5njXV6KloeniGQSYAGOVjWdi0P6NPDSBdC/vdIYlZ3c
+0l8KSthHNqYWwwfbZrVyKtjH9rOKNg0OcYzMvSK+wt6LibNbTorqhg4fLycwIFkj
+ZZZMUb1o6nZN571dKE7rz+Qx3P9MLeEqBuiuI/Wvpdx0BTM7RAAS4ayJXukA+KiO
+bPjuq5jxn7uaMY4xKkA7+wGyVdDl24R2ZGTqHfZQlQKCAQBdMRkVUie2Y2B7PZVF
+PylfeXpNTotdz4dUlEm93h2XkDVaIK/ODi7tJTdr/kNUE06ciHcxtInLKgF11rjj
+9Fz1ihohTaoBUqD9p1bgFaOf4N1+nPd4K6XkSMnAlOtM/JIew1RAXahU1kQumxpL
+ULg299kpu1hqYRLtheBjlJrJpyLFS6YEzjA8f6SYRU1Sx1xO9XCOwwYwtDMKX2VI
+N6ilJaVe2t6i8Pd6TeaeLXqobuxZC+zq848+g3nIo0pXWB219/YUupKPgKa1IoxJ
+JHwZh2Sa32DTZFokNrntWvxsL199YexPnIeu8FBOMzwNSqGtVGBD6zpBTBqoXR+g
+HM7DAoIBAQCIihVQPXZYBt89XzV4/bqQaQ6vUd11ZFNL3a5M0HS8AfIDdR9BaU2y
+ZzEZR1JeuLlKFXwVdcnVGXy75ZUHYrcO76o8X3lyb4/CstTJc+pkLTC7s12RPyzZ
+FwS+B6Tl3QNj5YM5bxjuMKtu2ps8zZ9+gOTxATQndeRAJLBdJQXHNb5YTDPzpbqt
+JVNDYeWXzxKpirZUTfEbPPfJ+bjvjmMuf8/3fm81dw0FrUoZDoQP6QVfYWujVglu
+f1Hmlmy7jAkVml3usJBqerOovpUVV5ZRwiiF5qYB8t4Cq8oyH/gqhm/3G0/nxa48
+UpFeE8aWESssVy3B5ta/S83E1pnmMk1lAoIBACRQMEkyv3vIQZmMQzcsg0Y4FX+R
+f7lZ80rKbwYpwAKM4xHHXkj46jGBj0ZGHRNIR0BQqOksF8Sg29fjlXFA5G8yMlU/
+hHFEfsY4dSS1VfmGoFr2kSYKJszlcybOeEM0ceuSNafZ+5X59g86g+iHZ9TsJ6ly
+F+cNYLIyVVCcaNB8YYiU9J20aMlzI+7Pr1ohesyb/7DwYMC78HzJO/AgvJNI477E
+lO/+5Ou1nJDDWRqncfOZGtnYaz6vGjVV3yWwSnVyksgyoGgExXb8+ItU5xwJValS
+lnkqM7ADuldyO61e7ctxJzOI9YWceYrDN38XV889umYWHB812rdBXmgGPvg=
+-----END RSA PRIVATE KEY-----

src/test/resources/tls/ca.txt

@@ -0,0 +1 @@
+7161BDE3516329B98ECE89BD1B3A84A165B36131

src/test/resources/tls/client.csr

@@ -0,0 +1,25 @@
+-----BEGIN NEW CERTIFICATE REQUEST-----
+MIIEPzCCA+kCAQAwbDEQMA4GA1UEBhMHVW5rbm93bjEQMA4GA1UECBMHVW5rbm93
+bjEQMA4GA1UEBxMHVW5rbm93bjEOMAwGA1UEChMFcmVkaXMxDjAMBgNVBAsTBXJl
+ZGlzMRQwEgYDVQQDEwtyZWRpcyByZWRpczCCA0IwggI1BgcqhkjOOAQBMIICKAKC
+AQEAj3k12bmq6b+r7Yh6z0lRtvMuxZ47rzcY6OrElh8+/TYG50NRqcQYMzm4CefC
+rhxTm6dHW4XQEa24tHmHdUmEaVysDo8UszYIKKIv+icRCj1iqZNFNAmg/mlsRlj4
+S90ggZw3CaAQV7GVrc0AIz26VIS2KR+dZI74g0SGd5ec7AS0NKasLnXpmF3iPbAp
+L8ERjJ/6nYGB5zONt5K3MNe540lZL2gJmHIVORXqPWuLRlPGM0WPgDsypMLg8nKQ
+JW5OP4o7CDihxFDk4YwaKaN9316hQ95LZv8EkD7VzxYj4VjUh8YI6X8hHNgdyiPL
+bjgHZfgi40K+SEwFdjk5YBzWZwIdALr2lqaFePff3uf6Z8l3x4XvMrIzuuWAwLzV
+aV0CggEAFqZcWCBIUHBOdQKjl1cEDTTaOjR4wVTU5KXALSQu4E+W5h5L0JBKvayP
+N+6x4J8xgtI8kEPLZC+IAEFg7fnKCbMgdqecMqYn8kc+kYebosTnRL0ggVRMtVuA
+LDaNH6g+1InpTg+gaI4yQopceMR4xo0FJ7ccmjq7CwvhLERoljnn08502xAaZaor
+h/ZMaCbbPscvS1WZg0u07bAvfJDppJbTpV1TW+v8RdT2GfY/Pe27hzklwvIk4Hcx
+KW2oh+weR0j4fvtf3rdUhDFrIjLe5VPdrwIRKw0fAtowlzIk/ieu2oudSyki2bqL
+457Z4QOmPFKBC8aIt+LtQxbh7xfb3gOCAQUAAoIBABhNEA7ZsggSRP9+M+YZPxsG
+HqXC+JUDPxFdt8G6LwXiLMSrDK7PRwWGY+srFpk/9XbHloJFUNMy7mTs44FikjRk
+Ckv9RdYxySWVe6DB8pZfRMBtwpL8EVB5H3zLzwl4bo7aSwqIGcW9vbLf9lDiAJr1
+tLPB7u00PYLmhLBpxsjt3IASQU7eQoHbKU1fqVFC0owPLV7eDMWXtDXW15CqcNVM
+RYH89GF1FVft5cyc+ezRtBumVTWfkfiypXKNemMtz8nG4XPafM4t/cwL32jeqNfj
+D+49rJCszRcbeWW38UUZUvrR0Pg4d/zMjweuFtxYvltOg5YQkCQ+GB4EAdpeEO2g
+MDAuBgkqhkiG9w0BCQ4xITAfMB0GA1UdDgQWBBRRT1L9TaDwnVyuQBHSRIfqwU6h
+TzANBglghkgBZQMEAwIFAANBADA+Ah0Ak8JdJGCo3g5GLlnJlf4b1wwYuLY5r26a
+apTxzwIdAKF297kB9IeY0JVbHKQcwyWAJzOtQO82mKCHrIo=
+-----END NEW CERTIFICATE REQUEST-----

src/test/resources/tls/redis.crt

@@ -0,0 +1,23 @@
+-----BEGIN CERTIFICATE-----
+MIID4jCCAcoCFHFhveNRYym5js6JvRs6hKFls2ExMA0GCSqGSIb3DQEBCwUAMDUx
+EzARBgNVBAoMClJlZGlzIFRlc3QxHjAcBgNVBAMMFUNlcnRpZmljYXRlIEF1dGhv
+cml0eTAeFw0yMDA1MTcxNTA1MDFaFw0yMTA1MTcxNTA1MDFaMCYxEzARBgNVBAoM
+ClJlZGlzIFRlc3QxDzANBgNVBAMMBlNlcnZlcjCCASIwDQYJKoZIhvcNAQEBBQAD
+ggEPADCCAQoCggEBANd6DHmb4xtWSej6EOHHNHP/zSVuQ3jYUqTzc5s1oWrmDyro
+rk3rnRBo1l9X6n9EESaMZyZxJFkrgnMlYNbZjy7KgKpGPP1BLDwyeBo6pYg8MRZK
+0Kd0GaFqHk1WpboC9qKyhyWiD/C18+6Aq6Vm5ZcfnScanJ1WbmGZt+6NtGTOBDWu
+BGfCzCx/6oIkDvlebycFs7JuL1uxIaZYKfUG2bPWkVpbtbNcune6A2pTtsfMdx8U
+qWOW087uco3Q8QEa+rwLCDzhT6NywllGHN5ua5CgGdrYWFeH5lAuiNxvWbCaN9v8
+ua6+/xalOGewPixQbSgF6K0grjjg/jSdyt53BH0CAwEAATANBgkqhkiG9w0BAQsF
+AAOCAgEAmFgZAW4De4ushRBrzSIRa5n8Q8Nkn8DcS0ludeFLiV49gyXD9b0Nnw8w
+Ct+qxMMiVoWXqUUJWkfhcGQ/FbBZnDLsh3ZSHlyaMB+dXbmC5SJB9IlJsvEwjmN9
+RBEJ5VUwEc+OMb6w0CnG9tr//b1N5+iwvmdfapJcTradMwOe02ZJhD06Tvapol6P
+L4z/ErSTKJRHzBPgzeSQHoRwvYbs4GE5VGMlygEq/v8ieodH0eO0IH9Cb3wro+Yq
+6+SkbtOaJKdr15DZ/zd8UgoaBGxJFJ03cBcZHgV9FYfvv9QrNxkp4mx/g4UIe9Zn
+6LqJSqxoQmhLWOTitp2iW/yMmDtSo2jwi4KVx+ENO9O0NsPUP2nk6mkH1YMMVg32
+mmrcuqOMijQu8b1MI76mO0KY3fCmbS6d0gReEcVYBZ5aPPCFTOeZVFF3n2Iz44+h
+PrE+21UgwWYxmHQoSJ+f5378EEJYr3bY/PHOp/HEzPshlU3u++3utcGQbQRowUeF
+cNd/gdOwHQpw7Sx6YFUvdTs9PEexPzgwzca8mPVto9uO8T5LLyZUouG6/bPzIsj7
+bDeZ9o56JhpR6flgg5SvWanyUL5ihbqhIxJcQai/XbMS3h61GK9H9RCu9LoJiRMM
++P2bBcsd0bqzysjbifk68UjcOSpCosLBavF/JSyAO9k2ytBzah8=
+-----END CERTIFICATE-----

src/test/resources/tls/redis.dh

@@ -0,0 +1,8 @@
+-----BEGIN DH PARAMETERS-----
+MIIBCAKCAQEAsUMvwTsUNheculmKMUjtZZJYw8DPD1vlh3DlD1xjwShqh46ICyna
+fER4nKo9Lt63zNcM68w1aNgiyajbJgzemuNbRh55vh88jV4rNitqWcb0MiiuOWUc
+3MjNtp6U7ttoZrMhXtiPLwEfNtkUZJZAaAnvs6MEu7BgyoVXpvt8Azckh1dpYeOt
+TFnmIqVMziH1R2MxIFCkxZNsL9vJtrf8K3bgBJaPFpJeTPRMS25Pg90iJ2ZJLDZU
+OjRuQpt7yaEGNJP3ADjQAWrSRMe2NnfJ2b2yI2CzTBQ0DOeAw731TmRw7pxIOPEu
+N1jPJMNsM9FLoeslpJ9neot7UrqZtCt5SwIBAg==
+-----END DH PARAMETERS-----

src/test/resources/tls/redis.key

@@ -0,0 +1,27 @@
+-----BEGIN RSA PRIVATE KEY-----
+MIIEpAIBAAKCAQEA13oMeZvjG1ZJ6PoQ4cc0c//NJW5DeNhSpPNzmzWhauYPKuiu
+TeudEGjWX1fqf0QRJoxnJnEkWSuCcyVg1tmPLsqAqkY8/UEsPDJ4GjqliDwxFkrQ
+p3QZoWoeTValugL2orKHJaIP8LXz7oCrpWbllx+dJxqcnVZuYZm37o20ZM4ENa4E
+Z8LMLH/qgiQO+V5vJwWzsm4vW7Ehplgp9QbZs9aRWlu1s1y6d7oDalO2x8x3HxSp
+Y5bTzu5yjdDxARr6vAsIPOFPo3LCWUYc3m5rkKAZ2thYV4fmUC6I3G9ZsJo32/y5
+rr7/FqU4Z7A+LFBtKAXorSCuOOD+NJ3K3ncEfQIDAQABAoIBAGQFJkdIwhnNaw93
+DGERS9rQkZRfY3hzyaEB1NbmBSCO29mKGmbXCJg2YdPuBk6+9MsU/0iL2lh95ta2
+MgZpBJquqxze766LExJ6Rt+9+1qKvipf3gzsynzvulMh9lmqyHtrLWqdmJKekzVR
+ituDMO1+Yj9lje9G0IQDi6pzIpprYLdstQJsUoafwN8TbqPGem8Z8/ili3TIj9z/
+EZuSH/Crv80ls+ptz2GiPcAxUctqAfha+3lkX+qWklTd+0B5LgHrf2agxIAb7549
+ZQTo4kDPDem7Rvqj4IQMHQhRdgSNYOmjidIF+XnbsdVw2rSbqMx6z+eLepuGtUQj
+fWDh5gECgYEA9GddWg36dF5kebvBfuFso4DSqKBip6P6cogzoI6fHP2b4Qe73hlq
+YiLOA3dPN/a8D0Ox3HNK8jx23EzG/JiIlBYX3RcB9+iUtg2Iixz9FiHnQkKwJFBS
+VnWOb4rNQqWm+5W/OxE3da5dvsQKKpcgAK9OYj84X0lH3196GsxRrIECgYEA4bNS
+6J0tbWHZ6CnTSZJz3BRNFnn8WSLy6A8Yytku1DnJjODuJT0/JwxglM+sR022V7JY
+YCBfuueIXhqYbqCqCzLxZg21+w/3jpIZp7eDd5nY+VDnUv0PyNwGgv5rS6nEgpeL
+YdbDYbj0ZOLZjSDrz5OfqihNQZssfWeB+ecvCf0CgYA/s/l3EZGoZzoVKMUkhylD
+7L37yeItA+axl6KtRL9gVRIeM1/aYhGChsPfz2dMlPkrmV9wsHRmczAf97sd97wR
+rTiHHgobTfoFAb4HVIT7EdcvRCaZMH5lnrqDhFBAAOFnTf7MLI6iE9LHeF2WAFIN
+G6R4ozXUUEt1g3NWLM9VAQKBgQC73b86PnKspJF0LTRg/hWQcBmGhv1k2LFmNgLF
+/id7oapBqIyx1Jw3jZbq5z4Yj/giYSIsyWXFtqmM4whUtUk1Ty8eanU6yJygQL44
+G4nDyPyQ8iXKrzgvUe3dpZZ8AZC/vxLW2qQBOKm9PBIn5epC+zcgtLEx1c8fh0Pq
+VuORpQKBgQDXfhxTrpYyoxJmAoLmj9IOdsE/vjlcpriaQu4hkzaN6wz79O637WBk
+zoaT72zYbCpWhD42yZLqQIkrgYjsht30Wut1dp/0FQSoT872aB62Q90UVKmX4TvN
+wODJz8mtdC5co5fjxbaUn9Zfc0LUO9KPhFd0fb6SwCthBSQ4RmBWgg==
+-----END RSA PRIVATE KEY-----

src/test/scala/com/redislabs/provider/redis/env/RedisStandaloneSSLEnv.scala

@@ -0,0 +1,21 @@
+package com.redislabs.provider.redis.env
+
+import com.redislabs.provider.redis.{RedisConfig, RedisEndpoint}
+import org.apache.spark.SparkConf
+
+trait RedisStandaloneSSLEnv extends Env {
+
+  override val redisPort = 6380
+
+  override val conf: SparkConf = new SparkConf()
+    .setMaster("local[*]").setAppName(getClass.getName)
+    .set("spark.redis.host", redisHost)
+    .set("spark.redis.port", s"$redisPort")
+    .set("spark.redis.auth", redisAuth)
+    .set("spark.redis.ssl", "true")
+    .set("spark.streaming.stopGracefullyOnShutdown", "true")
+    .set("spark.driver.bindAddress", "127.0.0.1")
+
+  override val redisConfig: RedisConfig =
+    new RedisConfig(RedisEndpoint(redisHost, redisPort, redisAuth, ssl=true))
+}

src/test/scala/com/redislabs/provider/redis/util/ConnectionSSLUtilsTest.scala

@@ -0,0 +1,23 @@
+package com.redislabs.provider.redis.util
+
+import com.redislabs.provider.redis.env.RedisStandaloneSSLEnv
+import com.redislabs.provider.redis.util.ConnectionUtils.{JedisExt, XINFO}
+import org.scalatest.{FunSuite, Matchers}
+import redis.clients.jedis.StreamEntryID
+
+import scala.collection.JavaConverters._
+
+/**
+  * @author The Viet Nguyen
+  */
+class ConnectionSSLUtilsTest extends FunSuite with Matchers with RedisStandaloneSSLEnv {
+
+  test("xinfo") {
+    val streamKey = TestUtils.generateRandomKey()
+    val conn = redisConfig.connectionForKey(streamKey)
+    val data = Map("key" -> "value").asJava
+    val entryId = conn.xadd(streamKey, new StreamEntryID(0, 1), data)
+    val info = conn.xinfo(XINFO.SubCommandStream, streamKey)
+    info.get(XINFO.LastGeneratedId) shouldBe Some(entryId.toString)
+  }
+}