Merge branch 'main' into direct-get-batch

nats-io · Nov 9, 2024 · 4bcd562 · 4bcd562
2 parents b858c48 + 0cc14f3
commit 4bcd562
Show file tree

Hide file tree

Showing 10 changed files with 23 additions and 23 deletions.
diff --git a/jetstream/examples/01_consumers.ts b/jetstream/examples/01_consumers.ts
@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/transport-deno@3.0.0-7";
-import { jetstream } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect } from "@nats-io/transport-deno";
+import { jetstream } from "@nats-io/jetstream";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

diff --git a/jetstream/examples/02_next.ts b/jetstream/examples/02_next.ts
@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/transport-deno@3.0.0-7";
-import { jetstream } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect } from "@nats-io/transport-deno";
+import { jetstream } from "@nats-io/jetstream";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

diff --git a/jetstream/examples/03_batch.ts b/jetstream/examples/03_batch.ts
@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/transport-deno@3.0.0-7";
-import { jetstream } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect } from "@nats-io/transport-deno";
+import { jetstream } from "@nats-io/jetstream";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

diff --git a/jetstream/examples/04_consume.ts b/jetstream/examples/04_consume.ts
@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/transport-deno@3.0.0-7";
-import { jetstream } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect } from "@nats-io/transport-deno";
+import { jetstream } from "@nats-io/jetstream";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

diff --git a/jetstream/examples/05_consume.ts b/jetstream/examples/05_consume.ts
@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/transport-deno@3.0.0-7";
-import { jetstream } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect } from "@nats-io/transport-deno";
+import { jetstream } from "@nats-io/jetstream";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

diff --git a/jetstream/examples/06_heartbeats.ts b/jetstream/examples/06_heartbeats.ts
@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/transport-deno@3.0.0-7";
-import { ConsumerEvents, jetstream } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect } from "@nats-io/transport-deno";
+import { ConsumerEvents, jetstream } from "@nats-io/jetstream";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

diff --git a/jetstream/examples/07_consume_jobs.ts b/jetstream/examples/07_consume_jobs.ts
@@ -13,10 +13,10 @@
  * limitations under the License.
  */
 
-import { connect, delay } from "jsr:@nats-io/transport-deno@3.0.0-7";
-import { SimpleMutex } from "jsr:@nats-io/nats-core@3.0.0-17/internal";
-import { jetstream } from "jsr:@nats-io/jetstream@3.0.0-18";
-import type { JsMsg } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect, delay } from "@nats-io/transport-deno";
+import { SimpleMutex } from "@nats-io/nats-core/internal";
+import { jetstream } from "@nats-io/jetstream";
+import type { JsMsg } from "@nats-io/jetstream";
 import { setupStreamAndConsumer } from "./util.ts";
 
 // create a connection

diff --git a/jetstream/examples/08_consume_process.ts b/jetstream/examples/08_consume_process.ts
@@ -13,9 +13,9 @@
  * limitations under the License.
  */
 
-import { connect } from "jsr:@nats-io/transport-deno@3.0.0-7";
+import { connect } from "@nats-io/transport-deno";
 import { setupStreamAndConsumer } from "./util.ts";
-import { jetstream } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { jetstream } from "@nats-io/jetstream";
 
 // create a connection
 const nc = await connect();

diff --git a/jetstream/examples/js_readme_publish_examples.ts b/jetstream/examples/js_readme_publish_examples.ts
@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect, Empty } from "jsr:@nats-io/transport-deno@3.0.0-7";
-import { jetstream, jetstreamManager } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect, Empty } from "@nats-io/transport-deno";
+import { jetstream, jetstreamManager } from "@nats-io/jetstream";
 import type { PubAck } from "../src/mod.ts";
 
 const nc = await connect();

diff --git a/jetstream/examples/jsm_readme_jsm_example.ts b/jetstream/examples/jsm_readme_jsm_example.ts
@@ -13,8 +13,8 @@
  * limitations under the License.
  */
 
-import { connect, Empty } from "jsr:@nats-io/nats-transport-deno@3.0.0-5";
-import { AckPolicy, jetstreamManager } from "jsr:@nats-io/jetstream@3.0.0-18";
+import { connect, Empty } from "@nats-io/transport-deno";
+import { AckPolicy, jetstreamManager } from "@nats-io/jetstream";
 
 const nc = await connect();
 const jsm = await jetstreamManager(nc);
@@ -48,7 +48,7 @@ await jsm.streams.update(name, si.config);
 // get a particular stored message in the stream by sequence
 // this is not associated with a consumer
 const sm = await jsm.streams.getMessage("mystream", { seq: 1 });
-console.log(sm.seq);
+console.log(sm?.seq);
 
 // delete the 5th message in the stream, securely erasing it
 await jsm.streams.deleteMessage("mystream", 5);