summaryrefslogtreecommitdiff
path: root/java/client/src
diff options
context:
space:
mode:
authorRajith Muditha Attapattu <rajith@apache.org>2010-01-28 00:26:20 +0000
committerRajith Muditha Attapattu <rajith@apache.org>2010-01-28 00:26:20 +0000
commit72109ca034bbbd7d7c71e5a040c6e92277329476 (patch)
tree0c0f6af7f34b6f8401441f83ccead116309f5793 /java/client/src
parent0694a2fef88073eba1614d4f4b018bf9ca56f958 (diff)
downloadqpid-python-72109ca034bbbd7d7c71e5a040c6e92277329476.tar.gz
moving the logic of creating the map message to the AMQSession.java.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@903917 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src')
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java16
1 files changed, 0 insertions, 16 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
index 899d63af4e..adc8b277a4 100644
--- a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
+++ b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
@@ -61,9 +61,6 @@ import java.util.Map;
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 @@ public class AMQSession_0_10 extends AMQSession<BasicMessageConsumer_0_10, Basic
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);
- }
- }
}