1 2sharedsub examples 3---------------------- 4 5Description 6----------- 7This example illustrates how to write an application the use of 8JMS2.0 simplified API to create shared non durable & durable consumers and sharing 9of messages between them. 10 11Some basic info on this example: 12 13- ProducerExample.class sends messages to the particular topic and displays the messages sent. 14- SharedNonDuraConsumerExample.java creates two shared non durable subscriber threads and displays 15 the shared messages between them. 16- SharedDuraConsumerExample.java creates two shared durable subscriber threads and displays 17 the shared messages between them. 18 19Files 20----- 21SharedDuraConsumerExample.java Source file for this example. 22SharedNonDuraConsumerExample.java Source file for this example. 23ProducerExample.java Source file for this example. 24*.class Prebuilt Java class files for this example. 25README This file. 26 27Configuring the environment 28--------------------------- 29To recompile or run this example, you need to set CLASSPATH 30to include at least: 31 jms.jar 32 imq.jar 33 directory containing this example 34 35A detailed guideline on configuring your environment and setting CLASSPATH 36is found in the top-level README file of the examples (demo) directory of 37the Message Queue installation (<IMQ_HOME>/examples/README) as well as in 38the "Quick Start Tutorial" in the Oracle GlassFish(tm) Server Message Queue 39Developer's Guide. 40 41Building the example 42-------------------- 43Run the following: 44 45 javac SharedDuraConsumerExample.java 46 javac SharedNonDuraConsumerExample.java 47 javac ProducerExample.java 48 49Running the shareddura example 50---------------------------------- 51 52Start a broker 53 54 imqbrokerd -tty 55 56Run the following command first on one terminal: 57 58 java SharedDuraConsumerExample <topic_name> [<number_of_messages>] 59 60Run the following command on another terminal: 61 62 java ProducerExample <topic_name> [<number_of_messages>] 63 64 65The output of SharedDuraConsumerExample looks like this: 66 67java SharedDuraConsumerExample test1 20 68Topic name is test1 69SUBSCRIBER 2 : Message received: Message 1 70SUBSCRIBER 1 : Message received: Message 2 71SUBSCRIBER 2 : Message received: Message 3 72SUBSCRIBER 1 : Message received: Message 4 73SUBSCRIBER 2 : Message received: Message 5 74SUBSCRIBER 1 : Message received: Message 6 75SUBSCRIBER 2 : Message received: Message 7 76SUBSCRIBER 1 : Message received: Message 8 77SUBSCRIBER 2 : Message received: Message 9 78SUBSCRIBER 1 : Message received: Message 10 79SUBSCRIBER 2 : Message received: Message 11 80SUBSCRIBER 1 : Message received: Message 12 81SUBSCRIBER 2 : Message received: Message 13 82SUBSCRIBER 1 : Message received: Message 14 83SUBSCRIBER 2 : Message received: Message 15 84SUBSCRIBER 1 : Message received: Message 16 85SUBSCRIBER 2 : Message received: Message 17 86SUBSCRIBER 1 : Message received: Message 18 87SUBSCRIBER 2 : Message received: Message 19 88SUBSCRIBER 1 : Message received: Message 20 89Received all messages 90 91The output of ProducerExample looks like this: 92 93java ProducerExample test1 20 94Topic name is test1 95Created jms context successfully 96Created topic successfully 97Message sent : Message 1 98Message sent : Message 2 99Message sent : Message 3 100Message sent : Message 4 101Message sent : Message 5 102Message sent : Message 6 103Message sent : Message 7 104Message sent : Message 8 105Message sent : Message 9 106Message sent : Message 10 107Message sent : Message 11 108Message sent : Message 12 109Message sent : Message 13 110Message sent : Message 14 111Message sent : Message 15 112Message sent : Message 16 113Message sent : Message 17 114Message sent : Message 18 115Message sent : Message 19 116Message sent : Message 20 117 118 119Running the sharednondura example 120---------------------------------- 121 122Start a broker 123 124 imqbrokerd -tty 125 126Run the following command first on one terminal: 127 128 java SharedNonDuraConsumerExample <topic_name> [<number_of_messages>] 129 130Run the following command on another terminal: 131 132 java ProducerExample <topic_name> [<number_of_messages>] 133 134 135The output of SharedNonDuraConsumerExample looks like this: 136 137java SharedNonDuraConsumerExample t1 20 138Topic name is t1 139SUBSCRIBER 1 : Message received: Message 1 140SUBSCRIBER 2 : Message received: Message 2 141SUBSCRIBER 1 : Message received: Message 3 142SUBSCRIBER 2 : Message received: Message 4 143SUBSCRIBER 1 : Message received: Message 5 144SUBSCRIBER 2 : Message received: Message 6 145SUBSCRIBER 2 : Message received: Message 7 146SUBSCRIBER 1 : Message received: Message 8 147SUBSCRIBER 2 : Message received: Message 9 148SUBSCRIBER 1 : Message received: Message 10 149SUBSCRIBER 2 : Message received: Message 11 150SUBSCRIBER 1 : Message received: Message 12 151SUBSCRIBER 2 : Message received: Message 13 152SUBSCRIBER 1 : Message received: Message 14 153SUBSCRIBER 2 : Message received: Message 15 154SUBSCRIBER 1 : Message received: Message 16 155SUBSCRIBER 2 : Message received: Message 17 156SUBSCRIBER 1 : Message received: Message 18 157SUBSCRIBER 2 : Message received: Message 19 158SUBSCRIBER 1 : Message received: Message 20 159Received all messages 160 161The output of ProducerExample looks like this: 162 163java ProducerExample t1 20 164Topic name is t1 165Created jms context successfully 166Created topic successfully 167Message sent : Message 1 168Message sent : Message 2 169Message sent : Message 3 170Message sent : Message 4 171Message sent : Message 5 172Message sent : Message 6 173Message sent : Message 7 174Message sent : Message 8 175Message sent : Message 9 176Message sent : Message 10 177Message sent : Message 11 178Message sent : Message 12 179Message sent : Message 13 180Message sent : Message 14 181Message sent : Message 15 182Message sent : Message 16 183Message sent : Message 17 184Message sent : Message 18 185Message sent : Message 19 186Message sent : Message 20 187 188