• Post Reply
  • Bookmark Topic Watch Topic
  • New Topic

My AsynchronousConsumer Won't Listen!

 
George Berish
Greenhorn
Posts: 22
  • Mark post as helpful
  • send pies
  • Quote
  • Report post to moderator
Hi,

I have a WebStart downloaded Java SWING client that I want to have listen continuously to a server side Queue.

I am using a JBoss local server that has a Queue configured and bound to a JNDI name of "queue/goAdminOut".

I know that the queue exists and has a message waiting, because I can see it on the JBoss JMX web-console (see console screen print below).

Here is the relevant code.

1. Two classes that mimic my client.

TestConsumerView
-- A JFrame that stays alive till it is closed.

TestConsumer
-- An object that is instantiated as a field in TestConsumerView
-- It establishes the connection, session and message consumer with a selector. It also sets a Listener on the consumer.

2. The command screen print when I run TestConsumerView

3. A screen print from the JBoss JMX web console confirming that the message is in the queue.

TestConsumerView Code
TestConsumer Code
Screen Output
WEB CONSOLE OUTPUT
 
George Berish
Greenhorn
Posts: 22
  • Mark post as helpful
  • send pies
  • Quote
  • Report post to moderator
SORRY! I mistakenly put two copies of TestConsumerView above and left out TestConsumer.

Here is the missing code:
 
Jaikiran Pai
Marshal
Pie
Posts: 10447
227
IntelliJ IDE Ubuntu
  • Mark post as helpful
  • send pies
  • Quote
  • Report post to moderator
Hi,
Are your send and receive operations in the same transactions? If yes, then the send and receive operations need to be separated out into 2 different transactions.

If they are already in different transaction, then try sending/receiving the message without the message selector, so that you can narrow down on the problem.
 
  • Post Reply
  • Bookmark Topic Watch Topic
  • New Topic