User: kimptoc
Date: 01/05/19 16:13:11
Modified: src/main/org/jboss/test/jmsra/bean PublisherBean.java
PublisherCMPBean.java TopicPublisherBean.java
Log:
made method signature valid for ejb - to help debug jmsra test failing
Revision Changes Path
1.2 +73 -73 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.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- PublisherBean.java 2001/04/26 21:18:52 1.1
+++ PublisherBean.java 2001/05/19 23:13:11 1.2
@@ -1,6 +1,6 @@
package org.jboss.test.jmsra.bean;
-import java.rmi.RemoteException;
+import java.rmi.RemoteException;
import java.util.*;
import javax.ejb.SessionBean;
import javax.ejb.SessionContext;
@@ -10,12 +10,12 @@
public class PublisherBean implements SessionBean {
-
+
private static final String CONNECTION_JNDI =
"java:comp/env/jms/MyQueueConnection";
private static final String QUEUE_JNDI = "java:comp/env/jms/QueueName";
private static final String BEAN_JNDI = "java:comp/env/ejb/PublisherCMP";
-
+
private SessionContext ctx = null;
private Queue queue = null;
private QueueConnection queueConnection = null;
@@ -26,81 +26,81 @@
this.ctx = ctx;
}
- public void ejbCreate() throws EJBException {
+ public void ejbCreate() {
try {
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());
}
}
/**
* Send a message with a message nr in property MESSAGE_NR
*/
- public void simple(int messageNr) throws EJBException {
- sendMessage(messageNr);
+ public void simple(int messageNr) {
+ sendMessage(messageNr);
}
/**
* Try send a message with a message nr in property MESSAGE_NR,
* but set rollback only
*/
- public void simpleFail(int messageNr) throws EJBException {
- 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) throws EJBException{
- // 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 {
- try {
- h.remove(new Integer(messageNr));
- }catch(Exception e) {
- e.printStackTrace();
- }
- }
-
- }
-
- public void beanError(int messageNr) throws EJBException{
- // 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 {
- try {
- h.remove(new Integer(messageNr));
- }catch(Exception ex) {
- ex.printStackTrace();
- }
- }
+ 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());
+
}
+
+ 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 {
+ 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 {
+ try {
+ h.remove(new Integer(messageNr));
+ }catch(Exception ex) {
+ ex.printStackTrace();
+ }
+ }
+ }
+
public void ejbRemove() throws RemoteException {
if(queueConnection != null) {
try {
@@ -114,27 +114,27 @@
public void ejbActivate() {}
public void ejbPassivate() {}
- private void sendMessage(int messageNr) throws EJBException{
- QueueSession queueSession = null;
- try {
- QueueSender queueSender = null;
- TextMessage message = null;
-
- queueSession =
+ private void sendMessage(int messageNr) {
+ 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);
-
-
+ message.setText(String.valueOf(messageNr));
+ message.setIntProperty(Publisher.JMS_MESSAGE_NR, messageNr);
+ queueSender.send(message);
+
+
} catch (JMSException ex) {
-
+
ex.printStackTrace();
ctx.setRollbackOnly();
- throw new EJBException(ex.toString());
+ throw new EJBException(ex.toString());
} finally {
if (queueSession != null) {
try {
1.2 +18 -18
jbosstest/src/main/org/jboss/test/jmsra/bean/PublisherCMPBean.java
Index: PublisherCMPBean.java
===================================================================
RCS file:
/cvsroot/jboss/jbosstest/src/main/org/jboss/test/jmsra/bean/PublisherCMPBean.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- PublisherCMPBean.java 2001/04/26 21:18:52 1.1
+++ PublisherCMPBean.java 2001/05/19 23:13:11 1.2
@@ -5,12 +5,12 @@
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) any later version
- *
+ *
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
- *
+ *
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
@@ -29,46 +29,46 @@
*
* Created: Tue Apr 24 22:32:41 2001
*
- * @author
+ * @author
* @version
*/
public class PublisherCMPBean extends EntitySupport {
public Integer nr;
public PublisherCMPBean() {
-
+
}
public Integer getNr()
{
return nr;
}
-
+
public void setNr(Integer nr)
{
- this.nr = nr;
+ this.nr = nr;
}
-
- public void ok(int nr)throws EJBException {
- // Do nothing
+
+ public void ok(int nr) {
+ // Do nothing
}
- public void error(int nr)throws EJBException {
- // Roll back throug an exception
- throw new EJBException("Roll back!");
+ public void error(int nr) {
+ // Roll back throug an exception
+ throw new EJBException("Roll back!");
}
// EntityBean implementation -------------------------------------
- public Integer ejbCreate(Integer nr)
+ public Integer ejbCreate(Integer nr)
throws CreateException
- {
+ {
this.nr = nr;
return null;
}
-
- public void ejbPostCreate(Integer nr)
+
+ public void ejbPostCreate(Integer nr)
throws CreateException
- {
+ {
}
-
+
public void ejbLoad()
{
}
1.2 +74 -74
jbosstest/src/main/org/jboss/test/jmsra/bean/TopicPublisherBean.java
Index: TopicPublisherBean.java
===================================================================
RCS file:
/cvsroot/jboss/jbosstest/src/main/org/jboss/test/jmsra/bean/TopicPublisherBean.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- TopicPublisherBean.java 2001/04/26 21:18:52 1.1
+++ TopicPublisherBean.java 2001/05/19 23:13:11 1.2
@@ -1,6 +1,6 @@
package org.jboss.test.jmsra.bean;
-import java.rmi.RemoteException;
+import java.rmi.RemoteException;
import java.util.*;
import javax.ejb.SessionBean;
import javax.ejb.SessionContext;
@@ -10,12 +10,12 @@
public class TopicPublisherBean implements SessionBean {
-
+
private static final String CONNECTION_JNDI =
"java:comp/env/jms/MyTopicConnection";
private static final String TOPIC_JNDI = "java:comp/env/jms/TopicName";
private static final String BEAN_JNDI = "java:comp/env/ejb/PublisherCMP";
-
+
private SessionContext ctx = null;
private Topic topic = null;
private TopicConnection topicConnection = null;
@@ -26,81 +26,81 @@
this.ctx = ctx;
}
- public void ejbCreate() throws EJBException {
+ public void ejbCreate() {
try {
Context context = new InitialContext();
topic = (Topic)context.lookup(TOPIC_JNDI);
-
- TopicConnectionFactory factory =
(TopicConnectionFactory)context.lookup(CONNECTION_JNDI);
- topicConnection = factory.createTopicConnection();
-
+
+ TopicConnectionFactory factory =
(TopicConnectionFactory)context.lookup(CONNECTION_JNDI);
+ topicConnection = factory.createTopicConnection();
+
} catch (Exception ex) {
// JMSException or NamingException could be thrown
ex.printStackTrace();
- throw new EJBException(ex.toString());
+ throw new EJBException(ex.toString());
}
}
/**
* Send a message with a message nr in property MESSAGE_NR
*/
- public void simple(int messageNr) throws EJBException {
- sendMessage(messageNr);
+ public void simple(int messageNr) {
+ sendMessage(messageNr);
}
/**
* Try send a message with a message nr in property MESSAGE_NR,
* but set rollback only
*/
- public void simpleFail(int messageNr) throws EJBException {
- 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) throws EJBException{
- // 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 {
- try {
- h.remove(new Integer(messageNr));
- }catch(Exception e) {
- e.printStackTrace();
- }
- }
-
- }
-
- public void beanError(int messageNr) throws EJBException{
- // 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 {
- try {
- h.remove(new Integer(messageNr));
- }catch(Exception ex) {
- ex.printStackTrace();
- }
- }
+ 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());
+
}
+
+ 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 {
+ 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 {
+ try {
+ h.remove(new Integer(messageNr));
+ }catch(Exception ex) {
+ ex.printStackTrace();
+ }
+ }
+ }
+
public void ejbRemove() throws RemoteException {
if(topicConnection != null) {
try {
@@ -114,27 +114,27 @@
public void ejbActivate() {}
public void ejbPassivate() {}
- private void sendMessage(int messageNr) throws EJBException{
- TopicSession topicSession = null;
- try {
- TopicPublisher topicPublisher = null;
- TextMessage message = null;
-
- topicSession =
+ private void sendMessage(int messageNr) {
+ TopicSession topicSession = null;
+ try {
+ TopicPublisher topicPublisher = null;
+ TextMessage message = null;
+
+ topicSession =
topicConnection.createTopicSession(true, Session.AUTO_ACKNOWLEDGE);
topicPublisher = topicSession.createPublisher(topic);
-
+
message = topicSession.createTextMessage();
- message.setText(String.valueOf(messageNr));
- message.setIntProperty(Publisher.JMS_MESSAGE_NR, messageNr);
- topicPublisher.publish(message);
-
-
+ message.setText(String.valueOf(messageNr));
+ message.setIntProperty(Publisher.JMS_MESSAGE_NR, messageNr);
+ topicPublisher.publish(message);
+
+
} catch (JMSException ex) {
-
+
ex.printStackTrace();
ctx.setRollbackOnly();
- throw new EJBException(ex.toString());
+ throw new EJBException(ex.toString());
} finally {
if (topicSession != null) {
try {
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
