You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: modules/ROOT/partials/jms-quickstart-create-project.adoc
+4-4Lines changed: 4 additions & 4 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -1,4 +1,4 @@
1
-
. Create a new Maven project:
1
+
. Create a new {maven-short} project:
2
2
+
3
3
[source,bash]
4
4
----
@@ -19,7 +19,7 @@ cd StarlightForJMSClient
19
19
. Open the project in your IDE, and then add the {product} dependency to the `pom.xml` file.
20
20
+
21
21
This quickstart uses the `pulsar-jms-all` package, which is a fat JAR file that includes all dependencies.
22
-
{company} recommends using the {jms_repo}releases[latest stable release].
22
+
{company} recommends using the {jms_repo}/releases[latest stable release].
23
23
+
24
24
.pom.xml
25
25
[source,xml]
@@ -46,7 +46,7 @@ This quickstart uses the `pulsar-jms-all` package, which is a fat JAR file that
46
46
47
47
. For this quickstart, include the following plugin configuration in the `build` section:
48
48
+
49
-
* **`<artifactId>maven-assembly-plugin</artifactId>`**: The Maven Assembly Plugin that is used to compile a JAR file with all dependencies included.
49
+
* **`<artifactId>maven-assembly-plugin</artifactId>`**: The {maven-short} Assembly Plugin that is used to compile a JAR file with all dependencies included.
50
50
* **`<descriptorRef>jar-with-dependencies</descriptorRef>`**: An additional descriptor appended to the compiled JAR file name.
51
51
* **`<mainClass>org.example.App</mainClass>`**: The default package and class so you can run the compiled JAR file without any additional specifications.
52
52
+
@@ -72,7 +72,7 @@ This quickstart uses the `pulsar-jms-all` package, which is a fat JAR file that
72
72
</build>
73
73
----
74
74
75
-
. In your Maven project, create an `example` subdirectory at `/src/main/java/org`:
75
+
. In your {maven-short} project, create an `example` subdirectory at `/src/main/java/org`:
Copy file name to clipboardExpand all lines: modules/examples/pages/pulsar-jms-implementation.adoc
+2-2Lines changed: 2 additions & 2 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -133,8 +133,8 @@ Both of those features can be emulated on the client side with the following lim
133
133
* For shared subscriptions, especially on queues, the message is discarded on the client and is "negative acknowledged" in order to let other consumers receive the message.
134
134
* For `QueueBrowsers`, the message is discarded on the client side.
135
135
136
-
Currently, the implementation of message selectors is based on Apache ActiveMQ(R) Java client classes, which are imported as a dependency in {product}.
137
-
Apache ActiveMQ is licensed under Apache 2.0.
136
+
Currently, the implementation of message selectors is based on {activemq-reg} Java client classes, which are imported as a dependency in {product}.
Copy file name to clipboardExpand all lines: modules/examples/pages/pulsar-jms-server-side-filters.adoc
+2-2Lines changed: 2 additions & 2 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -37,11 +37,11 @@ Batch messages with compression consume a non-negligible amount of CPU, heap, an
37
37
This doesn't apply to compressed single messages.
38
38
39
39
* *Unsupported message types*: {product} doesn't support encrypted batch messages because the filter can't decode the payload of the entry.
40
-
For the same reason, {product} doesn't support custom formats like native Kafka messages.
40
+
For the same reason, {product} doesn't support custom formats like native {kafka-reg} messages.
41
41
42
42
== Enable server-side filtering
43
43
44
-
The `.nar` file filter is packaged with {luna-streaming} *2.10.03+* and also available in the GitHub repo https://github.com/datastax/pulsar-jms/releases[here].
44
+
The `.nar` file filter is packaged with {luna-streaming} *2.10.03+* and also available in the GitHub repo {jms_repo}/releases[here].
45
45
46
46
. Install {product} with the fat JAR that includes all dependencies.
Copy file name to clipboardExpand all lines: modules/jms-migration/pages/pulsar-jms-quickstart-sa.adoc
+13-13Lines changed: 13 additions & 13 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -11,13 +11,13 @@ This quickstart explains how to prepare an {pulsar-reg} streaming instance, and
11
11
12
12
[tabs]
13
13
======
14
-
{astra-streaming}::
14
+
{astra-stream}::
15
15
+
16
16
--
17
-
To use {product} with an {astra-streaming} {pulsar-short} cluster, you need the following:
17
+
To use {product} with an {astra-stream} {pulsar-short} cluster, you need the following:
18
18
19
-
* An active {astra-streaming} {pulsar-short} cluster with a tenant, namespace, and topic that you want to use with {product}.
20
-
If you don't have these structures configured in {astra-streaming}, see the xref:astra-streaming:getting-started:index.adoc[].
19
+
* An active {astra-stream} {pulsar-short} cluster with a tenant, namespace, and topic that you want to use with {product}.
20
+
If you don't have these structures configured in {astra-stream}, see the xref:astra-streaming:getting-started:index.adoc[].
21
21
22
22
* The connection details for your tenant, which are found on the tenant's **Connect** tab under **Tenant Details**:
23
23
+
@@ -91,23 +91,23 @@ Starting the Docker container produces many status messages and output similar t
91
91
92
92
== Produce and consume messages with {product}
93
93
94
-
This example shows how to produce and consume messages with Starlight for JMS using a JMS client, https://openjdk.java.net/install/[Java OpenJDK] 8 or 11, and https://maven.apache.org/install.html[Apache Maven].
94
+
This example shows how to produce and consume messages with Starlight for JMS using a JMS client, https://openjdk.java.net/install/[Java OpenJDK] 8 or 11, and https://maven.apache.org/install.html[{maven-reg}].
95
95
You can also use Gradle with some modifications.
96
96
97
-
For the complete source code for this example, see the https://github.com/datastax/astra-streaming-examples/tree/master/java/starlight-for-jms[{company} streaming examples repository].
98
-
This example was written for {astra-streaming} but it can be used with {luna-streaming} or self-managed {pulsar-short} clusters by setting the connection properties appropriately.
97
+
For the complete source code for this example, see the {astra-streaming-examples-repo}/tree/master/java/starlight-for-jms[{company} streaming examples repository].
98
+
This example was written for {astra-stream} but it can be used with {luna-streaming} or self-managed {pulsar-short} clusters by setting the connection properties appropriately.
. In the `example` directory, create an `App.java` file.
108
108
In the next steps, you will add code to this file to create a complete program that produces and consumes messages.
109
109
110
-
. Paste the following code in the file, and then replace the placeholders with the <<prepare-your-pulsar-cluster,tenant connection details, namespace, and topic from {astra-streaming}>>.
110
+
. Paste the following code in the file, and then replace the placeholders with the <<prepare-your-pulsar-cluster,tenant connection details, namespace, and topic from {astra-stream}>>.
111
111
Your editor will report errors because this isn't a complete program yet.
112
112
+
113
113
./src/main/java/org/example/App.java
@@ -195,9 +195,9 @@ Sending: Hello there!
195
195
Received: Hello there!
196
196
----
197
197
198
-
. In {astra-streaming}, go to your tenant's **Namespaces and Topics** tab to inspect the activity in the namespace that you used in the Java program.
198
+
. In {astra-stream}, go to your tenant's **Namespaces and Topics** tab to inspect the activity in the namespace that you used in the Java program.
199
199
+
200
-
If you everything was configured correctly, then the namespace's metrics should reflect that at least one message was published and consumed by your {astra-streaming} {pulsar-short} topic.
200
+
If you everything was configured correctly, then the namespace's metrics should reflect that at least one message was published and consumed by your {astra-stream} {pulsar-short} topic.
201
201
--
202
202
203
203
{luna-streaming}::
@@ -279,7 +279,7 @@ For more information about consumers, see xref:reference:pulsar-jms-mappings.ado
279
279
mvn clean install
280
280
----
281
281
+
282
-
The first time you compile the JAR file, Maven downloads all required dependencies.
282
+
The first time you compile the JAR file, {maven-short} downloads all required dependencies.
283
283
Subsequent runs are faster.
284
284
285
285
. Run the sample application:
@@ -408,7 +408,7 @@ For more information about consumers, see xref:reference:pulsar-jms-mappings.ado
408
408
mvn clean install
409
409
----
410
410
+
411
-
The first time you compile the JAR file, Maven downloads all required dependencies.
411
+
The first time you compile the JAR file, {maven-short} downloads all required dependencies.
Copy file name to clipboardExpand all lines: modules/reference/pages/pulsar-jms-reference.adoc
+1-1Lines changed: 1 addition & 1 deletion
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -86,7 +86,7 @@ Other entries are ignored.
86
86
| String
87
87
| If not specified, for {pulsar-short} standalone instances running on localhost, defaults to the same value as `webServiceUrl`, \`http://localhost:8080`. Can also be specified as \`pulsar://localhost:6650` for {pulsar-short} standalone instances on localhost.
88
88
a| The URL to connect to the {pulsar-short} broker or proxy
89
-
The `brokerServiceUrl` must be specified for {astra-streaming}. Must be customized as required for {pulsar-short} standalone instances that aren't running on localhost.
89
+
The `brokerServiceUrl` must be specified for {astra-stream}. Must be customized as required for {pulsar-short} standalone instances that aren't running on localhost.
0 commit comments