Menu
▾
▴
[jboss-cvs] jboss-jms/src/main/org/jboss/jms/client Lifecycle.java SessionDelegate.java ConnectionDelegate.java ProducerDelegate.java BrowserDelegate.java ConsumerDelegate.java
|
From: Adrian B. <ej...@us...> - 2003-08-31 20:51:44
|
User: ejort
Date: 03/08/31 13:51:41
Modified: src/main/org/jboss/jms/client SessionDelegate.java
ConnectionDelegate.java ProducerDelegate.java
BrowserDelegate.java ConsumerDelegate.java
Added: src/main/org/jboss/jms/client Lifecycle.java
Log:
Implement basic close infrastructure processing
Revision Changes Path
1.4 +3 -16 jboss-jms/src/main/org/jboss/jms/client/SessionDelegate.java
Index: SessionDelegate.java
===================================================================
RCS file: /cvsroot/jboss/jboss-jms/src/main/org/jboss/jms/client/SessionDelegate.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- SessionDelegate.java 22 Aug 2003 11:49:08 -0000 1.3
+++ SessionDelegate.java 31 Aug 2003 20:51:41 -0000 1.4
@@ -24,9 +24,10 @@
* The implementation of a session
*
* @author <a href="mailto:ad...@jb...>Adrian Brock</a>
- * @version $Revision: 1.3 $
+ * @version $Revision: 1.4 $
*/
-public interface SessionDelegate
+public interface SessionDelegate
+ extends Lifecycle
{
// Constants -----------------------------------------------------
@@ -40,20 +41,6 @@
* @param acknowledge true for acknowledge, false for a Nack
*/
void acknowledge(Message message, boolean acknowledge);
-
- /**
- * Notify about to close
- *
- * @throws JMSException for any error
- */
- void closing() throws JMSException;
-
- /**
- * Close the delegate
- *
- * @throws JMSException for any error
- */
- void close() throws JMSException;
/**
* Commit a session
1.3 +3 -16 jboss-jms/src/main/org/jboss/jms/client/ConnectionDelegate.java
Index: ConnectionDelegate.java
===================================================================
RCS file: /cvsroot/jboss/jboss-jms/src/main/org/jboss/jms/client/ConnectionDelegate.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- ConnectionDelegate.java 22 Aug 2003 11:49:08 -0000 1.2
+++ ConnectionDelegate.java 31 Aug 2003 20:51:41 -0000 1.3
@@ -17,27 +17,14 @@
* The implementation of a connection
*
* @author <a href="mailto:ad...@jb...>Adrian Brock</a>
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
*/
-public interface ConnectionDelegate
+public interface ConnectionDelegate
+ extends Lifecycle
{
// Constants -----------------------------------------------------
// Public --------------------------------------------------------
-
- /**
- * Notify about closing
- *
- * @throws JMSException for any error
- */
- void closing() throws JMSException;
-
- /**
- * Close the delegate
- *
- * @throws JMSException for any error
- */
- void close() throws JMSException;
/**
* Create a session
1.4 +2 -15 jboss-jms/src/main/org/jboss/jms/client/ProducerDelegate.java
Index: ProducerDelegate.java
===================================================================
RCS file: /cvsroot/jboss/jboss-jms/src/main/org/jboss/jms/client/ProducerDelegate.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- ProducerDelegate.java 30 Aug 2003 14:23:43 -0000 1.3
+++ ProducerDelegate.java 31 Aug 2003 20:51:41 -0000 1.4
@@ -15,27 +15,14 @@
* The implementation of a producer
*
* @author <a href="mailto:ad...@jb...>Adrian Brock</a>
- * @version $Revision: 1.3 $
+ * @version $Revision: 1.4 $
*/
public interface ProducerDelegate
+ extends Lifecycle
{
// Constants -----------------------------------------------------
// Public --------------------------------------------------------
-
- /**
- * Notify about to close
- *
- * @throws JMSException for any error
- */
- void closing() throws JMSException;
-
- /**
- * Close the delegate
- *
- * @throws JMSException for any error
- */
- void close() throws JMSException;
/**
* Send a message
1.3 +3 -16 jboss-jms/src/main/org/jboss/jms/client/BrowserDelegate.java
Index: BrowserDelegate.java
===================================================================
RCS file: /cvsroot/jboss/jboss-jms/src/main/org/jboss/jms/client/BrowserDelegate.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- BrowserDelegate.java 30 Aug 2003 14:23:43 -0000 1.2
+++ BrowserDelegate.java 31 Aug 2003 20:51:41 -0000 1.3
@@ -14,27 +14,14 @@
* The implementation of a browser
*
* @author <a href="mailto:ad...@jb...>Adrian Brock</a>
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
*/
-public interface BrowserDelegate
+public interface BrowserDelegate
+ extends Lifecycle
{
// Constants -----------------------------------------------------
// Public --------------------------------------------------------
-
- /**
- * Notify about to close
- *
- * @throws JMSException for any error
- */
- void closing() throws JMSException;
-
- /**
- * Close the delegate
- *
- * @throws JMSException for any error
- */
- void close() throws JMSException;
/**
* Browse the messages
1.2 +2 -15 jboss-jms/src/main/org/jboss/jms/client/ConsumerDelegate.java
Index: ConsumerDelegate.java
===================================================================
RCS file: /cvsroot/jboss/jboss-jms/src/main/org/jboss/jms/client/ConsumerDelegate.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- ConsumerDelegate.java 21 Aug 2003 10:08:01 -0000 1.1
+++ ConsumerDelegate.java 31 Aug 2003 20:51:41 -0000 1.2
@@ -14,27 +14,14 @@
* The implementation of a consumer
*
* @author <a href="mailto:ad...@jb...>Adrian Brock</a>
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
*/
-public interface ConsumerDelegate
+public interface ConsumerDelegate
+ extends Lifecycle
{
// Constants -----------------------------------------------------
// Public --------------------------------------------------------
-
- /**
- * Notify about to close
- *
- * @throws JMSException for any error
- */
- void closing() throws JMSException;
-
- /**
- * Close the delegate
- *
- * @throws JMSException for any error
- */
- void close() throws JMSException;
/**
* Receive a message
1.1 jboss-jms/src/main/org/jboss/jms/client/Lifecycle.java
Index: Lifecycle.java
===================================================================
/*
* JBoss, the OpenSource J2EE webOS
*
* Distributable under LGPL license.
* See terms of license at gnu.org.
*/
package org.jboss.jms.client;
import javax.jms.JMSException;
/**
* The lifecycle
*
* @author <a href="mailto:ad...@jb...>Adrian Brock</a>
* @version $Revision: 1.1 $
*/
public interface Lifecycle
{
// Constants -----------------------------------------------------
// Public --------------------------------------------------------
/**
* Notify about to close
*
* @throws JMSException for any error
*/
void closing() throws JMSException;
/**
* Close the delegate
*
* @throws JMSException for any error
*/
void close() throws JMSException;
// Inner Classes --------------------------------------------------
}
|