diff --git a/jetstream/examples/01_consumers.ts b/jetstream/examples/01_consumers.ts index cbbaa810..8df13fbe 100644 --- 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 index 94d645f6..0630bccd 100644 --- 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 index 686f70a8..71a3fd86 100644 --- 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 index 601bf339..31af01cb 100644 --- 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 index d1b0ca4b..3ec6f06b 100644 --- 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 index fc52d40e..5829d988 100644 --- 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 index f158bb94..046ec274 100644 --- 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 index 9af823b4..f602a408 100644 --- 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 index a8adb1f5..6e359e9f 100644 --- 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 index 41fcdf83..9c0daa1a 100644 --- 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); diff --git a/jetstream/examples/util.ts b/jetstream/examples/util.ts index c0820f99..a1ad1418 100644 --- a/jetstream/examples/util.ts +++ b/jetstream/examples/util.ts @@ -14,8 +14,8 @@ */ import { createConsumer, fill, initStream } from "../tests/jstest_util.ts"; -import type { NatsConnection } from "jsr:@nats-io/nats-core@3.0.0-31"; -import { nuid } from "jsr:@nats-io/nats-core@3.0.0-31"; +import type { NatsConnection } from "@nats-io/nats-core"; +import { nuid } from "@nats-io/nats-core"; export async function setupStreamAndConsumer( nc: NatsConnection,