начал изучать jms , что - то никак не пойму , обязательно их реализоывать как как сессион бин или можно просто класс написать из которого будет осуществлятся поиск и подключение к Топику или точке? и как запустить такую программу?

http://www.javable.com/columns/serv_side/workshop/14/
в этой статье приведён пример :


как я понял , для работы jms приложение его надо реализовать как бин (S /E) и выложить на java ee сервер и обращатся к нему как к ejb , а тут просто класс или это нерабочий пример?
Итак, приступим к созданию простейших sender и receiver.

// Используем JMS и JNDI пакеты
import javax.jms.*;
import javax.naming.*;
public class SimpleSender{
public static void main(String args[]){
try {
//Сначала найдем сервис JNDI
Contect ctx = new InitialContext();
//Теперь найдем ConnectionFactory с помощью JNDI
//Имя, с которым зарегистрирован
// стандартный ConnectionFactory в дереве
// JNDIзависит от реализации –
// например, в случае WebLogic Server это
// weblogic.jms.ConnectionFactory
QueueConnectionFactory qcf =
(QueueConnectionFactory)ctx.lookup(
"MyConnectionFactory");
//А теперь создадим Connection
QueueConnection con = qcf.createQueueConnection();
//Создадим Session со следующими свойствами:
//а)посылка сообщений не является частью транзакции
//б)подтверждение о получении сообщения осуществляет JMS
//автоматически
QueueSession session =
con.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
//Найдем Destination с помощью JNDI. Если еще не существует
// (не зарегистрирована в JNDI) – создадим и зарегистрируем
Queue queue = null;
try{
queue = (Queue)ctx.lookup("MyQueue");
}catch(NameNotFoundException nnfe){
queue = session.createQueue("MyQueue");
ctx.bind("MyQueue",queue);
}
//Простейшее текстовое сообщение
TextMessage textMessage =
session.createTextMessage();
//Создадим Producer
QueueSender sender =
session.createSender(queue);
//Активизируем Connection
con.start();
//Теперь мы готовы посылать сообщения
//Будем посылать наше сообщение каждую секунду
//или тот интервал, который указан в первом аргументе
long sendInterval;
try{
sendInterval = Long.parseLong(args[0]);
}catch(Exception rae){
sendInterval = 1000;
}
//Пошлем, например, тысячу сообщений
for(int i=0;i<1000;i++){
//Создадим простейшее текстовое сообщение
textMessage.setText("Hi! It's my message number "+i);
//И пошлем его
sender.send(textMessage);
try{
Thread.sleep(sendInterval);
}catch(Exception se){
System.out.println("Got an exception "+se.getMessage());
}
}
}catch(Exception e){
e.printStackTrace();
}
}
}

и
Первый пример receiver – с использованием receive().

import javax.jms.*;
import javax.naming.*;
public class SyncReceiver {
public static void main(String[] args) {
try{
Context ctx = new InitialContext();
QueueConnectionFactory qcf =
(QueueConnectionFactory)ctx.lookup("MyConnectionFactory");
QueueConnection con = qcf.createQueueConnection();
QueueSession session =
con.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
Queue queue = null;
try{
queue = (Queue)ctx.lookup("MyQueue");
}catch(NameNotFoundException nnfe){
queue = session.createQueue("MyQueue");
ctx.bind("MyQueue", queue);
}
// Создадим Consumer
QueueReceiver receiver = session.createReceiver(queue);
// Активизируем Connection
con.start();
//Мы готовы принимать сообщения
for(;;){
//Обратите внимание на использование метода receive()
TextMessage textMessage = (TextMessage)receiver.receive();
System.out.println("Got a message :"+textMessage.getText());
}
}catch(Exception e){
e.printStackTrace();
}
}
}

Следующий пример – асинхронное получение сообщений с использованием интерфейса MessageListener.

import javax.jms.*;
import javax.naming.*;
//Обратите внимание, что класс реализует интерфей MessageListener
public class AsyncReceiver implements MessageListener{
public AsyncReceiver(){
}
//Метод onMessage интерфейса MessageListener будет вызван
//Consumer'ом для обработки поступившего сообщения
public void onMessage(Message message){
try{
TextMessage textMessage = (TextMessage)message;
System.out.println("Got a message : "+textMessage.getText());
}catch(JMSException jmse){
jmse.printStackTrace();
}
}
public static void main(String[] args) {
try{
Context ctx = new InitialContext();
QueueConnectionFactory qcf =
(QueueConnectionFactory)ctx.lookup( "MyConnectionFactory");
QueueConnection con = qcf.createQueueConnection();
QueueSession session =
con.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
Queue queue = null;
try{
queue = (Queue)ctx.lookup("MyQueue");
}catch(NameNotFoundException nnfe){
queue = session.createQueue("MyQueue");
ctx.bind("MyQueue", queue);
}
QueueReceiver receiver = session.createReceiver(queue);
con.start();
AsyncReceiver async = new AcyncReceiver();
//Зарегистрировать новый AsyncReceiver обьект как
//MessageListener дляreceiver
receiver.setMessageListener(async);
//А далее - делать что-либо, не ожидая сообщения.
//Сообщение будет обработано, как только придет.
//Для примера будем эмулировать бурную деятельность –
//"спать"!
Thread.sleep(100000000);
}catch(Exception e){
e.printStackTrace();
}
}
}

Просто не совсем понимаю как такое должно работать, попробовал написать такой класс ( но без мейн) и вызывать метод для отправки - получения из другого класса , но это же должно обрабатыватся веб сервервером , а получается, что для размещения в веб контенере надо что бы это был ejb т е надо наследовать бин и реализовать интерфейсы "обращения" , а без ejb никак ? т е вот такой вариант как в статье не реализовать?
И ещё вопрос: можно ли такое приложение (без ejb) запустить на Tomcat или нужен именно веб контеннер (когда я пытался с tomcat он ругался на отсутствие javax.jms библиотеки хоть она и лежала в проекте)

Kachalovа) наличии работающего JMS-сервера)
правильно я понял, что достаточно запустить сервер , диплоить туда (данный) проект не надо
Kachalov
б) правильном задании имени службы в контексте JNDI (в Вашем случае имя подозрительно короткое, такие имя возможно если JMS-служба и приложение запущены в общей JVM, что очевидно не так)

у сервера и приложения одинаковые JAVA_HOME

спасибо большое , за помощь!!

j2eeadmin где взять эту утилиту ?