[jboss-cvs] JBoss Messaging SVN: r8494 - in branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884: src/main/org/jboss/jms/client and 8 other directories.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Wed Jan 25 06:01:58 EST 2012
Author: raggz
Date: 2012-01-25 06:01:57 -0500 (Wed, 25 Jan 2012)
New Revision: 8494
Added:
branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/wireformat/ConnectionCreateSessionDelegateRequest2.java
Modified:
branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/
branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/.classpath
branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/client/JBossConnection.java
branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/client/container/StateCreationAspect.java
branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/client/delegate/ClientConnectionDelegate.java
branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/delegate/ConnectionEndpoint.java
branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/server/endpoint/ServerConnectionEndpoint.java
branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/server/endpoint/advised/ConnectionAdvised.java
branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/wireformat/ConnectionCreateSessionDelegateRequest.java
branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/wireformat/PacketSupport.java
branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/tests/src/org/jboss/test/messaging/jms/ConnectionConsumerTest.java
branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/tests/src/org/jboss/test/messaging/jms/WireFormatTest.java
branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/tests/src/org/jboss/test/messaging/jms/server/connectionmanager/SimpleConnectionManagerTest.java
Log:
Back port JBMessaging-1831
Property changes on: branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884
___________________________________________________________________
Modified: svn:mergeinfo
- /branches/Branch_1_4:8138
+ /branches/Branch_1_4:8138,8141
Modified: branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/.classpath
===================================================================
--- branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/.classpath 2012-01-25 10:50:52 UTC (rev 8493)
+++ branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/.classpath 2012-01-25 11:01:57 UTC (rev 8494)
@@ -1,66 +1,128 @@
<?xml version="1.0" encoding="UTF-8"?>
<classpath>
- <classpathentry kind="src" path="docs/examples/queue-failover/src"/>
- <classpathentry kind="src" path="integration/EAP4/src"/>
- <classpathentry kind="src" path="integration/EAP4/tests-src"/>
<classpathentry kind="src" path="docs/examples/bridge/src"/>
- <classpathentry kind="src" path="docs/examples/stateless-clustered/src"/>
- <classpathentry kind="src" path="docs/examples/web-service/src-client"/>
- <classpathentry kind="src" path="docs/examples/web-service/src"/>
- <classpathentry kind="src" path="docs/examples/mdb-failure/src"/>
+ <classpathentry kind="src" path="integration/EAP5/src/main"/>
+ <classpathentry kind="src" path="integration/EAP5/tests-src"/>
+ <classpathentry kind="src" path="docs/examples/common/src"/>
<classpathentry kind="src" path="docs/examples/distributed-queue/src"/>
- <classpathentry kind="src" path="output/gen-parsers"/>
- <classpathentry kind="src" path="docs/examples/common/src"/>
<classpathentry kind="src" path="docs/examples/distributed-topic/src"/>
<classpathentry kind="src" path="docs/examples/ejb3mdb/src"/>
<classpathentry kind="src" path="docs/examples/http/src"/>
+ <classpathentry kind="src" path="docs/examples/mdb-failure/src"/>
<classpathentry kind="src" path="docs/examples/mdb/src"/>
- <classpathentry kind="src" path="docs/examples/ordering-group/src"/>
+ <classpathentry kind="src" path="docs/examples/queue-failover/src"/>
<classpathentry kind="src" path="docs/examples/queue/src"/>
<classpathentry kind="src" path="docs/examples/secure-socket/src"/>
+ <classpathentry kind="src" path="docs/examples/stateless-clustered/src"/>
<classpathentry kind="src" path="docs/examples/stateless/src"/>
<classpathentry kind="src" path="docs/examples/topic/src"/>
- <classpathentry excluding="**/.svn/**/*" kind="src" path="src/main"/>
- <classpathentry excluding="**/.svn/**/*" kind="src" path="tests/src"/>
- <classpathentry kind="lib" path="thirdparty/oswego-concurrent/lib/concurrent.jar" sourcepath="/extra/work-clebert/concurrent/concurrent/src"/>
- <classpathentry kind="lib" path="thirdparty/jgroups/lib/jgroups.jar"/>
+ <classpathentry kind="src" path="docs/examples/web-service/src"/>
+ <classpathentry kind="src" path="docs/examples/web-service/src-client"/>
+ <classpathentry kind="src" path="output/gen-parsers"/>
+ <classpathentry kind="src" path="src/main"/>
+ <classpathentry kind="src" path="tests/src"/>
+ <classpathentry kind="lib" path="lib/docbook-support/support/lib/avalon-framework-cvs-20020806.jar"/>
+ <classpathentry kind="lib" path="lib/docbook-support/support/lib/batik.jar"/>
+ <classpathentry kind="lib" path="lib/docbook-support/support/lib/fop.jar"/>
+ <classpathentry kind="lib" path="lib/docbook-support/support/lib/jai_codec.jar"/>
+ <classpathentry kind="lib" path="lib/docbook-support/support/lib/jai_core.jar"/>
+ <classpathentry kind="lib" path="lib/docbook-support/support/lib/rowan-0.1.jar"/>
<classpathentry kind="lib" path="thirdparty/apache-log4j/lib/log4j.jar"/>
- <classpathentry kind="lib" path="thirdparty/junit/lib/junit.jar"/>
- <classpathentry kind="lib" path="thirdparty/jboss/profiler/jvmti/lib/jboss-profiler-jvmti.jar"/>
- <classpathentry kind="lib" path="thirdparty/hsqldb/lib/hsqldb.jar"/>
<classpathentry kind="lib" path="thirdparty/apache-logging/lib/commons-logging.jar"/>
- <classpathentry kind="lib" path="thirdparty/jboss/serialization/lib/jboss-serialization.jar"/>
- <classpathentry kind="lib" path="thirdparty/sun-javacc/lib/javacc.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-modeler/lib/commons-modeler.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-tomcat/lib/catalina-manager.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-tomcat/lib/catalina-optional.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-tomcat/lib/catalina.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-tomcat/lib/jasper-compiler-jdt.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-tomcat/lib/jasper-compiler.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-tomcat/lib/jasper-runtime.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-tomcat/lib/naming-resources.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-tomcat/lib/servlets-default.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-tomcat/lib/servlets-invoker.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-tomcat/lib/servlets-webdav.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-tomcat/lib/tomcat-ajp.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-tomcat/lib/tomcat-apr.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-tomcat/lib/tomcat-coyote.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-tomcat/lib/tomcat-http.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-tomcat/lib/tomcat-util.jar"/>
<classpathentry kind="lib" path="thirdparty/apache-xerces/lib/xercesImpl.jar"/>
+ <classpathentry kind="lib" path="thirdparty/commons-el/lib/commons-el.jar"/>
<classpathentry kind="lib" path="thirdparty/dom4j/lib/dom4j.jar"/>
+ <classpathentry kind="lib" path="thirdparty/hsqldb/lib/hsqldb.jar"/>
<classpathentry kind="lib" path="thirdparty/javassist/lib/javassist.jar"/>
- <classpathentry kind="lib" path="thirdparty/jboss/aop/lib/jdk14-pluggable-instrumentor.jar"/>
- <classpathentry kind="lib" path="thirdparty/jboss/aop/lib/jrockit-pluggable-instrumentor.jar"/>
<classpathentry kind="lib" path="thirdparty/jboss/aop/lib/pluggable-instrumentor.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/backport-concurrent/lib/jboss-backport-concurrent.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/jbossretro-rt/lib/jbossretro-rt.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/jbossxb/lib/jboss-xml-binding-sources.jar"/>
<classpathentry kind="lib" path="thirdparty/jboss/jbossxb/lib/jboss-xml-binding.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/profiler/jvmti/lib/jboss-profiler-jvmti.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/remoting/lib/jboss-remoting-src.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/remoting/lib/jboss-remoting.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/serialization/lib/jboss-serialization.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/test14/lib/jboss-test14.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-common-jdbc-wrapper.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-local-jdbc.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-system.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-transaction-client.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jms-ra.jar"/>
+ <classpathentry kind="lib" path="thirdparty/junit/lib/junit.jar"/>
+ <classpathentry kind="lib" path="thirdparty/oswego-concurrent/lib/concurrent.jar"/>
<classpathentry kind="lib" path="thirdparty/retrotranslator/lib/backport-util-concurrent.jar"/>
<classpathentry kind="lib" path="thirdparty/retrotranslator/lib/retrotranslator-runtime.jar"/>
<classpathentry kind="lib" path="thirdparty/retrotranslator/lib/retrotranslator-transformer.jar"/>
+ <classpathentry kind="lib" path="thirdparty/sun-javacc/lib/javacc.jar"/>
<classpathentry kind="lib" path="thirdparty/trove/lib/trove.jar"/>
- <classpathentry kind="lib" path="thirdparty/jboss/remoting/lib/jboss-remoting.jar"/>
- <classpathentry kind="lib" path="thirdparty/jboss/jbossts14/lib/jbossjta.jar"/>
+ <classpathentry kind="lib" path="thirdparty/wutka-dtdparser/lib/dtdparser.jar"/>
+ <classpathentry kind="lib" path="tools/lib/jbossbuild.jar"/>
+ <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
+ <classpathentry kind="var" path="ANT_HOME/lib/ant-junit.jar"/>
<classpathentry kind="var" path="ANT_HOME/lib/ant.jar"/>
- <classpathentry kind="var" path="ANT_HOME/lib/ant-junit.jar"/>
- <classpathentry kind="lib" path="thirdparty/jboss/common/lib/jboss-common.jar"/>
- <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-j2ee.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jgroups/lib/jgroups.jar" sourcepath="thirdparty/jgroups/lib/jgroups-sources.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-log4j/lib/snmpTrapAppender.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-logging/lib/commons-logging-src.zip"/>
+ <classpathentry kind="lib" path="thirdparty/apache-xerces/lib/resolver.jar"/>
+ <classpathentry kind="lib" path="thirdparty/apache-xerces/lib/xml-apis.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/common-core/lib/jboss-common-core.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/common-core/lib/jboss-common-core-sources.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/common-logging-jdk/lib/jboss-logging-jdk.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/common-logging-jdk/lib/jboss-logging-jdk-sources.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/common-logging-log4j/lib/jboss-logging-log4j.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/common-logging-log4j/lib/jboss-logging-log4j-sources.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/common-logging-spi/lib/jboss-logging-spi.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/common-logging-spi/lib/jboss-logging-spi-sources.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/jboss-mdr/lib/jboss-mdr.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/jboss-mdr/lib/jboss-mdr-sources.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jgroups/lib/jgroups-sources.jar"/>
+ <classpathentry kind="lib" path="thirdparty/oswego-concurrent/lib/concurrent-src.zip"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/aop/lib/jboss-aop-client.jar"/>
<classpathentry kind="lib" path="thirdparty/jboss/aop/lib/jboss-aop.jar"/>
- <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-system.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/aop/lib/jboss-aop-aspects.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/jbossts/lib/jbossjts-integration.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/jbossts/lib/jbossjts-jacorb.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/jbossts/lib/jbossjts.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/jbossts/lib/jbossts-common.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/integration/lib/jboss-classloading-spi.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/integration/lib/jboss-corba-ots-spi.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/integration/lib/jboss-deployment-spi.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/integration/lib/jboss-integration.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/integration/lib/jboss-jca-spi.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/integration/lib/jboss-transaction-spi.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/jboss-javaee/lib/jboss-javaee.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/jboss-security-spi/lib/jboss-security-spi.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/jbosssx-client/lib/jbosssx-client.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/microcontainer/lib/jboss-aop-mc-int.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/microcontainer/lib/jboss-dependency.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/microcontainer/lib/jboss-guice-int.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/microcontainer/lib/jboss-kernel.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/microcontainer/lib/jboss-spring-int.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-j2se.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-system-jmx.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-jca.jar"/>
<classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-jmx.jar"/>
- <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-transaction-client.jar"/>
- <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jbosssx-client.jar"/>
- <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss.jar"/>
- <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jms-ra.jar"/>
- <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-common.jar"/>
- <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-common-jdbc-wrapper.jar"/>
- <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jbosscx-client.jar"/>
- <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-jca.jar"/>
- <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-local-jdbc.jar"/>
- <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-xml-binding.jar"/>
- <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
- <classpathentry kind="output" path="bin"/>
+ <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-managed.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/jboss-man/lib/jboss-managed.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jboss/jboss-man/lib/jboss-metatype.jar"/>
+ <classpathentry kind="lib" path="thirdparty/jbossas/core-libs/lib/jboss-mbeans.jar"/>
+ <classpathentry kind="output" path="tests/output/classes"/>
</classpath>
Modified: branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/client/JBossConnection.java
===================================================================
--- branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/client/JBossConnection.java 2012-01-25 10:50:52 UTC (rev 8493)
+++ branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/client/JBossConnection.java 2012-01-25 11:01:57 UTC (rev 8494)
@@ -267,7 +267,7 @@
}
SessionDelegate sessionDelegate =
- delegate.createSessionDelegate(transacted, acknowledgeMode, isXA, false);
+ delegate.createSessionDelegate(transacted, acknowledgeMode, isXA);
return new JBossSession(sessionDelegate, type);
}
Modified: branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/client/container/StateCreationAspect.java
===================================================================
--- branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/client/container/StateCreationAspect.java 2012-01-25 10:50:52 UTC (rev 8493)
+++ branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/client/container/StateCreationAspect.java 2012-01-25 11:01:57 UTC (rev 8494)
@@ -121,8 +121,13 @@
boolean transacted = ((Boolean)mi.getArguments()[0]).booleanValue();
int ackMode = ((Integer)mi.getArguments()[1]).intValue();
boolean xa = ((Boolean)mi.getArguments()[2]).booleanValue();
- boolean isCC = ((Boolean)mi.getArguments()[3]).booleanValue();
+ boolean isCC = false;
+ if (mi.getArguments().length >= 4)
+ {
+ isCC = ((Boolean)mi.getArguments()[3]).booleanValue();
+ }
+
SessionState sessionState =
new SessionState(connectionState, sessionDelegate, transacted,
ackMode, xa, sessionDelegate.getDupsOKBatchSize(),
Modified: branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/client/delegate/ClientConnectionDelegate.java
===================================================================
--- branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/client/delegate/ClientConnectionDelegate.java 2012-01-25 10:50:52 UTC (rev 8493)
+++ branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/client/delegate/ClientConnectionDelegate.java 2012-01-25 11:01:57 UTC (rev 8494)
@@ -44,6 +44,7 @@
import org.jboss.jms.wireformat.CloseRequest;
import org.jboss.jms.wireformat.ClosingRequest;
import org.jboss.jms.wireformat.ConnectionCreateSessionDelegateRequest;
+import org.jboss.jms.wireformat.ConnectionCreateSessionDelegateRequest2;
import org.jboss.jms.wireformat.ConnectionGetClientIDRequest;
import org.jboss.jms.wireformat.ConnectionGetIDBlockRequest;
import org.jboss.jms.wireformat.ConnectionGetPreparedTransactionsRequest;
@@ -179,12 +180,21 @@
throw new IllegalStateException("This invocation should not be handled here!");
}
+ public SessionDelegate createSessionDelegate(boolean transacted, int acknowledgmentMode, boolean isXA) throws JMSException
+ {
+ RequestSupport req =
+ new ConnectionCreateSessionDelegateRequest(id, version, transacted,
+ acknowledgmentMode, isXA);
+
+ return (SessionDelegate)doInvoke(client, req);
+ }
+
public SessionDelegate createSessionDelegate(boolean transacted,
int acknowledgmentMode,
boolean isXA, boolean isCC) throws JMSException
{
RequestSupport req =
- new ConnectionCreateSessionDelegateRequest(id, version, transacted,
+ new ConnectionCreateSessionDelegateRequest2(id, version, transacted,
acknowledgmentMode, isXA, isCC);
return (SessionDelegate)doInvoke(client, req);
Modified: branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/delegate/ConnectionEndpoint.java
===================================================================
--- branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/delegate/ConnectionEndpoint.java 2012-01-25 10:50:52 UTC (rev 8493)
+++ branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/delegate/ConnectionEndpoint.java 2012-01-25 11:01:57 UTC (rev 8494)
@@ -41,6 +41,10 @@
{
SessionDelegate createSessionDelegate(boolean transacted,
int acknowledgmentMode,
+ boolean isXA) throws JMSException;
+
+ SessionDelegate createSessionDelegate(boolean transacted,
+ int acknowledgmentMode,
boolean isXA, boolean isCC) throws JMSException;
String getClientID() throws JMSException;
Modified: branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/server/endpoint/ServerConnectionEndpoint.java
===================================================================
--- branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/server/endpoint/ServerConnectionEndpoint.java 2012-01-25 10:50:52 UTC (rev 8493)
+++ branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/server/endpoint/ServerConnectionEndpoint.java 2012-01-25 11:01:57 UTC (rev 8494)
@@ -224,6 +224,11 @@
// ConnectionDelegate implementation ------------------------------------------------------------
+ public SessionDelegate createSessionDelegate(boolean transacted, int acknowledgmentMode, boolean isXA) throws JMSException
+ {
+ return createSessionDelegate(transacted, acknowledgmentMode, isXA, false);
+ }
+
public SessionDelegate createSessionDelegate(boolean transacted,
int acknowledgmentMode,
boolean isXA, boolean isCC)
Modified: branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/server/endpoint/advised/ConnectionAdvised.java
===================================================================
--- branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/server/endpoint/advised/ConnectionAdvised.java 2012-01-25 10:50:52 UTC (rev 8493)
+++ branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/server/endpoint/advised/ConnectionAdvised.java 2012-01-25 11:01:57 UTC (rev 8494)
@@ -68,6 +68,11 @@
return endpoint.closing(sequence);
}
+ public SessionDelegate createSessionDelegate(boolean transacted, int acknowledgmentMode, boolean isXA) throws JMSException
+ {
+ return endpoint.createSessionDelegate(transacted, acknowledgmentMode, isXA);
+ }
+
public SessionDelegate createSessionDelegate(boolean transacted,
int acknowledgmentMode,
boolean isXA, boolean isCC) throws JMSException
Modified: branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/wireformat/ConnectionCreateSessionDelegateRequest.java
===================================================================
--- branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/wireformat/ConnectionCreateSessionDelegateRequest.java 2012-01-25 10:50:52 UTC (rev 8493)
+++ branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/wireformat/ConnectionCreateSessionDelegateRequest.java 2012-01-25 11:01:57 UTC (rev 8494)
@@ -45,8 +45,6 @@
private boolean xa;
- private boolean isCC;
-
public ConnectionCreateSessionDelegateRequest()
{
}
@@ -54,7 +52,7 @@
public ConnectionCreateSessionDelegateRequest(String objectId,
byte version,
boolean transacted, int ackMode,
- boolean xa, boolean isCC)
+ boolean xa)
{
super(objectId, PacketSupport.REQ_CONNECTION_CREATESESSIONDELEGATE, version);
@@ -63,8 +61,6 @@
this.acknowledgmentMode = ackMode;
this.xa = xa;
-
- this.isCC = isCC;
}
public void read(DataInputStream is) throws Exception
@@ -76,8 +72,6 @@
acknowledgmentMode = is.readInt();
xa = is.readBoolean();
-
- isCC = is.readBoolean();
}
public ResponseSupport serverInvoke() throws Exception
@@ -90,7 +84,7 @@
throw new IllegalStateException("Cannot find object in dispatcher with id " + objectId);
}
- return new ConnectionCreateSessionDelegateResponse((ClientSessionDelegate)endpoint.createSessionDelegate(transacted, acknowledgmentMode, xa, isCC));
+ return new ConnectionCreateSessionDelegateResponse((ClientSessionDelegate)endpoint.createSessionDelegate(transacted, acknowledgmentMode, xa));
}
public void write(DataOutputStream os) throws Exception
@@ -105,8 +99,6 @@
os.writeBoolean(xa);
- os.writeBoolean(isCC);
-
os.flush();
}
Copied: branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/wireformat/ConnectionCreateSessionDelegateRequest2.java (from rev 8141, branches/Branch_1_4/src/main/org/jboss/jms/wireformat/ConnectionCreateSessionDelegateRequest2.java)
===================================================================
--- branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/wireformat/ConnectionCreateSessionDelegateRequest2.java (rev 0)
+++ branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/wireformat/ConnectionCreateSessionDelegateRequest2.java 2012-01-25 11:01:57 UTC (rev 8494)
@@ -0,0 +1,115 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2005-2010, Red Hat Middleware LLC, and individual contributors
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+
+package org.jboss.jms.wireformat;
+
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+
+import org.jboss.jms.client.delegate.ClientSessionDelegate;
+import org.jboss.jms.delegate.ConnectionEndpoint;
+
+/**
+ * A ConnectionCreateSessionDelegateRequest2
+ *
+ * @author howard
+ *
+ * Created Dec 1, 2010 12:41:35 PM
+ *
+ *
+ */
+public class ConnectionCreateSessionDelegateRequest2 extends RequestSupport
+{
+ private boolean transacted;
+
+ private int acknowledgmentMode;
+
+ private boolean xa;
+
+ private boolean isCC;
+
+ public ConnectionCreateSessionDelegateRequest2()
+ {
+ }
+
+ public ConnectionCreateSessionDelegateRequest2(String objectId,
+ byte version,
+ boolean transacted, int ackMode,
+ boolean xa, boolean isCC)
+ {
+ super(objectId, PacketSupport.REQ_CONNECTION_CREATESESSIONDELEGATE2, version);
+
+ this.transacted = transacted;
+
+ this.acknowledgmentMode = ackMode;
+
+ this.xa = xa;
+
+ this.isCC = isCC;
+ }
+
+ public void read(DataInputStream is) throws Exception
+ {
+ super.read(is);
+
+ transacted = is.readBoolean();
+
+ acknowledgmentMode = is.readInt();
+
+ xa = is.readBoolean();
+
+ isCC = is.readBoolean();
+ }
+
+ public ResponseSupport serverInvoke() throws Exception
+ {
+ ConnectionEndpoint endpoint =
+ (ConnectionEndpoint)Dispatcher.instance.getTarget(objectId);
+
+ if (endpoint == null)
+ {
+ throw new IllegalStateException("Cannot find object in dispatcher with id " + objectId);
+ }
+
+ return new ConnectionCreateSessionDelegateResponse((ClientSessionDelegate)endpoint.createSessionDelegate(transacted, acknowledgmentMode, xa, isCC));
+ }
+
+ public void write(DataOutputStream os) throws Exception
+ {
+ super.write(os);
+
+ //Write the args
+
+ os.writeBoolean(transacted);
+
+ os.writeInt(acknowledgmentMode);
+
+ os.writeBoolean(xa);
+
+ os.writeBoolean(isCC);
+
+ os.flush();
+ }
+
+}
+
Modified: branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/wireformat/PacketSupport.java
===================================================================
--- branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/wireformat/PacketSupport.java 2012-01-25 10:50:52 UTC (rev 8493)
+++ branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/src/main/org/jboss/jms/wireformat/PacketSupport.java 2012-01-25 11:01:57 UTC (rev 8494)
@@ -91,6 +91,7 @@
public static final int REQ_CONNECTION_STOP = 205;
public static final int REQ_CONNECTION_SENDTRANSACTION = 206;
public static final int REQ_CONNECTION_GETPREPAREDTRANSACTIONS = 207;
+ public static final int REQ_CONNECTION_CREATESESSIONDELEGATE2 = 208;
// Session
// -------
@@ -226,6 +227,9 @@
case REQ_CONNECTION_CREATESESSIONDELEGATE:
packet = new ConnectionCreateSessionDelegateRequest();
break;
+ case REQ_CONNECTION_CREATESESSIONDELEGATE2:
+ packet = new ConnectionCreateSessionDelegateRequest2();
+ break;
case REQ_CONNECTION_GETCLIENTID:
packet = new ConnectionGetClientIDRequest();
break;
Modified: branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/tests/src/org/jboss/test/messaging/jms/ConnectionConsumerTest.java
===================================================================
--- branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/tests/src/org/jboss/test/messaging/jms/ConnectionConsumerTest.java 2012-01-25 10:50:52 UTC (rev 8493)
+++ branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/tests/src/org/jboss/test/messaging/jms/ConnectionConsumerTest.java 2012-01-25 11:01:57 UTC (rev 8494)
@@ -176,7 +176,7 @@
}
}
-
+ //https://jira.jboss.org/browse/JBMESSAGING-1831
public void testWaitForDeliveryFinish() throws Exception
{
if (ServerManagement.isRemote()) return;
Modified: branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/tests/src/org/jboss/test/messaging/jms/WireFormatTest.java
===================================================================
--- branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/tests/src/org/jboss/test/messaging/jms/WireFormatTest.java 2012-01-25 10:50:52 UTC (rev 8493)
+++ branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/tests/src/org/jboss/test/messaging/jms/WireFormatTest.java 2012-01-25 11:01:57 UTC (rev 8494)
@@ -57,6 +57,7 @@
import org.jboss.jms.wireformat.ClosingRequest;
import org.jboss.jms.wireformat.ClosingResponse;
import org.jboss.jms.wireformat.ConnectionCreateSessionDelegateRequest;
+import org.jboss.jms.wireformat.ConnectionCreateSessionDelegateRequest2;
import org.jboss.jms.wireformat.ConnectionCreateSessionDelegateResponse;
import org.jboss.jms.wireformat.ConnectionFactoryAddCallbackRequest;
import org.jboss.jms.wireformat.ConnectionFactoryCreateConnectionDelegateRequest;
@@ -166,6 +167,11 @@
wf.testConnectionCreateSessionDelegateRequest();
}
+ public void testConnectionCreateSessionDelegateRequest2() throws Exception
+ {
+ wf.testConnectionCreateSessionDelegateRequest2();
+ }
+
public void testConnectionGetClientIDRequest() throws Exception
{
wf.testConnectionGetClientIDRequest();
@@ -503,11 +509,19 @@
public void testConnectionCreateSessionDelegateRequest() throws Exception
{
RequestSupport req =
- new ConnectionCreateSessionDelegateRequest("23", (byte)77, true, 23, true, false);
+ new ConnectionCreateSessionDelegateRequest("23", (byte)77, true, 23, true);
testPacket(req, PacketSupport.REQ_CONNECTION_CREATESESSIONDELEGATE);
}
+ public void testConnectionCreateSessionDelegateRequest2() throws Exception
+ {
+ RequestSupport req =
+ new ConnectionCreateSessionDelegateRequest2("23", (byte)77, true, 23, true, false);
+
+ testPacket(req, PacketSupport.REQ_CONNECTION_CREATESESSIONDELEGATE);
+ }
+
public void testConnectionGetClientIDRequest() throws Exception
{
RequestSupport req =
Modified: branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/tests/src/org/jboss/test/messaging/jms/server/connectionmanager/SimpleConnectionManagerTest.java
===================================================================
--- branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/tests/src/org/jboss/test/messaging/jms/server/connectionmanager/SimpleConnectionManagerTest.java 2012-01-25 10:50:52 UTC (rev 8493)
+++ branches/JBossMessaging_1_4_7_GA_JBMESSAGING-1831_JBMESSAGING-1884/tests/src/org/jboss/test/messaging/jms/server/connectionmanager/SimpleConnectionManagerTest.java 2012-01-25 11:01:57 UTC (rev 8494)
@@ -334,6 +334,11 @@
return null;
}
+ public SessionDelegate createSessionDelegate(boolean transacted, int acknowledgmentMode, boolean isXA) throws JMSException
+ {
+ return null;
+ }
+
public String getClientID() throws JMSException
{
return null;
@@ -376,6 +381,7 @@
{
return null;
}
+
}
}
More information about the jboss-cvs-commits
mailing list