User: user57
Date: 01/07/03 18:27:34
Modified: src/main/org/jboss/test/jmsra/bean PublisherBean.java
Log:
o Beginning to fix the JMS RA test suite. This should run with-out any
errors, but there is still something odd about it, I think it has something
todo with the topic testing. Will look into that more tomorrow.
Revision Changes Path
1.3 +55 -54 jbosstest/src/main/org/jboss/test/jmsra/bean/PublisherBean.java
Index: PublisherBean.java
===================================================================
RCS file:
/cvsroot/jboss/jbosstest/src/main/org/jboss/test/jmsra/bean/PublisherBean.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- PublisherBean.java 2001/05/19 23:13:11 1.2
+++ PublisherBean.java 2001/07/04 01:27:34 1.3
@@ -19,6 +19,7 @@
private SessionContext ctx = null;
private Queue queue = null;
private QueueConnection queueConnection = null;
+
public PublisherBean() {
}
@@ -31,13 +32,13 @@
Context context = new InitialContext();
queue = (Queue)context.lookup(QUEUE_JNDI);
- QueueConnectionFactory factory =
(QueueConnectionFactory)context.lookup(CONNECTION_JNDI);
- queueConnection = factory.createQueueConnection();
+ QueueConnectionFactory factory =
(QueueConnectionFactory)context.lookup(CONNECTION_JNDI);
+ queueConnection = factory.createQueueConnection();
} catch (Exception ex) {
// JMSException or NamingException could be thrown
ex.printStackTrace();
- throw new EJBException(ex.toString());
+ throw new EJBException(ex.toString());
}
}
@@ -45,64 +46,64 @@
* Send a message with a message nr in property MESSAGE_NR
*/
public void simple(int messageNr) {
- sendMessage(messageNr);
+ sendMessage(messageNr);
}
+
/**
* Try send a message with a message nr in property MESSAGE_NR,
* but set rollback only
*/
public void simpleFail(int messageNr) {
- sendMessage(messageNr);
- // Roll it back, no message should be sent if transactins work
- System.err.println("DEBUG: Setting rollbackOnly");
- ctx.setRollbackOnly();
- System.err.println("DEBUG rollback set: " + ctx.getRollbackOnly());
+ sendMessage(messageNr);
+ // Roll it back, no message should be sent if transactins work
+ System.err.println("DEBUG: Setting rollbackOnly");
+ ctx.setRollbackOnly();
+ System.err.println("DEBUG rollback set: " + ctx.getRollbackOnly());
}
public void beanOk(int messageNr) {
- // DO JMS - First transaction
- sendMessage(messageNr);
- PublisherCMPHome h = null;
- try {
- // DO entity bean - Second transaction
- h = (PublisherCMPHome) new InitialContext().lookup(BEAN_JNDI);
- PublisherCMP b = h.create(new Integer(messageNr));
- b.ok(messageNr);
- }catch(Exception ex) {
- throw new EJBException("OPS exception in ok: " + ex);
- } finally {
+ // DO JMS - First transaction
+ sendMessage(messageNr);
+ PublisherCMPHome h = null;
try {
- h.remove(new Integer(messageNr));
- }catch(Exception e) {
- e.printStackTrace();
+ // DO entity bean - Second transaction
+ h = (PublisherCMPHome) new InitialContext().lookup(BEAN_JNDI);
+ PublisherCMP b = h.create(new Integer(messageNr));
+ b.ok(messageNr);
+ } catch(Exception ex) {
+ throw new EJBException("OPS exception in ok: " + ex);
+ } finally {
+ try {
+ h.remove(new Integer(messageNr));
+ } catch(Exception e) {
+ e.printStackTrace();
+ }
}
}
-
- }
public void beanError(int messageNr) {
- // DO JMS - First transaction
- sendMessage(messageNr);
- PublisherCMPHome h = null;
- try {
- // DO entity bean - Second transaction
- h = (PublisherCMPHome) new InitialContext().lookup(BEAN_JNDI);
- PublisherCMP b = h.create(new Integer(messageNr));
- b.error(messageNr);
- } catch(Exception ex) {
- throw new EJBException("Exception in erro: " + ex);
- }finally {
+ // DO JMS - First transaction
+ sendMessage(messageNr);
+ PublisherCMPHome h = null;
try {
- h.remove(new Integer(messageNr));
- }catch(Exception ex) {
- ex.printStackTrace();
+ // DO entity bean - Second transaction
+ h = (PublisherCMPHome) new InitialContext().lookup(BEAN_JNDI);
+ PublisherCMP b = h.create(new Integer(messageNr));
+ b.error(messageNr);
+ } catch(Exception ex) {
+ throw new EJBException("Exception in erro: " + ex);
+ }finally {
+ try {
+ h.remove(new Integer(messageNr));
+ }catch(Exception ex) {
+ ex.printStackTrace();
+ }
}
}
- }
public void ejbRemove() throws RemoteException {
- if(queueConnection != null) {
+ if (queueConnection != null) {
try {
queueConnection.close();
} catch (Exception e) {
@@ -115,27 +116,27 @@
public void ejbPassivate() {}
private void sendMessage(int messageNr) {
- QueueSession queueSession = null;
- try {
- QueueSender queueSender = null;
- TextMessage message = null;
+ QueueSession queueSession = null;
+ try {
+ QueueSender queueSender = null;
+ TextMessage message = null;
queueSession =
queueConnection.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
queueSender = queueSession.createSender(queue);
message = queueSession.createTextMessage();
- message.setText(String.valueOf(messageNr));
- message.setIntProperty(Publisher.JMS_MESSAGE_NR, messageNr);
- queueSender.send(message);
-
-
- } catch (JMSException ex) {
-
+ message.setText(String.valueOf(messageNr));
+ message.setIntProperty(Publisher.JMS_MESSAGE_NR, messageNr);
+ queueSender.send(message);
+ System.out.println("sent message with nr = " + messageNr);
+ }
+ catch (JMSException ex) {
ex.printStackTrace();
ctx.setRollbackOnly();
- throw new EJBException(ex.toString());
- } finally {
+ throw new EJBException(ex.toString());
+ }
+ finally {
if (queueSession != null) {
try {
queueSession.close();
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
