Гость
Войти | Профиль | Очистить
Целевая тема:
Создать новую тему:
Автор:
Действия ...
Форумы / Java [игнор отключен] [закрыт для гостей] / jms+jboss / 11 сообщений из 11, страница 1 из 1
07.06.2007, 10:20:15
    #34580032
ИгорьМ
ИгорьМ
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
jms+jboss
при реализации jms с queue или topic используемая очередь ( топик) должны быть заранее описаны в xml файлах у jboss, а как быть в ситуации когда queue или topic необходимо создавать ( и регистрировать у web серв.) из программы , как такое можно сделать?


Подрузамеваю, что для этих целей используется jboss api , но не совсем понятно как это делать.

может быть у кого -то есть пример?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
09.06.2007, 09:05:19
    #34585534
expp
expp
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
jms+jboss
деплоим MBean куи через JMX. ничего сложного

а вобще бредятина. MDB тоже будете в динамике конфигурировать?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
09.06.2007, 15:17:21
    #34586361
ИгорьМ
ИгорьМ
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
jms+jboss
Мне надо, что бы сообщения получали разные клиенты зарание их число не известно. Топик не подходит т к класс получателя должен "жить" что бы получить сообщения, а у меня он создаётся только когда клиент лезет за сообщением.
написал такую вещь:

Код: plaintext
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
 public   class  JBossMQAdmin {
     public  JBossMQAdmin()  throws  Exception {
       
        ArrayList servers = MBeanServerFactory.findMBeanServer( null );
         if  (servers ==  null ){
            System.out.println("No MBeanServer found.");
        }
        MBeanServer server = (MBeanServer)servers.get( 0 );

        //MBeanServer server = MBeanServerLocator.locateJBoss();
        
        
        ObjectName objectName = objectName =  new  ObjectName("jboss:service=DeploymentService");


        DeploymentServiceMBean dservice =
        (DeploymentServiceMBean)MBeanServerInvocationHandler.newProxyInstance(
                                                 server,
                                                 objectName,
                                                 DeploymentServiceMBean. class ,
                                                 false);
        
        HashMap properties =  new  HashMap();
        Map map =  null ;
            map.put("QueueName", "Q");

        String  module = dservice.createModule("myqueue", "jms-queue", properties);
        dservice.deployModuleAsynch(module);

    }

Почему не так
Код: plaintext
1.
2.
3.
4.
5.
6.
7.
ArrayList servers = MBeanServerFactory.findMBeanServer( null );
         if  (servers ==  null ){
            System.out.println("No MBeanServer found.");
        }
        MBeanServer server = (MBeanServer)servers.get( 0 );
и не так
Код: plaintext
1.
MBeanServer server = MBeanServerLocator.locateJBoss();

сервер не находится?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
09.06.2007, 17:10:33
    #34586601
expp
expp
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
jms+jboss
я извиняюсь, но выглядит, как полная ахинея...

задачу обрисуйте подробнее, что? кому получать?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
09.06.2007, 17:54:31
    #34586696
ИгорьМ
ИгорьМ
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
jms+jboss
exppя извиняюсь, но выглядит, как полная ахинея...

задачу обрисуйте подробнее, что? кому получать?

Попарное Общение нескольких людей через инет .

Примерно так:

setMessage - класс который осуществляет отправку сообщения ( jms)
getMessage- класс который получает сообщение

Клиент обращается по какому - то адресу (в "расспределитель" тут ведётся список пар клиентов, клиент первый )ему выдаётся id с которым он вызывает метод
класса setMessage для отправки сообщения, где id - это имя очереди.
setMessage.send(String id);
Появляется ещё клиент, обращается в "расспределитель" в списке ищется свободный польз. если находится, то этому клиенту возвращается тот же id по которому он вызывает методы классов setMessage , getMessage.
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
09.06.2007, 17:56:09
    #34586701
ИгорьМ
ИгорьМ
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
jms+jboss
если нет свободных, то ему присваевается новый id , с этим именем "id" создаётся новая очередь....
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
09.06.2007, 17:59:35
    #34586705
ИгорьМ
ИгорьМ
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
jms+jboss
может вы подскажите , каким образом узнаётся эта часть пути : localhost/jndi/rmi:/JMXConnector
( а конкретно название класса JMXConnector к которому надо обратится)

JMXServiceURL url =
new JMXServiceURL("service:jmx:rmi://localhost/jndi/rmi:/JMXConnector");
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
09.06.2007, 19:10:47
    #34586804
expp
expp
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
jms+jboss
1. боюсь jms не для этого
2. у сообщений можно выставлять значения полей по которым они могут фильтроваться
3. может
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
13.06.2007, 10:55:39
    #34590969
ИгорьМ
ИгорьМ
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
jms+jboss
expp2. у сообщений можно выставлять значения полей по которым они могут фильтроваться


Так при использование Очереди мне сначала придётся получить сообщение а потом уже смотреть , для меня оно или нет ( по значю поля) , а остальные клиенты это сообщение уже не смогут получить. А использовать Топик я не могу т к при его исп. надо что бы экземпляр получателя был создан раньше , чем сообщение отправится.

Или я ошибаюсь?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
13.06.2007, 11:05:28
    #34591018
ИгорьМ
ИгорьМ
Гость
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
jms+jboss
ИгорьМ expp2. у сообщений можно выставлять значения полей по которым они могут фильтроваться


Так при использование Очереди мне сначала придётся получить сообщение а потом уже смотреть , для меня оно или нет ( по значю поля) , а остальные клиенты это сообщение уже не смогут получить. А использовать Топик я не могу т к при его исп. надо что бы экземпляр получателя был создан раньше , чем сообщение отправится.

Или я ошибаюсь?

Или тут поможет использовать transacted sessions?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
13.06.2007, 13:24:59
    #34591570
expp
expp
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
jms+jboss
кароч, аську писать на jms ненадо
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
Форумы / Java [игнор отключен] [закрыт для гостей] / jms+jboss / 11 сообщений из 11, страница 1 из 1
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение  
Полит. конфиден.  
созд. / загр.: 504ms
Закрыть
start [/forum/topic.php?fid=59&tablet=1&tid=2145434]:
 0ms
get settings:
 14ms
get forum list:
 22ms
check forum access:
 7ms
check topic access:
 7ms
track hit:
 54ms
get topic data:
 19ms
get forum data:
 5ms
get page messages:
 76ms
get tp. blocked users:
 3ms
others: 297ms
total:  504ms
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]