[jboss-user] [Messaging, JMS & JBossMQ] - Unable to Connect to Connection Factory
HI I am a newbie.to JBoss..I am using JbossIDE...JemsInstaller...
I selected ejb3.0 option while installing...
Here is my Client code which sends messages to JMS queue...
@Resource(mappedName = "java:JmsXA")
| private static ConnectionFactory connectionFactory;
| @Resource(mappedName = "queue/myqueue")
| private static Queue queue;
| public static void main(String[] args) {
| final int NUM_MSGS = 3;
| try {
| connection = connectionFactory.createConnection();
| session = connection.createSession(false,AUTO_ACKNOWLEDGE);
| messageProducer = session.createProducer(queue);
| message = session.createTextMessage();
|
| for (int i = 0; i < NUM_MSGS; i++) {
| message.setText("This is message " + (i + 1));
| System.out.println("Sending message: " +
message.getText());
| messageProducer.send(message);
| }
|
But The ConnectionFactory object after @resource is null...
If i try to lookup using IntiallookUp()
it is giving this error:
JmsXA not bound
If i use ConnectionFactory in the place of JmsXA
It will give unmarshelled exception....
In the server side i am not using any deployment descriptor as i am using EJB3.0
MDB looks like this:
@MessageDriven(activationConfig =
| {
| @ActivationConfigProperty(propertyName="messagingType",
propertyValue="javax.jms.MessageListener"),
| @ActivationConfigProperty(propertyName="destinationType",
propertyValue="javax.jms.Queue"),
| @ActivationConfigProperty(propertyName="Destination",
propertyValue="testqueue"),
| @ActivationConfigProperty(propertyName="ConnectionFactoryName",
propertyValue="ConnectionFactory"),
| @ActivationConfigProperty(propertyName="Transacted",
propertyValue="true"),
| @ActivationConfigProperty(propertyName="Xa",
propertyValue="true"),
| @ActivationConfigProperty(propertyName="DeliveryOption",
propertyValue="B"),
| @ActivationConfigProperty(propertyName="SubscriptionDurability",
propertyValue="Durable"),
| @ActivationConfigProperty(propertyName="MaxPoolSize",
propertyValue="20"),
| @ActivationConfigProperty(propertyName="MaxMessages",
propertyValue="1"),
| @ActivationConfigProperty(propertyName="resourceAdaptorName",
propertyValue="swiftmq.rar")
| })
|
| public class AnnotatedTestMDBBean implements MessageListener {
|
| public void onMessage(Message arg0) {
| if(arg0 instanceof TextMessage){
| TextMessage tm = (TextMessage)arg0;
| try{
| String text = tm.getText();
| System.out.println("Received text:"+text);
| }catch(JMSException e){
| e.printStackTrace();
| }
| }
|
|
|
Is there anything i have to use....
Any links or tutorials are welcome....
Thanks in advance...
Gopal V
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4046456#...
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&a...