Merge 6a5977d into 4965795

build.sbt

@@ -28,7 +28,7 @@ ThisBuild / description := "CodeFeedr provides an infrastructure on top of Apach
 ThisBuild / licenses := List("Apache 2" -> new URL("http://www.apache.org/licenses/LICENSE-2.0.txt"))
 ThisBuild / homepage := Some(url("https://github.com/codefeedr/codefeedr"))
 
-ThisBuild / version := "0.1.4"
+ThisBuild / version := "0.1.5"
 ThisBuild / organization := "org.codefeedr"
 ThisBuild / scalaVersion := scala212
 

codefeedr-plugins/codefeedr-ghtorrent/src/main/scala/org/codefeedr/plugins/ghtorrent/util/GHTorrentRabbitMQSource.scala

@@ -47,12 +47,14 @@ import collection.JavaConverters._
   * @param port the port, default is 5672.
   * @param routingKeysFile the location of the routingKeysFile (in the resources directory).
   * @param usesCorrelationId if correlation id's should be enabled, default is false.
+  * @param password your password to specify to GHTorrent.
   */
-class GHTorrentRabbitMQSource(username: String,
+class GHTorrentRabbitMQSource(username: String = "streamer",
                               host: String = "localhost",
                               port: Int = 5672,
                               routingKeysFile: String = "routing_keys.txt",
-                              usesCorrelationId: Boolean = false)
+                              usesCorrelationId: Boolean = false,
+                              password: String = "streamer")
     extends MultipleIdsMessageAcknowledgingSourceBase[String, String, Long](
       classOf[String])
     with ResultTypeQueryable[String] {
@@ -70,8 +72,8 @@ class GHTorrentRabbitMQSource(username: String,
       .setHost(host)
       .setPort(port)
       .setVirtualHost("/")
-      .setUserName("streamer")
-      .setPassword("streamer")
+      .setUserName(username)
+      .setPassword(password)
       .build()
 
   @transient