Menu
▾
▴
[jboss-cvs] jboss-jms/src/main/org/jboss/jms/client/delegate ...
|
From: Timothy F. <ti...@jb...> - 2006-03-07 21:14:17
|
User: timfox
Date: 06/03/07 16:14:15
Modified: src/main/org/jboss/jms/client/delegate
ClientConsumerDelegate.java
ClientSessionDelegate.java
Log:
Renamed message delegates to message proxies
Revision Changes Path
1.9 +4 -4 jboss-jms/src/main/org/jboss/jms/client/delegate/ClientConsumerDelegate.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: ClientConsumerDelegate.java
===================================================================
RCS file: /cvsroot/jboss/jboss-jms/src/main/org/jboss/jms/client/delegate/ClientConsumerDelegate.java,v
retrieving revision 1.8
retrieving revision 1.9
diff -u -b -r1.8 -r1.9
--- ClientConsumerDelegate.java 7 Mar 2006 17:11:13 -0000 1.8
+++ ClientConsumerDelegate.java 7 Mar 2006 21:14:15 -0000 1.9
@@ -29,7 +29,7 @@
import org.jboss.jms.client.state.ConnectionState;
import org.jboss.jms.delegate.ConsumerDelegate;
import org.jboss.jms.destination.JBossDestination;
-import org.jboss.jms.message.MessageDelegate;
+import org.jboss.jms.message.MessageProxy;
import org.jboss.jms.server.remoting.MetaDataConstants;
import org.jboss.remoting.Client;
@@ -39,9 +39,9 @@
* @author <a href="mailto:ti...@jb...">Tim Fox</a>
* @author <a href="mailto:ov...@jb...">Ovidiu Feodorov</a>
*
- * @version <tt>$Revision: 1.8 $</tt>
+ * @version <tt>$Revision: 1.9 $</tt>
*
- * $Id: ClientConsumerDelegate.java,v 1.8 2006/03/07 17:11:13 timfox Exp $
+ * $Id: ClientConsumerDelegate.java,v 1.9 2006/03/07 21:14:15 timfox Exp $
*/
public class ClientConsumerDelegate extends DelegateSupport implements ConsumerDelegate
{
@@ -124,7 +124,7 @@
* This invocation should either be handled by the client-side interceptor chain or by the
* server-side endpoint.
*/
- public MessageDelegate getMessageNow(boolean wait) throws JMSException
+ public MessageProxy getMessageNow(boolean wait) throws JMSException
{
throw new IllegalStateException("This invocation should not be handled here!");
}
1.8 +17 -17 jboss-jms/src/main/org/jboss/jms/client/delegate/ClientSessionDelegate.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: ClientSessionDelegate.java
===================================================================
RCS file: /cvsroot/jboss/jboss-jms/src/main/org/jboss/jms/client/delegate/ClientSessionDelegate.java,v
retrieving revision 1.7
retrieving revision 1.8
diff -u -b -r1.7 -r1.8
--- ClientSessionDelegate.java 7 Mar 2006 17:11:13 -0000 1.7
+++ ClientSessionDelegate.java 7 Mar 2006 21:14:15 -0000 1.8
@@ -35,12 +35,12 @@
import org.jboss.jms.destination.JBossDestination;
import org.jboss.jms.destination.JBossQueue;
import org.jboss.jms.destination.JBossTopic;
-import org.jboss.jms.message.BytesMessageDelegate;
-import org.jboss.jms.message.MapMessageDelegate;
-import org.jboss.jms.message.MessageDelegate;
-import org.jboss.jms.message.ObjectMessageDelegate;
-import org.jboss.jms.message.StreamMessageDelegate;
-import org.jboss.jms.message.TextMessageDelegate;
+import org.jboss.jms.message.BytesMessageProxy;
+import org.jboss.jms.message.MapMessageProxy;
+import org.jboss.jms.message.MessageProxy;
+import org.jboss.jms.message.ObjectMessageProxy;
+import org.jboss.jms.message.StreamMessageProxy;
+import org.jboss.jms.message.TextMessageProxy;
import org.jboss.remoting.Client;
/**
@@ -49,9 +49,9 @@
* @author <a href="mailto:ti...@jb...">Tim Fox</a>
* @author <a href="mailto:ov...@jb...">Ovidiu Feodorov</a>
*
- * @version <tt>$Revision: 1.7 $</tt>
+ * @version <tt>$Revision: 1.8 $</tt>
*
- * $Id: ClientSessionDelegate.java,v 1.7 2006/03/07 17:11:13 timfox Exp $
+ * $Id: ClientSessionDelegate.java,v 1.8 2006/03/07 21:14:15 timfox Exp $
*/
public class ClientSessionDelegate extends DelegateSupport implements SessionDelegate
{
@@ -153,7 +153,7 @@
* This invocation should either be handled by the client-side interceptor chain or by the
* server-side endpoint.
*/
- public BytesMessageDelegate createBytesMessage() throws JMSException
+ public BytesMessageProxy createBytesMessage() throws JMSException
{
throw new IllegalStateException("This invocation should not be handled here!");
}
@@ -173,7 +173,7 @@
* This invocation should either be handled by the client-side interceptor chain or by the
* server-side endpoint.
*/
- public MapMessageDelegate createMapMessage() throws JMSException
+ public MapMessageProxy createMapMessage() throws JMSException
{
throw new IllegalStateException("This invocation should not be handled here!");
}
@@ -182,7 +182,7 @@
* This invocation should either be handled by the client-side interceptor chain or by the
* server-side endpoint.
*/
- public MessageDelegate createMessage() throws JMSException
+ public MessageProxy createMessage() throws JMSException
{
throw new IllegalStateException("This invocation should not be handled here!");
}
@@ -191,7 +191,7 @@
* This invocation should either be handled by the client-side interceptor chain or by the
* server-side endpoint.
*/
- public ObjectMessageDelegate createObjectMessage() throws JMSException
+ public ObjectMessageProxy createObjectMessage() throws JMSException
{
throw new IllegalStateException("This invocation should not be handled here!");
}
@@ -200,7 +200,7 @@
* This invocation should either be handled by the client-side interceptor chain or by the
* server-side endpoint.
*/
- public ObjectMessageDelegate createObjectMessage(Serializable object) throws JMSException
+ public ObjectMessageProxy createObjectMessage(Serializable object) throws JMSException
{
throw new IllegalStateException("This invocation should not be handled here!");
}
@@ -227,7 +227,7 @@
* This invocation should either be handled by the client-side interceptor chain or by the
* server-side endpoint.
*/
- public StreamMessageDelegate createStreamMessage() throws JMSException
+ public StreamMessageProxy createStreamMessage() throws JMSException
{
throw new IllegalStateException("This invocation should not be handled here!");
}
@@ -236,7 +236,7 @@
* This invocation should either be handled by the client-side interceptor chain or by the
* server-side endpoint.
*/
- public TextMessageDelegate createTextMessage() throws JMSException
+ public TextMessageProxy createTextMessage() throws JMSException
{
throw new IllegalStateException("This invocation should not be handled here!");
}
@@ -245,7 +245,7 @@
* This invocation should either be handled by the client-side interceptor chain or by the
* server-side endpoint.
*/
- public TextMessageDelegate createTextMessage(String text) throws JMSException
+ public TextMessageProxy createTextMessage(String text) throws JMSException
{
throw new IllegalStateException("This invocation should not be handled here!");
}
@@ -371,7 +371,7 @@
* This invocation should either be handled by the client-side interceptor chain or by the
* server-side endpoint.
*/
- public void addAsfMessage(MessageDelegate m, int consumerID, ConsumerDelegate cons)
+ public void addAsfMessage(MessageProxy m, int consumerID, ConsumerDelegate cons)
{
throw new IllegalStateException("This invocation should not be handled here!");
}
|