jstrachan 2003/03/19 14:29:35 Modified: messenger/src/conf subscriptions.dtd messenger project.xml messenger/src/java/org/apache/commons/messenger Messenger.java DefaultMessenger.java Log: Patch to allow access to the asynchronous session as well as the synchronous session. Revision Changes Path 1.4 +1 -1 jakarta-commons-sandbox/messenger/src/conf/subscriptions.dtd Index: subscriptions.dtd =================================================================== RCS file: /home/cvs/jakarta-commons-sandbox/messenger/src/conf/subscriptions.dtd,v retrieving revision 1.3 retrieving revision 1.4 diff -u -r1.3 -r1.4 --- subscriptions.dtd 4 Dec 2002 10:13:35 -0000 1.3 +++ subscriptions.dtd 19 Mar 2003 22:29:35 -0000 1.4 @@ -7,7 +7,7 @@ <!ELEMENT subscriptions (subscription+)> -<!ELEMENT subscription (listener | servlet | bridge | distributeBridge | stopWatch )+> +<!ELEMENT subscription (listener | servlet | bridge | distributeBridge | stopWatch )+ (consumerThread)?> <!ATTLIST subscription connection (queue|topic) #REQUIRED subject CDATA #REQUIRED 1.14 +1 -1 jakarta-commons-sandbox/messenger/project.xml Index: project.xml =================================================================== RCS file: /home/cvs/jakarta-commons-sandbox/messenger/project.xml,v retrieving revision 1.13 retrieving revision 1.14 diff -u -r1.13 -r1.14 --- project.xml 4 Mar 2003 13:19:01 -0000 1.13 +++ project.xml 19 Mar 2003 22:29:35 -0000 1.14 @@ -4,7 +4,7 @@ <pomVersion>3</pomVersion> <name>commons-messenger</name> <id>commons-messenger</id> - <currentVersion>1.0-dev-11</currentVersion> + <currentVersion>1.0-dev-12</currentVersion> <organization> <name>Apache Software Foundation</name> <url>http://www.apache.org</url> 1.16 +13 -6 jakarta-commons-sandbox/messenger/src/java/org/apache/commons/messenger/Messenger.java Index: Messenger.java =================================================================== RCS file: /home/cvs/jakarta-commons-sandbox/messenger/src/java/org/apache/commons/messenger/Messenger.java,v retrieving revision 1.15 retrieving revision 1.16 diff -u -r1.15 -r1.16 --- Messenger.java 4 Mar 2003 10:21:00 -0000 1.15 +++ Messenger.java 19 Mar 2003 22:29:35 -0000 1.16 @@ -111,10 +111,17 @@ /** Returns the underlying JMS connection that this Messenger is using */ public Connection getConnection() throws JMSException; - /** - * Returns the underlying JMS session that this thread is using for - * this Messenger for synchronous operation - */ public Session getSession() throws JMSException; + /** + * Returns the underlying JMS session that this thread is using for + * synchronous operations such as send() and receive() for synchronous operation + */ + public Session getSession() throws JMSException; + + /** + * Returns the underlying JMS session that this thread is using for + * this Messenger for asynchronous operation such as addMessageListener() operations + */ + public Session getAsyncSession() throws JMSException; /** Creates a ConnectionConsumer which is useful if used inside an application server 1.16 +6 -2 jakarta-commons-sandbox/messenger/src/java/org/apache/commons/messenger/DefaultMessenger.java Index: DefaultMessenger.java =================================================================== RCS file: /home/cvs/jakarta-commons-sandbox/messenger/src/java/org/apache/commons/messenger/DefaultMessenger.java,v retrieving revision 1.15 retrieving revision 1.16 diff -u -r1.15 -r1.16 --- DefaultMessenger.java 4 Mar 2003 13:19:01 -0000 1.15 +++ DefaultMessenger.java 19 Mar 2003 22:29:35 -0000 1.16 @@ -83,6 +83,10 @@ return getMessengerSession().getSession(); } + public Session getAsyncSession() throws JMSException { + return getMessengerSession().getListenerSession(); + } + // Implementation methods //------------------------------------------------------------------------- protected boolean isTopic(Connection connection) throws JMSException {
--------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]