Skip to content

Commit b501d62

Browse files
Fix source code language
1 parent 03f1609 commit b501d62

File tree

6 files changed

+30
-30
lines changed

6 files changed

+30
-30
lines changed

modules/ROOT/pages/pulsar-jms-faq.adoc

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -29,14 +29,14 @@ In the tck-executor module you'll find:
2929

3030
To build the package, run unit tests, and run the TCK:
3131

32-
[source,language-bash]
32+
[source,bash]
3333
----
3434
mvn clean install -Prun-tck
3535
----
3636

3737
To run only the TCK:
3838

39-
[source,language-bash]
39+
[source,bash]
4040
----
4141
mvn clean install -Prun-tck -am -DskipTests -pl tck-executor
4242
----
@@ -57,14 +57,14 @@ If you'd like to fork or contribute to Starlight for JMS:
5757

5858
. Clone the git repo:
5959
+
60-
[source,language-bash]
60+
[source,bash]
6161
----
6262
git clone [email protected]:datastax/pulsar-jms.git
6363
----
6464

6565
. Build using Maven:
6666
+
67-
[source,language-bash]
67+
[source,bash]
6868
----
6969
mvn clean install
7070
----

modules/examples/pages/pulsar-jms-implementation.adoc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ When you set a `clientId`, the actual subscription name in Pulsar is constructed
3535
One solution for this situation is the *dead letter topic* policy. The *dead-letter topic* policy routes the unsuccessful messages to the *dead-letter topic* for storage, so consumers can keep consuming while the unsuccessful messages are stored in the dead-letter topic for processing or evaluation.
3636

3737
Starlight for JMS allows further configuration of `deadLetterPolicy`. For more on `deadLetterTopic` configuration properties, see xref:reference:pulsar-jms-reference.adoc[].
38-
[source,language-java]
38+
[source,java]
3939
----
4040
Map<String, Object> deadLetterPolicy = new HashMap<>();
4141
consumerConfig.put("deadLetterPolicy", deadLetterPolicy);

modules/jms-migration/pages/pulsar-jms-install.adoc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ To avoid issues, DataStax recommends using: +
1414

1515
Install Starlight for JMS by adding the following dependency to your Java Maven project `pom.xml`. Remember to choose the most recent version.
1616

17-
[source,language-xml]
17+
[source,xml]
1818
----
1919
<dependency>
2020
<artifactId>pulsar-jms</artifactId>
@@ -27,7 +27,7 @@ That file contains only Starlight for JMS code and transitively imports the Apac
2727

2828
You can also use a "fat" JAR that includes all dependencies:
2929

30-
[source,language-xml]
30+
[source,xml]
3131
----
3232
<dependency>
3333
<artifactId>pulsar-jms-all</artifactId>

modules/jms-migration/pages/pulsar-jms-quickstart-sa.adoc

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -22,14 +22,14 @@ To install a Docker Pulsar instance:
2222
. Make sure you have https://docs.docker.com/get-docker/[Docker] installed on your platform.
2323
. Open a terminal and create a Pulsar Docker instance:
2424
+
25-
[source,language-bash]
25+
[source,bash]
2626
----
2727
docker run --name pulsar-jms-runner -p 8080:8080 -p 6650:6650 apachepulsar/pulsar:latest /pulsar/bin/pulsar standalone
2828
----
2929
+
3030
*Results*:
3131
+
32-
[source,language-bash]
32+
[source,bash]
3333
----
3434
Many status messages...
3535
@@ -51,7 +51,7 @@ We'll use Apache Maven to handle dependency management so you don't have to manu
5151
. Create a project directory in a convenient location.
5252
. Save the following file as `pom.xml` in your project directory.
5353
+
54-
[source,language-xml]
54+
[source,xml]
5555
----
5656
<?xml version="1.0" encoding="UTF-8"?>
5757
<project>
@@ -127,15 +127,15 @@ To create the standalone example app:
127127

128128
. In the project directory you created above, create the following directory hierarchy, `<project-directory>/src/main/java/example`:
129129
+
130-
[source,language-bash]
130+
[source,bash]
131131
----
132132
cd <project-directory>
133133
mkdir -p /src/main/java/example
134134
----
135135
+
136136
. Copy the following code into a file named `StandaloneTest.java` and save the file:
137137
+
138-
[source,language-java]
138+
[source,java]
139139
----
140140
package example;
141141
@@ -201,14 +201,14 @@ To compile the sample application:
201201
. Change to the `<product_directory`.
202202
. Run the maven command:
203203
+
204-
[source,language-bash]
204+
[source,bash]
205205
----
206206
mvn clean install
207207
----
208208
+
209209
*Results*:
210210
+
211-
[source,language-bash]
211+
[source,bash]
212212
----
213213
Many status messages...
214214
@@ -229,14 +229,14 @@ TIP: The first time you compile the JAR file, Maven downloads all required depen
229229

230230
To run the sample app, from the `<product_directory`:
231231

232-
[source,language-bash]
232+
[source,bash]
233233
----
234234
java -jar target/pulsar-fast-jms-example-1.0-jar-with-dependencies.jar
235235
----
236236

237237
*Results*:
238238

239-
[source,language-bash]
239+
[source,bash]
240240
----
241241
Sending: Hello world! 0
242242
@@ -277,14 +277,14 @@ To delete the Pulsar Docker container:
277277

278278
. Get a list of all Docker containers and note the container ID (`5116f0d16eb3` in the example):
279279
+
280-
[source,language-bash]
280+
[source,bash]
281281
----
282282
docker ps --all
283283
----
284284
+
285285
*Results*:
286286
+
287-
[source,language-bash]
287+
[source,bash]
288288
----
289289
CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES
290290
5116f0d16eb3 apachepulsar/pulsar:latest "/pulsar/bin/pulsar …" 2 hours ago Exited (130) 2 minutes ago pulsar-jms-runner
@@ -293,14 +293,14 @@ CONTAINER ID IMAGE COMMAND CREATED
293293
+
294294
. Delete the container using the container ID:
295295
+
296-
[source,language-bash]
296+
[source,bash]
297297
----
298298
docker rm 5116f0d16eb3
299299
----
300300
+
301301
*Results*:
302302
+
303-
[source,language-bash]
303+
[source,bash]
304304
----
305305
5116f0d16eb3
306306
----

modules/reference/pages/pulsar-jms-mappings.adoc

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ NOTE: In certain cases, the `peekMessages` API can return the last consumed mess
7777
By default, the subscription created by a JMS queue is named `jms-queue`, which can be overriden with `jms.queueSubscriptionName` in the `PulsarConnectionFactory` constructor.
7878

7979
You can instead set the subscription name at queue creation:
80-
[source,language-java]
80+
[source,java]
8181
----
8282
try (PulsarConnectionFactory factory = new PulsarConnectionFactory(properties); ){
8383
Queue queue = session.createQueue("pulsarQueue:subscriptionName");
@@ -87,7 +87,7 @@ try (PulsarConnectionFactory factory = new PulsarConnectionFactory(properties);
8787
In the above example, the subscription will be `subscriptionName`, and the queue will be backed by the `public/default/pulsarQueue` Pulsar topic. +
8888

8989
You can override the default `public/default` namespace with `jms.systemNamespace` in the `PulsarConnectionFactory` constructor:
90-
[source,language-java]
90+
[source,java]
9191
----
9292
Map<String, Object> configuration = new HashMap<>();
9393
configuration.put("jms.systemNamespace", "<my-tenant>/<my-namespace>");
@@ -97,7 +97,7 @@ factory.close();
9797
----
9898

9999
A fully-qualified namespace works similarly, but the topic destination points to a persistent topic URL:
100-
[source,language-java]
100+
[source,java]
101101
----
102102
Queue queue = session.createQueue("persistent://tenant/namespace/pulsarQueue:subscriptionName")
103103
----
@@ -109,14 +109,14 @@ In the above example, the subscription will be `subscriptionName`, and the queue
109109
By default, the `jms.precreateQueueSubscription` configuration flag is set to `true`, and the JMS client will pre-create the `jms-queue` subscription (see xref:pulsar-jms-mappings.adoc#jms-queue[Overriding jms-queue] above). +
110110

111111
To disable automatic subscription creation in the JMS client, set the `jms.precreateQueueSubscription` parameter to `false`, as below:
112-
[source,language-java]
112+
[source,java]
113113
----
114114
Map<String, Object> properties = new HashMap<>();
115115
properties.put("jms.precreateQueueSubscription", "false");
116116
----
117117

118118
To disable automatic subscription creation on the Pulsar broker, set the `allowAutoSubscriptionCreation` parameter to `false`, as below:
119-
[source,language-java]
119+
[source,java]
120120
----
121121
public static void before() throws Exception {
122122
cluster =

modules/reference/pages/pulsar-jms-reference.adoc

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ A complete configuration reference for Starlight for JMS.
55

66
Configuration information is passed to the `PulsarConnectionFactory` constructor:
77

8-
[source,language-java]
8+
[source,java]
99
----
1010
Map<String, Object> configuration = new HashMap<>();
1111
configuration.put("...","...");
@@ -16,7 +16,7 @@ factory.close();
1616

1717
Configuration information can also be passed as a JSON encoded string:
1818

19-
[source,language-java]
19+
[source,java]
2020
----
2121
String configuration = "{.....}";
2222
ConnectionFactory factory = new PulsarConnectionFactory();
@@ -29,7 +29,7 @@ Configuration information can be passed when a `JMSContext` or `Session` is crea
2929

3030
Create a `PulsarConnectionFactory` with `initialContext` for configuration.
3131

32-
[source,language-java]
32+
[source,java]
3333
----
3434
Map<String, Object> configuration = new HashMap<>();
3535
Map<String, Object> consumerConfig = new HashMap<>();
@@ -40,7 +40,7 @@ PulsarJMSContext initialContext = (PulsarJMSContext) factory.createContext();
4040

4141
The initial configuration in `initialContext` will be overridden by the subsequent `JMSContext` configuration `withCustomConfiguration`.
4242

43-
[source,language-java]
43+
[source,java]
4444
----
4545
Map<String, Object> perContextConfiguration new HashMap<>();
4646
Map<String, Object> perContextConsumerConfig = new HashMap<>();
@@ -50,7 +50,7 @@ JMSContext withCustomConfiguration = initialContext.createContext(mode, perConte
5050

5151
Or override the initial configuration in `initialContext` with the `JMSContext` configuration `withCustomConfiguration` in a Session object.
5252

53-
[source,language-java]
53+
[source,java]
5454
----
5555
Session.createSession(int mode, Map<String, Object> withCustomConfiguration)
5656
----

0 commit comments

Comments
 (0)