User: norbert
Date: 00/05/25 22:38:22
Modified: src/java/org/spyderMQ SpySession.java SpyTopicPublisher.java
Log:
Changes to selector ( classes )
Revision Changes Path
1.19 +13 -13 spyderMQ/src/java/org/spyderMQ/SpySession.java
Index: SpySession.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spyderMQ/SpySession.java,v
retrieving revision 1.18
retrieving revision 1.19
diff -u -r1.18 -r1.19
--- SpySession.java 2000/05/25 01:52:05 1.18
+++ SpySession.java 2000/05/26 05:38:22 1.19
@@ -28,7 +28,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.18 $
+ * @version $Revision: 1.19 $
*/
public class SpySession
implements Runnable, Session
@@ -94,21 +94,21 @@
return new SpyMapMessage();
}
- public Message createMessage() throws JMSException
+ public Message createMessage() throws JMSException
{
if (closed) throw new IllegalStateException("The session is closed");
return new SpyMessage();
}
- public ObjectMessage createObjectMessage() throws JMSException
+ public ObjectMessage createObjectMessage() throws JMSException
{
if (closed) throw new IllegalStateException("The session is closed");
return new SpyObjectMessage();
}
- public ObjectMessage createObjectMessage(Serializable object) throws
JMSException
+ public ObjectMessage createObjectMessage(Serializable object) throws
JMSException
{
if (closed) throw new IllegalStateException("The session is closed");
@@ -117,21 +117,21 @@
return msg;
}
- public StreamMessage createStreamMessage() throws JMSException
+ public StreamMessage createStreamMessage() throws JMSException
{
if (closed) throw new IllegalStateException("The session is closed");
return new SpyStreamMessage();
}
- public TextMessage createTextMessage() throws JMSException
+ public TextMessage createTextMessage() throws JMSException
{
if (closed) throw new IllegalStateException("The session is closed");
return new SpyTextMessage();
}
- public TextMessage createTextMessage(StringBuffer stringBuffer) throws
JMSException
+ public TextMessage createTextMessage(StringBuffer stringBuffer) throws
JMSException
{
if (closed) throw new IllegalStateException("The session is closed");
@@ -140,7 +140,7 @@
return msg;
}
- public boolean getTransacted() throws JMSException
+ public boolean getTransacted() throws JMSException
{
if (closed) throw new IllegalStateException("The session is closed");
@@ -148,14 +148,14 @@
}
- public MessageListener getMessageListener() throws JMSException
+ public MessageListener getMessageListener() throws JMSException
{
if (closed) throw new IllegalStateException("The session is closed");
return messageListener;
}
- public void setMessageListener(MessageListener listener) throws JMSException
+ public void setMessageListener(MessageListener listener) throws JMSException
{
if (closed) throw new IllegalStateException("The session is closed");
@@ -264,7 +264,7 @@
}
//Commit a transacted session
- public synchronized void commit() throws JMSException
+ public synchronized void commit() throws JMSException
{
if (closed) throw new IllegalStateException("The session is closed");
if (!transacted) throw new IllegalStateException("The session is not
transacted");
@@ -297,7 +297,7 @@
}
//Rollback a transacted session
- public synchronized void rollback() throws JMSException
+ public synchronized void rollback() throws JMSException
{
if (closed) throw new IllegalStateException("The session is closed");
if (!transacted) throw new IllegalStateException("The session is not
transacted");
@@ -327,7 +327,7 @@
}
}
- public synchronized void recover() throws JMSException
+ public synchronized void recover() throws JMSException
{
if (closed) throw new IllegalStateException("The session is closed");
if (transacted) throw new IllegalStateException("The session is
transacted");
1.9 +7 -7 spyderMQ/src/java/org/spyderMQ/SpyTopicPublisher.java
Index: SpyTopicPublisher.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spyderMQ/SpyTopicPublisher.java,v
retrieving revision 1.8
retrieving revision 1.9
diff -u -r1.8 -r1.9
--- SpyTopicPublisher.java 2000/05/18 20:20:57 1.8
+++ SpyTopicPublisher.java 2000/05/26 05:38:22 1.9
@@ -18,7 +18,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.8 $
+ * @version $Revision: 1.9 $
*/
public class SpyTopicPublisher
extends SpyMessageProducer
@@ -41,25 +41,25 @@
// Public --------------------------------------------------------
- public Topic getTopic() throws JMSException
+ public Topic getTopic() throws JMSException
{
return myTopic;
}
//Publish methods
- public void publish(Message message) throws JMSException
+ public void publish(Message message) throws JMSException
{
if (myTopic==null) throw new InvalidDestinationException("I do not
have a default Destination !");
publish(myTopic,message,defaultDeliveryMode,defaultPriority,defaultTTL);
}
-
- public void publish(Topic topic, Message message) throws JMSException
+
+ public void publish(Topic topic, Message message) throws JMSException
{
publish(topic,message,defaultDeliveryMode,defaultPriority,defaultTTL);
}
-
- public void publish(Message message, int deliveryMode, int priority, long
timeToLive) throws JMSException
+
+ public void publish(Message message, int deliveryMode, int priority, long
timeToLive) throws JMSException
{
if (myTopic==null) throw new InvalidDestinationException("Destination
is null !");
publish(myTopic,message,deliveryMode,priority,timeToLive);
