[jboss-user] [JBoss Messaging] - Re: JBoss Messaging not working as expected
Hi. Finally i managed to create a jira task and attached my eclipse project. If anyone could have a look at it and help me it would be great. Here is the link to jira: https://jira.jboss.org/jira/browse/JBMESSAGING-1684 Thanks in advance. @gaohoward: If i use 1 queue it works just fine. Even with 5 queues it works most of the time but with for example 10 queues i never successfully finished a test. -Alex View the original post : http://www.jboss.org/index.html?module=bbop=viewtopicp=4243428#4243428 Reply to the post : http://www.jboss.org/index.html?module=bbop=postingmode=replyp=4243428 ___ jboss-user mailing list jboss-user@lists.jboss.org https://lists.jboss.org/mailman/listinfo/jboss-user
[jboss-user] [JBoss Messaging] - Re: JBoss Messaging not working as expected
That's great Alex. I'll take a look. Thanks. Howard View the original post : http://www.jboss.org/index.html?module=bbop=viewtopicp=4243430#4243430 Reply to the post : http://www.jboss.org/index.html?module=bbop=postingmode=replyp=4243430 ___ jboss-user mailing list jboss-user@lists.jboss.org https://lists.jboss.org/mailman/listinfo/jboss-user
[jboss-user] [JBoss Messaging] - Re: JBoss Messaging not working as expected
Hi, I did a simple test as follows: 1. start up a JBM node which has 5 queues deployed. They are A, B, C, D, E 2. start 5 processes on another machine. Each process continuously sends and receive messages from a different queue. My results is that all the process works normally, all messages sent have been received. My question is how long before you find the message delivering start to slow down? View the original post : http://www.jboss.org/index.html?module=bbop=viewtopicp=4237903#4237903 Reply to the post : http://www.jboss.org/index.html?module=bbop=postingmode=replyp=4237903 ___ jboss-user mailing list jboss-user@lists.jboss.org https://lists.jboss.org/mailman/listinfo/jboss-user
[jboss-user] [JBoss Messaging] - Re: JBoss Messaging not working as expected
Hi! Can you please tell me the link to JIRA and what do you mean with self contained test? Do you mean the source of the program i am using? So long! Alex View the original post : http://www.jboss.org/index.html?module=bbop=viewtopicp=4237597#4237597 Reply to the post : http://www.jboss.org/index.html?module=bbop=postingmode=replyp=4237597 ___ jboss-user mailing list jboss-user@lists.jboss.org https://lists.jboss.org/mailman/listinfo/jboss-user
[jboss-user] [JBoss Messaging] - Re: JBoss Messaging not working as expected
https://jira.jboss.org/jira/browse/JBMESSAGING If you have a program that can reproduce the issue, it will be perfect for us to solve it. Thanks. View the original post : http://www.jboss.org/index.html?module=bbop=viewtopicp=4237610#4237610 Reply to the post : http://www.jboss.org/index.html?module=bbop=postingmode=replyp=4237610 ___ jboss-user mailing list jboss-user@lists.jboss.org https://lists.jboss.org/mailman/listinfo/jboss-user
[jboss-user] [JBoss Messaging] - Re: JBoss Messaging not working as expected
Hi. I've now tried using JBoss AS 5.0.1GA as suggested but the problem remains the same. Any advice? Alex View the original post : http://www.jboss.org/index.html?module=bbop=viewtopicp=4236670#4236670 Reply to the post : http://www.jboss.org/index.html?module=bbop=postingmode=replyp=4236670 ___ jboss-user mailing list jboss-user@lists.jboss.org https://lists.jboss.org/mailman/listinfo/jboss-user
[jboss-user] [JBoss Messaging] - Re: JBoss Messaging not working as expected
If you create a JIRA and attach a self contained test program that we can run to replicate the issue, someone can take a look at it. View the original post : http://www.jboss.org/index.html?module=bbop=viewtopicp=4236674#4236674 Reply to the post : http://www.jboss.org/index.html?module=bbop=postingmode=replyp=4236674 ___ jboss-user mailing list jboss-user@lists.jboss.org https://lists.jboss.org/mailman/listinfo/jboss-user
[jboss-user] [JBoss Messaging] - Re: JBoss Messaging not working as expected
Does it always happen or sometimes? View the original post : http://www.jboss.org/index.html?module=bbop=viewtopicp=4230319#4230319 Reply to the post : http://www.jboss.org/index.html?module=bbop=postingmode=replyp=4230319 ___ jboss-user mailing list jboss-user@lists.jboss.org https://lists.jboss.org/mailman/listinfo/jboss-user
[jboss-user] [JBoss Messaging] - Re: JBoss Messaging not working as expected
How do you know messages are left in the queue? when are you starting the consumers, messages can be buffered by a client so it may be that the first consumer to connect has all the messages sitting in its buffer. Post your code so we can take a look. View the original post : http://www.jboss.org/index.html?module=bbop=viewtopicp=4230379#4230379 Reply to the post : http://www.jboss.org/index.html?module=bbop=postingmode=replyp=4230379 ___ jboss-user mailing list jboss-user@lists.jboss.org https://lists.jboss.org/mailman/listinfo/jboss-user
[jboss-user] [JBoss Messaging] - Re: JBoss Messaging not working as expected
Hi.
I had a look in the JMX interface and there it says that 2 messages are pending
in the queue.
There is only one producer, consumer on each queue. So it should not happen
that one consumer buffers messages from another queue.
The producer should send 10.000 messages to one queue and the receivers expect
to receive 10.000 messages. The receivers will prompt a message when all
messages are received.
Producer:
initialization:
| public void init(String ip, int port, String qname) throws Exception {
| connection = createConnection(ip, port);
| connection.start();
| session = connection
| .createQueueSession(false,
Session.AUTO_ACKNOWLEDGE);
| try {
| q = (Queue) ctx.lookup(qname);
| } catch (Exception e) {
| q = session.createQueue(qname);
| ctx.bind(qname, q);
| }
| producer = session.createSender(q);
| }
|
| public QueueConnection createConnection(String ip, int port)
| throws NamingException, JMSException {
| try {
| ctx = (InitialContext) createContext(ip, 1099);
| } catch (Exception e) {
| e.printStackTrace();
| }
| QueueConnectionFactory qcf = (QueueConnectionFactory) ctx
| .lookup(ConnectionFactory);
| return qcf.createQueueConnection();
| }
|
| protected Context createContext(String ip, int port) throws Exception {
| String host = jnp:// + ip + : + port;
| return createContext(host);
| }
|
| protected Context createContext(String host) throws Exception {
| Properties props = new Properties();
|
| props.put(Context.INITIAL_CONTEXT_FACTORY,
| org.jnp.interfaces.NamingContextFactory);
| props.put(Context.PROVIDER_URL, host);
| props.put(Context.URL_PKG_PREFIXES,
| org.jboss.naming:org.jnp.interfaces);
|
| return new InitialContext(props);
| }
|
sending messages:
| public void sendMsg(String msgtxt) throws Exception {
| TextMessage simpleMessage = session.createTextMessage();
| simpleMessage.setText(msgtxt);
| producer.send(simpleMessage);
| }
|
Consumer implements MessageListener:
inititalization:
| private void init(String ip, int port, String qname) throws JMSException,
| NamingException {
| connection = createConnection(ip, port);
| connection.start();
| session = connection.createQueueSession(false,
| QueueSession.AUTO_ACKNOWLEDGE);
| Queue q = session.createQueue(qname);
| msgConsumer = session.createReceiver(q);
| msgConsumer.setMessageListener(this);
| }
|
| public QueueConnection createConnection(String ip, int port)
| throws NamingException, JMSException {
| try {
| ctx = (InitialContext) createContext(ip, 1099);
| } catch (Exception e) {
| e.printStackTrace();
| }
| ConnectionFactory tmp = (ConnectionFactory) ctx
| .lookup(ConnectionFactory);
| QueueConnectionFactory qcf = (QueueConnectionFactory) tmp;
| return qcf.createQueueConnection();
| }
|
| // the default method
| protected Context createContext(String ip, int port) throws Exception {
| String host = jnp:// + ip + : + port;
| return createContext(host);
| }
|
| protected Context createContext(String host) throws Exception {
| Properties props = new Properties();
|
| props.put(Context.INITIAL_CONTEXT_FACTORY,
| org.jnp.interfaces.NamingContextFactory);
| props.put(Context.PROVIDER_URL, host);
| props.put(Context.URL_PKG_PREFIXES,
| org.jboss.naming:org.jnp.interfaces);
|
| return new InitialContext(props);
| }
|
receiving messages:
| public void onMessage(Message msg) {
| cnt = cnt + 1;
| TextMessage txtMsg = (TextMessage) msg;
| if (cnt == msgToReceive) {
| running = !running;
| System.out.println(getClientId() + Received all msg @
| + System.currentTimeMillis());
| cnt = 0;
| } else if (cnt msgToReceive) {
| cnt = 0;
| }
| }
|
View the original post :
[jboss-user] [JBoss Messaging] - Re: JBoss Messaging not working as expected
Can you try jboss 5.0.1.GA, messaging is the default jms provider with this. View the original post : http://www.jboss.org/index.html?module=bbop=viewtopicp=4230409#4230409 Reply to the post : http://www.jboss.org/index.html?module=bbop=postingmode=replyp=4230409 ___ jboss-user mailing list jboss-user@lists.jboss.org https://lists.jboss.org/mailman/listinfo/jboss-user
[jboss-user] [JBoss Messaging] - Re: JBoss Messaging not working as expected
Thanks for the advice, I'm going to try it! View the original post : http://www.jboss.org/index.html?module=bbop=viewtopicp=4230410#4230410 Reply to the post : http://www.jboss.org/index.html?module=bbop=postingmode=replyp=4230410 ___ jboss-user mailing list jboss-user@lists.jboss.org https://lists.jboss.org/mailman/listinfo/jboss-user
