You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ra...@apache.org on 2010/01/28 01:26:20 UTC
svn commit: r903917 -
/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
Author: rajith
Date: Thu Jan 28 00:26:20 2010
New Revision: 903917
URL: http://svn.apache.org/viewvc?rev=903917&view=rev
Log:
moving the logic of creating the map message to the AMQSession.java.
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
Modified: qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java?rev=903917&r1=903916&r2=903917&view=diff
==============================================================================
--- qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java (original)
+++ qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java Thu Jan 28 00:26:20 2010
@@ -61,9 +61,6 @@
import java.util.Timer;
import java.util.TimerTask;
-import org.apache.qpid.client.message.AMQPEncodedMapMessage;
-import org.apache.qpid.client.message.JMSMapMessage;
-import org.apache.qpid.client.message.MessageFactoryRegistry;
import org.apache.qpid.client.message.AMQMessageDelegateFactory;
/**
@@ -939,17 +936,4 @@
return AMQMessageDelegateFactory.FACTORY_0_10;
}
- @ Override
- public MapMessage createMapMessage() throws JMSException
- {
- checkNotClosed();
- if (useAMQPEncodedMapMessage)
- {
- return new AMQPEncodedMapMessage(AMQMessageDelegateFactory.FACTORY_0_10);
- }
- else
- {
- return new JMSMapMessage(AMQMessageDelegateFactory.FACTORY_0_10);
- }
- }
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org