Injection of JMS Queue fails

[developer251]

Hi all !

I have a Java EE 5 application which injects JMS Queues as resources

@Resource(mappedName = "java:jboss/exported/jms/queue/mainQueue")

private Queue queue;

This works correctly on JBoss AS 7.1.1. However now I'm turning to Java EE 6 and CDI, so I've setup some Producers to create my resources

public class ResourceProducer {

@Produces  @Resource(mappedName = "java:jboss/exported/jms/queue/mainQueue")

private Queue queue;

. . . .

}

which are later injected in CDI beans:

@Inject

private Queue queue;

However now i get the following weird message:

16:42:50,809 ERROR [stderr] (http-127.0.0.1/127.0.0.1:8080-1) javax.jms.InvalidDestinationException: Not a HornetQ Destination:HornetQQueue[queue/mainQueue]

16:42:50,811 ERROR [stderr] (http-127.0.0.1/127.0.0.1:8080-1)   at org.hornetq.jms.client.HornetQSession.createProducer(HornetQSession.java:318)

I've tested this against JBoss AS 7.1.1 and 7.2.0 Alpha1

what could be the issue with it ? did I hit a bug  ?

Thanks

Max

[nickarls]

Check that you import the correct @Produces (CDI). I guess it will be a popular name...

[developer251]

Thanks for your reply Nicklas, however I have checked and I'm importing javax.enterprise.inject.Produces;

It should be the correct one.

Max

[nickarls]

So it's not an injection problem (you get not-null for the injection), the error comes when the queue is used?

[jaikiran]

Looked related to https://community.jboss.org/message/777287#777287

[nickarls]

It indeed looks like the code in

      if (destination != null && !(destination instanceof HornetQDestination))

      {

         throw new InvalidDestinationException("Not a HornetQ Destination:" + destination);

      }

But I thought there wouldn't be any proxies involved since the @Producer is @Dependent (default) scoped

[developer251]

Thanks for your replies. well the error is thown when I try to create a MessageProducer from the JMS Session:

protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

        QueueSender sender=null;

        Connection connection = null;

        Session session = null;

        try {

            connection = cf.createConnection();

            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

            MessageProducer publisher = session.createProducer(queue); // Exception !

        }

From what I can read in the other thread, it seems there is no immediate fix for it now ?

Thanks Max

[nickarls]

Does commenting out the if-statement from HornetQ and building your own version count? ;-)

[developer251]

Thanks, however looking at the code, even if I comment out the if statement there's a cast to HornetQDestination just after:

HornetQDestination jbd = (HornetQDestination)destination;

I think I'll hit a ClassCastException if I try to skip the instanceof check.......

[jbertram]

FYI - We're discussing how to deal with this on https://community.jboss.org/thread/213568.