diff --git a/compose.yaml b/compose.yaml index 46eb8b3..f7ccaec 100644 --- a/compose.yaml +++ b/compose.yaml @@ -13,21 +13,9 @@ services: - .:/workspace:cached working_dir: /workspace - nats-1: + nats: image: nats - command: -c /etc/server.conf --name nats-1 -p 4222 -m 8222 - volumes: - - ./docker/nats/server.conf:/etc/server.conf - - nats-2: - image: nats - command: -c /etc/server.conf --name nats-2 -p 4222 -m 8222 - volumes: - - ./docker/nats/server.conf:/etc/server.conf - - nats-3: - image: nats - command: -c /etc/server.conf --name nats-3 -p 4222 -m 8222 + command: -c /etc/server.conf -p 4222 -m 8222 volumes: - ./docker/nats/server.conf:/etc/server.conf diff --git a/docker/nats/server.conf b/docker/nats/server.conf index 060c021..70fa17f 100644 --- a/docker/nats/server.conf +++ b/docker/nats/server.conf @@ -13,12 +13,3 @@ accounts: { } jetstream {} - -cluster: { - name: RU, - port: 6222, - routes: [ - "nats://nats-1:6222" - "nats://nats-2:6222" - ] -} diff --git a/phpunit.xml.dist b/phpunit.xml.dist index aa1a56e..deeef1f 100644 --- a/phpunit.xml.dist +++ b/phpunit.xml.dist @@ -12,7 +12,7 @@ requireCoverageMetadata="true" > - + diff --git a/src/JetStream/KeyValue/Bucket.php b/src/JetStream/KeyValue/Bucket.php index 8231a23..1b41e07 100644 --- a/src/JetStream/KeyValue/Bucket.php +++ b/src/JetStream/KeyValue/Bucket.php @@ -71,10 +71,10 @@ public function get(string $key, int $revision = 0): ?Entry * @param non-empty-string $key * @return non-negative-int */ - public function put(string $key, ?string $value = null): int + public function put(string $key, ?string $value = null, ?Headers $headers = null): int { return $this->js - ->publish($this->prefixedSubject($key), new Message($value)) + ->publish($this->prefixedSubject($key), new Message($value, $headers)) ->seq ?? throw new \LogicException('Sequence expected on kv publish'); }