7:15 a.m.
Ingress JMS bridging results in endless invocations of observer method
----------------------------------------------------------------------
Key: SEAMJMS-65
URL: https://issues.jboss.org/browse/SEAMJMS-65
Project: Seam JMS
Issue Type: Bug
Components: Event Bridging
Affects Versions: 3.1.0.CR1
Environment: JBAS 7.1.0.Beta1b
Reporter: Thorsten Kunz
I have defined this interface method:
@Outbound public void routeStringToQueue(@Observes String string, @JmsDestination(jndiName
= "queue/pegasusMessage") Queue queue);
@Inbound public void routeStringsFromQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
Then create this observer method:
public void inboundMessageTest(@Observes @Inbound String message) { ... }
Once a String type event is fired this is being logged:
13:59:26,095 INFO [org.jboss.seam.jms.MessageManagerImpl]
(http-localhost-127.0.0.1-8080-1) Routing destination HornetQQueue[pegasusMessageQueue]
with message HornetQMessage[null]:PERSISTENT
13:59:26,108 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,110 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,337 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,339 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,386 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,387 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
[ ... and so on ... ]
It works just fine if I replace the observer method with a regular MDB for this
destination.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
7:26 a.m.
[
https://issues.jboss.org/browse/SEAMJMS-65?page=com.atlassian.jira.plugin...
]
John Ament commented on SEAMJMS-65:
-----------------------------------
Please take a look at section 5.2.1 of the document. Yes, it is possible to end up with
an infinite loop of messages if you do not trigger events correctly. This is because
CDI's event life cycle does not share qualifiers between the callee and the caller.
http://docs.jboss.org/seam/3/jms/latest/reference/en-US/html_single/
Ingress JMS bridging results in endless invocations of observer
method
----------------------------------------------------------------------
Key: SEAMJMS-65
URL: https://issues.jboss.org/browse/SEAMJMS-65
Project: Seam JMS
Issue Type: Bug
Components: Event Bridging
Affects Versions: 3.1.0.CR1
Environment: JBAS 7.1.0.Beta1b
Reporter: Thorsten Kunz
I have defined this interface method:
@Outbound public void routeStringToQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
@Inbound public void routeStringsFromQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
Then create this observer method:
public void inboundMessageTest(@Observes @Inbound String message) { ... }
Once a String type event is fired this is being logged:
13:59:26,095 INFO [org.jboss.seam.jms.MessageManagerImpl]
(http-localhost-127.0.0.1-8080-1) Routing destination HornetQQueue[pegasusMessageQueue]
with message HornetQMessage[null]:PERSISTENT
13:59:26,108 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,110 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,337 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,339 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,386 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,387 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
[ ... and so on ... ]
It works just fine if I replace the observer method with a regular MDB for this
destination.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
8:07 a.m.
[
https://issues.jboss.org/browse/SEAMJMS-65?page=com.atlassian.jira.plugin...
]
Thorsten Kunz commented on SEAMJMS-65:
--------------------------------------
I was reading this before I opened the ticket but it never worked no matter how I was
firing the event:
1.
@Inject
@Outbound
@Routing(RouteType.EGRESS)
private Event<String> stringEvent;
2.
@Inject
@Outbound
private Event<String> stringEvent;
3.
@Inject
@Routing(RouteType.EGRESS)
private Event<String> stringEvent;
[...]
stringEvent.fire("some message");
[...]
Allways ends up calling the observer method in an infinite loop.
Ingress JMS bridging results in endless invocations of observer
method
----------------------------------------------------------------------
Key: SEAMJMS-65
URL: https://issues.jboss.org/browse/SEAMJMS-65
Project: Seam JMS
Issue Type: Bug
Components: Event Bridging
Affects Versions: 3.1.0.CR1
Environment: JBAS 7.1.0.Beta1b
Reporter: Thorsten Kunz
I have defined this interface method:
@Outbound public void routeStringToQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
@Inbound public void routeStringsFromQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
Then create this observer method:
public void inboundMessageTest(@Observes @Inbound String message) { ... }
Once a String type event is fired this is being logged:
13:59:26,095 INFO [org.jboss.seam.jms.MessageManagerImpl]
(http-localhost-127.0.0.1-8080-1) Routing destination HornetQQueue[pegasusMessageQueue]
with message HornetQMessage[null]:PERSISTENT
13:59:26,108 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,110 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,337 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,339 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,386 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,387 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
[ ... and so on ... ]
It works just fine if I replace the observer method with a regular MDB for this
destination.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
8:32 a.m.
[
https://issues.jboss.org/browse/SEAMJMS-65?page=com.atlassian.jira.plugin...
]
John Ament commented on SEAMJMS-65:
-----------------------------------
Can you attach your full code:
- Observer Method Interface
- Code that fires the event.
- Code that observes the event.
Ingress JMS bridging results in endless invocations of observer
method
----------------------------------------------------------------------
Key: SEAMJMS-65
URL: https://issues.jboss.org/browse/SEAMJMS-65
Project: Seam JMS
Issue Type: Bug
Components: Event Bridging
Affects Versions: 3.1.0.CR1
Environment: JBAS 7.1.0.Beta1b
Reporter: Thorsten Kunz
I have defined this interface method:
@Outbound public void routeStringToQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
@Inbound public void routeStringsFromQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
Then create this observer method:
public void inboundMessageTest(@Observes @Inbound String message) { ... }
Once a String type event is fired this is being logged:
13:59:26,095 INFO [org.jboss.seam.jms.MessageManagerImpl]
(http-localhost-127.0.0.1-8080-1) Routing destination HornetQQueue[pegasusMessageQueue]
with message HornetQMessage[null]:PERSISTENT
13:59:26,108 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,110 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,337 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,339 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,386 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,387 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
[ ... and so on ... ]
It works just fine if I replace the observer method with a regular MDB for this
destination.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
8:35 a.m.
[
https://issues.jboss.org/browse/SEAMJMS-65?page=com.atlassian.jira.plugin...
]
John Ament reassigned SEAMJMS-65:
---------------------------------
Assignee: John Ament
Ingress JMS bridging results in endless invocations of observer
method
----------------------------------------------------------------------
Key: SEAMJMS-65
URL: https://issues.jboss.org/browse/SEAMJMS-65
Project: Seam JMS
Issue Type: Bug
Components: Event Bridging
Affects Versions: 3.1.0.CR1
Environment: JBAS 7.1.0.Beta1b
Reporter: Thorsten Kunz
Assignee: John Ament
I have defined this interface method:
@Outbound public void routeStringToQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
@Inbound public void routeStringsFromQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
Then create this observer method:
public void inboundMessageTest(@Observes @Inbound String message) { ... }
Once a String type event is fired this is being logged:
13:59:26,095 INFO [org.jboss.seam.jms.MessageManagerImpl]
(http-localhost-127.0.0.1-8080-1) Routing destination HornetQQueue[pegasusMessageQueue]
with message HornetQMessage[null]:PERSISTENT
13:59:26,108 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,110 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,337 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,339 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,386 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,387 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
[ ... and so on ... ]
It works just fine if I replace the observer method with a regular MDB for this
destination.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
10:28 a.m.
[
https://issues.jboss.org/browse/SEAMJMS-65?page=com.atlassian.jira.plugin...
]
Thorsten Kunz updated SEAMJMS-65:
---------------------------------
Attachment: EventGenerator.java
RoutingInterface.java
TestMessageConsumer.java
As requested the 3 classes
Ingress JMS bridging results in endless invocations of observer
method
----------------------------------------------------------------------
Key: SEAMJMS-65
URL: https://issues.jboss.org/browse/SEAMJMS-65
Project: Seam JMS
Issue Type: Bug
Components: Event Bridging
Affects Versions: 3.1.0.CR1
Environment: JBAS 7.1.0.Beta1b
Reporter: Thorsten Kunz
Assignee: John Ament
Attachments: EventGenerator.java, RoutingInterface.java,
TestMessageConsumer.java
I have defined this interface method:
@Outbound public void routeStringToQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
@Inbound public void routeStringsFromQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
Then create this observer method:
public void inboundMessageTest(@Observes @Inbound String message) { ... }
Once a String type event is fired this is being logged:
13:59:26,095 INFO [org.jboss.seam.jms.MessageManagerImpl]
(http-localhost-127.0.0.1-8080-1) Routing destination HornetQQueue[pegasusMessageQueue]
with message HornetQMessage[null]:PERSISTENT
13:59:26,108 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,110 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,337 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,339 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,386 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,387 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
[ ... and so on ... ]
It works just fine if I replace the observer method with a regular MDB for this
destination.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
8:33 p.m.
[
https://issues.jboss.org/browse/SEAMJMS-65?page=com.atlassian.jira.plugin...
]
John Ament commented on SEAMJMS-65:
-----------------------------------
Ok... your routing isn't quite right, which is why the cyclic messaging is happening.
When you map using routetype.both, as shown in the test case, it should work as expected
@Routing(RouteType.BOTH)
public void obsDoubleToTopic(@Observes Double d, @JmsDestination(jndiName =
"jms/T2") Topic t);
Since you're putting everything in an interface, the @Routing is not necessary, since
it is assumed by directional when none present. At your event injection point, you'll
use:
@Inject
@Outbound
private Event<String> stringEvent;
your consumer looks correct.
Ingress JMS bridging results in endless invocations of observer
method
----------------------------------------------------------------------
Key: SEAMJMS-65
URL: https://issues.jboss.org/browse/SEAMJMS-65
Project: Seam JMS
Issue Type: Bug
Components: Event Bridging
Affects Versions: 3.1.0.CR1
Environment: JBAS 7.1.0.Beta1b
Reporter: Thorsten Kunz
Assignee: John Ament
Attachments: EventGenerator.java, RoutingInterface.java,
TestMessageConsumer.java
I have defined this interface method:
@Outbound public void routeStringToQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
@Inbound public void routeStringsFromQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
Then create this observer method:
public void inboundMessageTest(@Observes @Inbound String message) { ... }
Once a String type event is fired this is being logged:
13:59:26,095 INFO [org.jboss.seam.jms.MessageManagerImpl]
(http-localhost-127.0.0.1-8080-1) Routing destination HornetQQueue[pegasusMessageQueue]
with message HornetQMessage[null]:PERSISTENT
13:59:26,108 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,110 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,337 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,339 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,386 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,387 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
[ ... and so on ... ]
It works just fine if I replace the observer method with a regular MDB for this
destination.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
3:19 a.m.
[
https://issues.jboss.org/browse/SEAMJMS-65?page=com.atlassian.jira.plugin...
]
Thorsten Kunz commented on SEAMJMS-65:
--------------------------------------
Well I only put the @Routing on the injected field to try different things. It was not
there in the first version I wrote.
Anyway I changed what you suggested but I am afraid it is still looping.
Here is how the routing interface looks like now:
@Routing(RouteType.BOTH)
public void bidirectionalStringQueue(@Observes String string, @JmsDestination(jndiName =
"queue/test") Queue queue);
And here is how the event generator injection looks like:
@Inject
@Outbound
private Event<String> stringEvent;
Everything else is still as it was in the attached classes. Don't know if it helps but
here is the deployment log:
10:15:25,330 INFO [org.jboss.as.server.deployment] (MSC service thread 1-2) Starting
deployment of "mdb-test.war"
10:15:25,588 WARN [org.jboss.as.server.deployment.service-loader] (MSC service thread
1-1) Encountered invalid class name
"implClass=org.jboss.seam.jms.test.descriptor.HornetQJMSDescriptorImpl" for
service type "org.jboss.seam.jms.test.descriptor.HornetQJMSDescriptor"
10:15:25,588 WARN [org.jboss.as.server.deployment.service-loader] (MSC service thread
1-1) Encountered invalid class name
"importerClass=org.jboss.shrinkwrap.descriptor.impl.base.XMLImporter" for
service type "org.jboss.seam.jms.test.descriptor.HornetQJMSDescriptor"
10:15:25,588 WARN [org.jboss.as.server.deployment.service-loader] (MSC service thread
1-1) Encountered invalid class name "defaultName=hornetq-jms.xml" for service
type "org.jboss.seam.jms.test.descriptor.HornetQJMSDescriptor"
10:15:25,761 INFO [org.jboss.weld] (MSC service thread 1-8) Processing CDI deployment:
mdb-test.war
10:15:25,843 INFO [org.jboss.weld] (MSC service thread 1-3) Starting Services for CDI
deployment: mdb-test.war
10:15:25,862 INFO [org.jboss.weld.Version] (MSC service thread 1-3) WELD-000900 SNAPSHOT
10:15:25,881 INFO [org.jboss.weld] (MSC service thread 1-6) Starting weld service
10:15:26,035 INFO [org.jboss.solder.config.xml.bootstrap.XmlConfigExtension] (MSC service
thread 1-6) Solder Config XML provider starting...
10:15:26,036 INFO [org.jboss.solder.config.xml.bootstrap.XmlConfigExtension] (MSC service
thread 1-6) Loading XmlDocumentProvider:
org.jboss.solder.config.xml.bootstrap.ResourceLoaderXmlDocumentProvider
10:15:26,039 INFO [org.jboss.solder.config.xml.bootstrap.XmlConfigExtension] (MSC service
thread 1-6) Reading XML file:
vfs:/content/mdb-test.war/WEB-INF/lib/seam-jms-3.1.0.CR1.jar/META-INF/beans.xml
10:15:26,044 INFO [org.jboss.solder.Version] (MSC service thread 1-6) Solder null (build
id: null)
10:15:26,214 INFO [org.jboss.solder.core.CoreExtension] (MSC service thread 1-6)
Preventing class org.jboss.seam.jms.bridge.RouteManagerImpl from being installed as bean
due to @Veto annotation
10:15:26,229 INFO [org.jboss.solder.core.CoreExtension] (MSC service thread 1-6)
Preventing class org.jboss.seam.jms.bridge.EgressRoutingObserver from being installed as
bean due to @Veto annotation
10:15:27,015 INFO [org.jboss.seam.jms.Seam3JmsExtension] (MSC service thread 1-6)
Skipping annotation @javax.enterprise.event.Observes(during=IN_PROGRESS,
notifyObserver=ALWAYS)
10:15:27,016 INFO [org.jboss.seam.jms.Seam3JmsExtension] (MSC service thread 1-6)
Skipping annotation @javax.enterprise.event.Observes(during=IN_PROGRESS,
notifyObserver=ALWAYS)
10:15:27,137 INFO [org.jboss.seam.jms.Seam3JmsExtension] (MSC service thread 1-2)
Version: null (build id: null)
10:15:27,138 INFO [org.jboss.seam.jms.bridge.EgressRoutingObserver] (MSC service thread
1-2) Routing destinations: [[HornetQQueue[testQueue]]]
10:15:27,139 INFO [org.jboss.seam.jms.bridge.RouteImpl] (MSC service thread 1-2) Routing
destinations: [[HornetQQueue[testQueue]]]
10:15:27,139 INFO [org.jboss.seam.jms.bridge.IngressMessageListener] (MSC service thread
1-2) Setting route. org.jboss.seam.jms.bridge.RouteImpl@cbbaf
10:15:27,139 INFO [org.jboss.seam.jms.bridge.IngressMessageListener] (MSC service thread
1-2) Qualifiers: [@org.jboss.seam.jms.annotations.Inbound(),
@org.jboss.seam.jms.annotations.Routing(value=INGRESS)]
10:15:27,178 INFO [javax.enterprise.resource.webcontainer.jsf.config] (MSC service thread
1-2) Mojarra 2.1.3 (SNAPSHOT 20110825) für Kontext '/mdb-test' wird
initialisiert.
10:15:27,657 INFO [org.hibernate.validator.util.Version] (MSC service thread 1-2)
Hibernate Validator 4.2.0.Final
10:15:27,779 INFO [solder-servlet] (MSC service thread 1-2) Catch Integration for
Servlets enabled
10:15:27,786 INFO [org.jboss.web] (MSC service thread 1-2) registering web context:
/mdb-test
10:15:27,826 INFO [org.jboss.as.server.controller] (DeploymentScanner-threads - 2)
Deployed "mdb-test.war"
Ingress JMS bridging results in endless invocations of observer
method
----------------------------------------------------------------------
Key: SEAMJMS-65
URL: https://issues.jboss.org/browse/SEAMJMS-65
Project: Seam JMS
Issue Type: Bug
Components: Event Bridging
Affects Versions: 3.1.0.CR1
Environment: JBAS 7.1.0.Beta1b
Reporter: Thorsten Kunz
Assignee: John Ament
Attachments: EventGenerator.java, RoutingInterface.java,
TestMessageConsumer.java
I have defined this interface method:
@Outbound public void routeStringToQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
@Inbound public void routeStringsFromQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
Then create this observer method:
public void inboundMessageTest(@Observes @Inbound String message) { ... }
Once a String type event is fired this is being logged:
13:59:26,095 INFO [org.jboss.seam.jms.MessageManagerImpl]
(http-localhost-127.0.0.1-8080-1) Routing destination HornetQQueue[pegasusMessageQueue]
with message HornetQMessage[null]:PERSISTENT
13:59:26,108 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,110 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,337 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,339 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,386 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,387 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
[ ... and so on ... ]
It works just fine if I replace the observer method with a regular MDB for this
destination.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
6:01 a.m.
[
https://issues.jboss.org/browse/SEAMJMS-65?page=com.atlassian.jira.plugin...
]
Thorsten Kunz commented on SEAMJMS-65:
--------------------------------------
I deployed the same war file to a JBAS 7.0.2.Final running with standalone-preview profile
and it also loops.
Ingress JMS bridging results in endless invocations of observer
method
----------------------------------------------------------------------
Key: SEAMJMS-65
URL: https://issues.jboss.org/browse/SEAMJMS-65
Project: Seam JMS
Issue Type: Bug
Components: Event Bridging
Affects Versions: 3.1.0.CR1
Environment: JBAS 7.1.0.Beta1b
Reporter: Thorsten Kunz
Assignee: John Ament
Attachments: EventGenerator.java, RoutingInterface.java,
TestMessageConsumer.java
I have defined this interface method:
@Outbound public void routeStringToQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
@Inbound public void routeStringsFromQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
Then create this observer method:
public void inboundMessageTest(@Observes @Inbound String message) { ... }
Once a String type event is fired this is being logged:
13:59:26,095 INFO [org.jboss.seam.jms.MessageManagerImpl]
(http-localhost-127.0.0.1-8080-1) Routing destination HornetQQueue[pegasusMessageQueue]
with message HornetQMessage[null]:PERSISTENT
13:59:26,108 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,110 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,337 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,339 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,386 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,387 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
[ ... and so on ... ]
It works just fine if I replace the observer method with a regular MDB for this
destination.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
6:31 a.m.
[
https://issues.jboss.org/browse/SEAMJMS-65?page=com.atlassian.jira.plugin...
]
Thorsten Kunz commented on SEAMJMS-65:
--------------------------------------
Am I the only one experiencing this issue or can someone else reproduce this? The issue is
still there in Seam 3.1.0.Final on JBAS 7.1.0.CR1.
Ingress JMS bridging results in endless invocations of observer
method
----------------------------------------------------------------------
Key: SEAMJMS-65
URL: https://issues.jboss.org/browse/SEAMJMS-65
Project: Seam JMS
Issue Type: Bug
Components: Event Bridging
Affects Versions: 3.1.0.CR1
Environment: JBAS 7.1.0.Beta1b
Reporter: Thorsten Kunz
Assignee: John Ament
Attachments: EventGenerator.java, RoutingInterface.java,
TestMessageConsumer.java
I have defined this interface method:
@Outbound public void routeStringToQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
@Inbound public void routeStringsFromQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
Then create this observer method:
public void inboundMessageTest(@Observes @Inbound String message) { ... }
Once a String type event is fired this is being logged:
13:59:26,095 INFO [org.jboss.seam.jms.MessageManagerImpl]
(http-localhost-127.0.0.1-8080-1) Routing destination HornetQQueue[pegasusMessageQueue]
with message HornetQMessage[null]:PERSISTENT
13:59:26,108 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,110 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,337 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,339 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,386 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,387 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
[ ... and so on ... ]
It works just fine if I replace the observer method with a regular MDB for this
destination.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
3:18 a.m.
[
https://issues.jboss.org/browse/SEAMJMS-65?page=com.atlassian.jira.plugin...
]
Andries Ehlers commented on SEAMJMS-65:
---------------------------------------
I'm experiencing exactly the same issue on my side with Seam 3.1.0 Final and JBoss
7.0.2.
Anybody got any ideas?
Ingress JMS bridging results in endless invocations of observer
method
----------------------------------------------------------------------
Key: SEAMJMS-65
URL: https://issues.jboss.org/browse/SEAMJMS-65
Project: Seam JMS
Issue Type: Bug
Components: Event Bridging
Affects Versions: 3.1.0.CR1
Environment: JBAS 7.1.0.Beta1b
Reporter: Thorsten Kunz
Assignee: John Ament
Attachments: EventGenerator.java, RoutingInterface.java,
TestMessageConsumer.java
I have defined this interface method:
@Outbound public void routeStringToQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
@Inbound public void routeStringsFromQueue(@Observes String string,
@JmsDestination(jndiName = "queue/pegasusMessage") Queue queue);
Then create this observer method:
public void inboundMessageTest(@Observes @Inbound String message) { ... }
Once a String type event is fired this is being logged:
13:59:26,095 INFO [org.jboss.seam.jms.MessageManagerImpl]
(http-localhost-127.0.0.1-8080-1) Routing destination HornetQQueue[pegasusMessageQueue]
with message HornetQMessage[null]:PERSISTENT
13:59:26,108 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,110 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,337 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,339 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,386 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,387 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
13:59:26,403 INFO [org.jboss.seam.jms.AbstractMessageListener] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Received a message
13:59:26,404 INFO [org.jboss.seam.jms.MessageManagerImpl] (Thread-1
(group:HornetQ-client-global-threads-1800568262)) Routing destination
HornetQQueue[pegasusMessageQueue] with message HornetQMessage[null]:PERSISTENT
[ ... and so on ... ]
It works just fine if I replace the observer method with a regular MDB for this
destination.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
4497
days inactive
4551
days old
10 comments
7 participants
participants (7)
-
Andries Ehlers (JIRA) -
John Ament (Assigned) (JIRA)
-
John Ament (Commented) (JIRA)
-
Thorsten Kunz (Commented) (JIRA)
-
Thorsten Kunz (Created) (JIRA)
-
Thorsten Kunz (JIRA)
-
Thorsten Kunz (Updated) (JIRA)