User: starksm
Date: 01/07/08 18:06:03
Modified: src/main/org/jboss/test/cts/jms Tag: Branch_2_4
MsgSender.java
Log:
Merge latest changes from main to the 2.4 branch
Revision Changes Path
No revision
No revision
1.1.2.1 +8 -11 jbosstest/src/main/org/jboss/test/cts/jms/MsgSender.java
Index: MsgSender.java
===================================================================
RCS file: /cvsroot/jboss/jbosstest/src/main/org/jboss/test/cts/jms/MsgSender.java,v
retrieving revision 1.1
retrieving revision 1.1.2.1
diff -u -r1.1 -r1.1.2.1
--- MsgSender.java 2001/03/02 03:11:28 1.1
+++ MsgSender.java 2001/07/09 01:06:03 1.1.2.1
@@ -20,14 +20,6 @@
public MsgSender ( )
{
- try
- {
- init( new InitialContext(), QUEUE);
- }
- catch(Exception ex)
- {
- ex.printStackTrace();
- }
}
/**
@@ -58,20 +50,25 @@
public void close()
throws JMSException
{
- qsender.close();
- qsession.close();
- qcon.close();
+ if( qcon != null ) {
+ qsender.close();
+ qsession.close();
+ qcon.close();
+ qcon = null;
+ }
}
public void sendMsg( String message )
{
try
{
+ init( new InitialContext(), QUEUE);
System.out.println("Sending a message.." );
qsender = qsession.createSender(queue);
msg = qsession.createTextMessage();
msg.setText(message);
qsender.send(msg);
+ close();
}
catch(Exception ex)
{
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
