add env rabbit user & pass

.github/workflows/publish.yml

@@ -7,7 +7,7 @@ on:
 jobs:
   push_to_registry:
     name: Push Docker image to Docker Hub
-    runs-on: [self-hosted]
+    runs-on: [ubuntu-latest]
     permissions:
       packages: write
       contents: read

README.md

@@ -52,7 +52,9 @@ Environment variables:
 * `CLICKHOUSE_DB` - ClickHouse database for inserts, default `default`
 * `RABBIT_HOST` - RabbitMQ host for subscribe, default `localhost`
 * `RABBIT_STOMP_PORT` - RabbitMQ STOMP port, default `61613`
-* `RABBIT_QUEUE` - RabbitMQ queue for buffer data
+* `RABBIT_USER` - RabbitMQ STOMP login user, default `guest`
+* `RABBIT_PASSWORD` - RabbitMQ STOMP login password, default `guest`
+* `RABBIT_QUEUE` - RabbitMQ queue for buffer data, default `clickhouse`
 * `MAX_DELAY` - time flush data to ClickHouse, default `5`
 * `MAX_FILE_SIZE` - max buffer size before flush to ClickHouse, default `5242880`
 

examples/run.php

@@ -21,10 +21,12 @@
 		'host'     => getenv('CLICKHOUSE_HOST'),
 		'port'     => getenv('CLICKHOUSE_PORT'),
 	],
-	'stomp'      => [
-		'host'  => getenv('RABBIT_HOST'),
-		'port'  => getenv('RABBIT_STOMP_PORT'),
-		'queue' => getenv('RABBIT_QUEUE') ?: 'clickhouse',
+	'stomp'         => [
+		'host'     => getenv('RABBIT_HOST'),
+		'port'     => getenv('RABBIT_STOMP_PORT'),
+		'user'     => getenv('RABBIT_USER'),
+		'password' => getenv('RABBIT_PASSWORD'),
+		'queue'    => getenv('RABBIT_QUEUE') ?: 'clickhouse',
 	],
 	'max_delay'     => getenv('MAX_DELAY'),
 	'max_file_size' => getenv('MAX_FILE_SIZE'),

src/ClickhouseWorker.php

@@ -255,8 +255,8 @@ protected function processing(string $file, string $table): void {
 	 */
 	private function stompConnect(): void {
 		$this->client = new Client('stomp://' . ($this->config['stomp']['host'] ?? null ?: '127.0.0.1') . ':' . ($this->config['stomp']['port'] ?? null ?: 61613), array_filter([
-			'login'            => $this->config['stomp']['user'] ?? null,
-			'passcode'         => $this->config['stomp']['password'] ?? null,
+			'login'            => $this->config['stomp']['user'] ?? null ?: 'guest',
+			'passcode'         => $this->config['stomp']['password'] ?? null ?: 'guest',
 			'reconnect_period' => 1,
 		]));