You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2014/12/22 17:56:10 UTC
[02/16] qpid-jms git commit: remove tmp module with old client work
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/AmqpValueDescribedType.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/AmqpValueDescribedType.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/AmqpValueDescribedType.java
deleted file mode 100644
index d524b46..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/AmqpValueDescribedType.java
+++ /dev/null
@@ -1,48 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.jms.test.testpeer.describedtypes.sections;
-
-import org.apache.qpid.proton.amqp.DescribedType;
-import org.apache.qpid.proton.amqp.Symbol;
-
-public class AmqpValueDescribedType implements DescribedType
-{
- private static final Symbol DESCIPTOR_SYMBOL = Symbol.valueOf("amqp:amqp-value:*");
- private Object _described;
-
- public AmqpValueDescribedType(Object described)
- {
- _described = described;
- }
-
- @Override
- public Object getDescriptor()
- {
- return DESCIPTOR_SYMBOL;
- }
-
- @Override
- public Object getDescribed()
- {
- return _described;
- }
-
-}
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/ApplicationPropertiesDescribedType.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/ApplicationPropertiesDescribedType.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/ApplicationPropertiesDescribedType.java
deleted file mode 100644
index 12f92a5..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/ApplicationPropertiesDescribedType.java
+++ /dev/null
@@ -1,45 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.jms.test.testpeer.describedtypes.sections;
-
-import org.apache.qpid.jms.test.testpeer.MapDescribedType;
-import org.apache.qpid.proton.amqp.Symbol;
-
-public class ApplicationPropertiesDescribedType extends MapDescribedType
-{
- private static final Symbol DESCIPTOR_SYMBOL = Symbol.valueOf("amqp:application-properties:map");
-
- @Override
- public Object getDescriptor()
- {
- return DESCIPTOR_SYMBOL;
- }
-
- public void setApplicationProperty(String name, Object value)
- {
- if(name == null)
- {
- throw new RuntimeException("ApplicationProperties maps must use non-null String keys");
- }
-
- getDescribed().put(name, value);
- }
-}
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/DataDescribedType.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/DataDescribedType.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/DataDescribedType.java
deleted file mode 100644
index 7205c9f..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/DataDescribedType.java
+++ /dev/null
@@ -1,54 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.jms.test.testpeer.describedtypes.sections;
-
-import org.apache.qpid.proton.amqp.Binary;
-import org.apache.qpid.proton.amqp.DescribedType;
-import org.apache.qpid.proton.amqp.Symbol;
-
-public class DataDescribedType implements DescribedType
-{
- private static final Symbol DESCIPTOR_SYMBOL = Symbol.valueOf("amqp:data:binary");
- private Binary _described;
-
- public DataDescribedType(Binary described)
- {
- if(described == null)
- {
- throw new IllegalArgumentException("provided Binary must not be null");
- }
-
- _described = described;
- }
-
- @Override
- public Object getDescriptor()
- {
- return DESCIPTOR_SYMBOL;
- }
-
- @Override
- public Object getDescribed()
- {
- return _described;
- }
-
-}
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/HeaderDescribedType.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/HeaderDescribedType.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/HeaderDescribedType.java
deleted file mode 100644
index ed7cb57..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/HeaderDescribedType.java
+++ /dev/null
@@ -1,89 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.jms.test.testpeer.describedtypes.sections;
-
-import org.apache.qpid.jms.test.testpeer.ListDescribedType;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-
-/**
- * Generated by generate-list-sections.xsl, which resides in this package.
- */
-public class HeaderDescribedType extends ListDescribedType
-{
- public static final Symbol DESCRIPTOR_SYMBOL = Symbol.valueOf("amqp:header:list");
- public static final UnsignedLong DESCRIPTOR_CODE = UnsignedLong.valueOf(0x0000000000000070L);
-
-
- private static final int FIELD_DURABLE = 0;
- private static final int FIELD_PRIORITY = 1;
- private static final int FIELD_TTL = 2;
- private static final int FIELD_FIRST_ACQUIRER = 3;
- private static final int FIELD_DELIVERY_COUNT = 4;
-
- public HeaderDescribedType(Object... fields)
- {
- super(5);
- int i = 0;
- for(Object field : fields)
- {
- getFields()[i++] = field;
- }
- }
-
- @Override
- public Symbol getDescriptor()
- {
- return DESCRIPTOR_SYMBOL;
- }
-
- public HeaderDescribedType setDurable(Object o)
- {
- getFields()[FIELD_DURABLE] = o;
- return this;
- }
-
- public HeaderDescribedType setPriority(Object o)
- {
- getFields()[FIELD_PRIORITY] = o;
- return this;
- }
-
- public HeaderDescribedType setTtl(Object o)
- {
- getFields()[FIELD_TTL] = o;
- return this;
- }
-
- public HeaderDescribedType setFirstAcquirer(Object o)
- {
- getFields()[FIELD_FIRST_ACQUIRER] = o;
- return this;
- }
-
- public HeaderDescribedType setDeliveryCount(Object o)
- {
- getFields()[FIELD_DELIVERY_COUNT] = o;
- return this;
- }
-
-}
-
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/MessageAnnotationsDescribedType.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/MessageAnnotationsDescribedType.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/MessageAnnotationsDescribedType.java
deleted file mode 100644
index 93a45b2..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/MessageAnnotationsDescribedType.java
+++ /dev/null
@@ -1,46 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.jms.test.testpeer.describedtypes.sections;
-
-import org.apache.qpid.jms.test.testpeer.MapDescribedType;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-
-public class MessageAnnotationsDescribedType extends MapDescribedType
-{
- private static final Symbol DESCIPTOR_SYMBOL = Symbol.valueOf("amqp:message-annotations:map");
-
- @Override
- public Object getDescriptor()
- {
- return DESCIPTOR_SYMBOL;
- }
-
- public void setSymbolKeyedAnnotation(String name, Object value)
- {
- getDescribed().put(Symbol.valueOf(name), value);
- }
-
- public void setUnsignedLongKeyedAnnotation(UnsignedLong name, Object value)
- {
- throw new UnsupportedOperationException("UnsignedLong keys are currently reserved");
- }
-}
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/PropertiesDescribedType.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/PropertiesDescribedType.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/PropertiesDescribedType.java
deleted file mode 100644
index 716fc39..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/PropertiesDescribedType.java
+++ /dev/null
@@ -1,145 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.jms.test.testpeer.describedtypes.sections;
-
-import org.apache.qpid.jms.test.testpeer.ListDescribedType;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-
-/**
- * Generated by generate-list-sections.xsl, which resides in this package.
- */
-public class PropertiesDescribedType extends ListDescribedType
-{
- public static final Symbol DESCRIPTOR_SYMBOL = Symbol.valueOf("amqp:properties:list");
- public static final UnsignedLong DESCRIPTOR_CODE = UnsignedLong.valueOf(0x0000000000000073L);
-
-
- private static final int FIELD_MESSAGE_ID = 0;
- private static final int FIELD_USER_ID = 1;
- private static final int FIELD_TO = 2;
- private static final int FIELD_SUBJECT = 3;
- private static final int FIELD_REPLY_TO = 4;
- private static final int FIELD_CORRELATION_ID = 5;
- private static final int FIELD_CONTENT_TYPE = 6;
- private static final int FIELD_CONTENT_ENCODING = 7;
- private static final int FIELD_ABSOLUTE_EXPIRY_TIME = 8;
- private static final int FIELD_CREATION_TIME = 9;
- private static final int FIELD_GROUP_ID = 10;
- private static final int FIELD_GROUP_SEQUENCE = 11;
- private static final int FIELD_REPLY_TO_GROUP_ID = 12;
-
- public PropertiesDescribedType(Object... fields)
- {
- super(13);
- int i = 0;
- for(Object field : fields)
- {
- getFields()[i++] = field;
- }
- }
-
- @Override
- public Symbol getDescriptor()
- {
- return DESCRIPTOR_SYMBOL;
- }
-
- public PropertiesDescribedType setMessageId(Object o)
- {
- getFields()[FIELD_MESSAGE_ID] = o;
- return this;
- }
-
- public PropertiesDescribedType setUserId(Object o)
- {
- getFields()[FIELD_USER_ID] = o;
- return this;
- }
-
- public PropertiesDescribedType setTo(Object o)
- {
- getFields()[FIELD_TO] = o;
- return this;
- }
-
- public PropertiesDescribedType setSubject(Object o)
- {
- getFields()[FIELD_SUBJECT] = o;
- return this;
- }
-
- public PropertiesDescribedType setReplyTo(Object o)
- {
- getFields()[FIELD_REPLY_TO] = o;
- return this;
- }
-
- public PropertiesDescribedType setCorrelationId(Object o)
- {
- getFields()[FIELD_CORRELATION_ID] = o;
- return this;
- }
-
- public PropertiesDescribedType setContentType(Object o)
- {
- getFields()[FIELD_CONTENT_TYPE] = o;
- return this;
- }
-
- public PropertiesDescribedType setContentEncoding(Object o)
- {
- getFields()[FIELD_CONTENT_ENCODING] = o;
- return this;
- }
-
- public PropertiesDescribedType setAbsoluteExpiryTime(Object o)
- {
- getFields()[FIELD_ABSOLUTE_EXPIRY_TIME] = o;
- return this;
- }
-
- public PropertiesDescribedType setCreationTime(Object o)
- {
- getFields()[FIELD_CREATION_TIME] = o;
- return this;
- }
-
- public PropertiesDescribedType setGroupId(Object o)
- {
- getFields()[FIELD_GROUP_ID] = o;
- return this;
- }
-
- public PropertiesDescribedType setGroupSequence(Object o)
- {
- getFields()[FIELD_GROUP_SEQUENCE] = o;
- return this;
- }
-
- public PropertiesDescribedType setReplyToGroupId(Object o)
- {
- getFields()[FIELD_REPLY_TO_GROUP_ID] = o;
- return this;
- }
-
-}
-
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/generate-list-sections.xsl
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/generate-list-sections.xsl b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/generate-list-sections.xsl
deleted file mode 100644
index 82ae80b..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/describedtypes/sections/generate-list-sections.xsl
+++ /dev/null
@@ -1,146 +0,0 @@
-<?xml version="1.0" encoding="utf-8"?>
-<xsl:stylesheet xmlns:xsl="http://www.w3.org/1999/XSL/Transform" version="1.0"
- xmlns:exsl="http://exslt.org/common"
- extension-element-prefixes="exsl">
-
-<!-- Used to generate the Java classes in this package.
- Changes to these classes should be effected by modifying this stylesheet then re-running it,
- using a stylesheet processor that understands the exsl directives such as xsltproc -->
-
-<xsl:template match="/">
- <xsl:variable name="license">/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-</xsl:variable>
-
- <xsl:for-each select="descendant-or-self::node()[name()='type']">
- <xsl:variable name="classname"><xsl:call-template name="dashToCamel"><xsl:with-param name="input" select="@name"/></xsl:call-template>DescribedType</xsl:variable>
- <xsl:if test="@provides = 'section'">
- <xsl:if test="@name = 'header' or @name='properties'">
- <xsl:call-template name="typeClass">
- <xsl:with-param name="license" select="$license"/>
- <xsl:with-param name="classname" select="$classname"/>
- </xsl:call-template>
- </xsl:if>
- </xsl:if>
-
- </xsl:for-each>
-</xsl:template>
-
-
-<!-- *************************************************************************************************************** -->
-
-<xsl:template name="typeClass">
- <xsl:param name="license"/>
- <xsl:param name="classname"/>
- <exsl:document href="{$classname}.java" method="text">
- <xsl:value-of select="$license"/>
-package org.apache.qpid.jms.test.testpeer.describedtypes.sections;
-
-import org.apache.qpid.jms.test.testpeer.ListDescribedType;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-
-/**
- * Generated by generate-list-sections.xsl, which resides in this package.
- */
-public class <xsl:value-of select="$classname"/> extends ListDescribedType
-{
- public static final Symbol DESCRIPTOR_SYMBOL = Symbol.valueOf("<xsl:value-of select="descendant::node()[name()='descriptor']/@name"/>");
- public static final UnsignedLong DESCRIPTOR_CODE = UnsignedLong.valueOf(<xsl:value-of select="concat(substring(descendant::node()[name()='descriptor']/@code,1,10),substring(descendant::node()[name()='descriptor']/@code,14))"/>L);
-
-<xsl:for-each select="descendant::node()[name()='field']">
- private static final int FIELD_<xsl:call-template name="toUpperDashToUnderscore"><xsl:with-param name="input" select="@name"/></xsl:call-template> = <xsl:value-of select="count(preceding-sibling::node()[name()='field'])"/>;</xsl:for-each>
-
- public <xsl:value-of select="$classname"/>(Object... fields)
- {
- super(<xsl:value-of select="count(descendant::node()[name()='field'])"/>);
- int i = 0;
- for(Object field : fields)
- {
- getFields()[i++] = field;
- }
- }
-
- @Override
- public Symbol getDescriptor()
- {
- return DESCRIPTOR_SYMBOL;
- }
-<xsl:for-each select="descendant::node()[name()='field']">
- public <xsl:value-of select="$classname"/> set<xsl:call-template name="dashToCamel"><xsl:with-param name="input" select="@name"/></xsl:call-template>(Object o)
- {
- getFields()[FIELD_<xsl:call-template name="toUpperDashToUnderscore"><xsl:with-param name="input" select="@name"/></xsl:call-template>] = o;
- return this;
- }
-</xsl:for-each>
-}
-
-</exsl:document>
-
-</xsl:template>
-
-<!-- *************************************************************************************************************** -->
-
-<xsl:template name="constructFromLiteral">
- <xsl:param name="type"/>
- <xsl:param name="value"/>
- <xsl:choose>
- <xsl:when test="$type = 'string'">"<xsl:value-of select="$value"/></xsl:when>
- <xsl:when test="$type = 'symbol'">Symbol.valueOf("<xsl:value-of select="$value"/>")</xsl:when>
- <xsl:when test="$type = 'ubyte'">UnsignedByte.valueOf((byte) <xsl:value-of select="$value"/>)</xsl:when>
- <xsl:when test="$type = 'ushort'">UnsignedShort.valueOf((short) <xsl:value-of select="$value"/>)</xsl:when>
- <xsl:when test="$type = 'uint'">UnsignedInteger.valueOf(<xsl:value-of select="$value"/>)</xsl:when>
- <xsl:when test="$type = 'ulong'">UnsignedLong.valueOf(<xsl:value-of select="$value"/>L)</xsl:when>
- <xsl:when test="$type = 'long'"><xsl:value-of select="$value"/>L</xsl:when>
- <xsl:when test="$type = 'short'">(short)<xsl:value-of select="$value"/></xsl:when>
- <xsl:when test="$type = 'short'">(byte)<xsl:value-of select="$value"/></xsl:when>
- <xsl:otherwise><xsl:value-of select="$value"/></xsl:otherwise>
- </xsl:choose>
-</xsl:template>
-
-<!-- *************************************************************************************************************** -->
-<xsl:template name="substringAfterLast"><xsl:param name="input"/><xsl:param name="arg"/>
- <xsl:choose>
- <xsl:when test="contains($input,$arg)"><xsl:call-template name="substringAfterLast"><xsl:with-param name="input"><xsl:value-of select="substring-after($input,$arg)"/></xsl:with-param><xsl:with-param name="arg"><xsl:value-of select="$arg"/></xsl:with-param></xsl:call-template></xsl:when>
- <xsl:otherwise><xsl:value-of select="$input"/></xsl:otherwise>
- </xsl:choose>
- </xsl:template>
-
- <xsl:template name="initCap"><xsl:param name="input"/><xsl:value-of select="translate(substring($input,1,1),'abcdefghijklmnopqrstuvwxyz','ABCDEFGHIJKLMNOPQRSTUVWXYZ')"/><xsl:value-of select="substring($input,2)"/></xsl:template>
-
- <xsl:template name="initLower"><xsl:param name="input"/><xsl:value-of select="translate(substring($input,1,1),'ABCDEFGHIJKLMNOPQRSTUVWXYZ','abcdefghijklmnopqrstuvwxyz')"/><xsl:value-of select="substring($input,2)"/></xsl:template>
-
- <xsl:template name="toUpper"><xsl:param name="input"/><xsl:value-of select="translate($input,'abcdefghijklmnopqrstuvwxyz','ABCDEFGHIJKLMNOPQRSTUVWXYZ')"/></xsl:template>
-
- <xsl:template name="toUpperDashToUnderscore"><xsl:param name="input"/><xsl:value-of select="translate($input,'abcdefghijklmnopqrstuvwxyz-','ABCDEFGHIJKLMNOPQRSTUVWXYZ_')"/></xsl:template>
-
- <xsl:template name="dashToCamel">
- <xsl:param name="input"/>
- <xsl:choose>
- <xsl:when test="contains($input,'-')"><xsl:call-template name="initCap"><xsl:with-param name="input" select="substring-before($input,'-')"/></xsl:call-template><xsl:call-template name="dashToCamel"><xsl:with-param name="input" select="substring-after($input,'-')"/></xsl:call-template></xsl:when>
- <xsl:otherwise><xsl:call-template name="initCap"><xsl:with-param name="input" select="$input"/></xsl:call-template></xsl:otherwise>
- </xsl:choose>
- </xsl:template>
-
- <xsl:template name="dashToLowerCamel">
- <xsl:param name="input"/>
- <xsl:call-template name="initLower"><xsl:with-param name="input"><xsl:call-template name="dashToCamel"><xsl:with-param name="input" select="$input"/></xsl:call-template></xsl:with-param></xsl:call-template>
- </xsl:template>
-</xsl:stylesheet>
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/AttachMatcher.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/AttachMatcher.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/AttachMatcher.java
deleted file mode 100644
index edd62cd..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/AttachMatcher.java
+++ /dev/null
@@ -1,231 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.jms.test.testpeer.matchers;
-
-import java.util.HashMap;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-import org.apache.qpid.jms.test.testpeer.FrameType;
-import org.apache.qpid.jms.test.testpeer.FrameWithNoPayloadMatchingHandler;
-import org.hamcrest.Matcher;
-
-/**
- * Generated by generate-matchers.xsl, which resides in this package.
- */
-public class AttachMatcher extends FrameWithNoPayloadMatchingHandler
-{
- /** Note that the ordinals of the Field enums match the order specified in the spec */
- public enum Field
- {
- NAME,
- HANDLE,
- ROLE,
- SND_SETTLE_MODE,
- RCV_SETTLE_MODE,
- SOURCE,
- TARGET,
- UNSETTLED,
- INCOMPLETE_UNSETTLED,
- INITIAL_DELIVERY_COUNT,
- MAX_MESSAGE_SIZE,
- OFFERED_CAPABILITIES,
- DESIRED_CAPABILITIES,
- PROPERTIES,
- }
-
- public AttachMatcher()
- {
- super(FrameType.AMQP,
- ANY_CHANNEL,
- UnsignedLong.valueOf(0x0000000000000012L),
- Symbol.valueOf("amqp:attach:list"),
- new HashMap<Enum<?>, Matcher<?>>(),
- null);
- }
-
- @Override
- public AttachMatcher onSuccess(Runnable onSuccessAction)
- {
- super.onSuccess(onSuccessAction);
- return this;
- }
-
- public AttachMatcher withName(Matcher<?> m)
- {
- getMatchers().put(Field.NAME, m);
- return this;
- }
-
- public AttachMatcher withHandle(Matcher<?> m)
- {
- getMatchers().put(Field.HANDLE, m);
- return this;
- }
-
- public AttachMatcher withRole(Matcher<?> m)
- {
- getMatchers().put(Field.ROLE, m);
- return this;
- }
-
- public AttachMatcher withSndSettleMode(Matcher<?> m)
- {
- getMatchers().put(Field.SND_SETTLE_MODE, m);
- return this;
- }
-
- public AttachMatcher withRcvSettleMode(Matcher<?> m)
- {
- getMatchers().put(Field.RCV_SETTLE_MODE, m);
- return this;
- }
-
- public AttachMatcher withSource(Matcher<?> m)
- {
- getMatchers().put(Field.SOURCE, m);
- return this;
- }
-
- public AttachMatcher withTarget(Matcher<?> m)
- {
- getMatchers().put(Field.TARGET, m);
- return this;
- }
-
- public AttachMatcher withUnsettled(Matcher<?> m)
- {
- getMatchers().put(Field.UNSETTLED, m);
- return this;
- }
-
- public AttachMatcher withIncompleteUnsettled(Matcher<?> m)
- {
- getMatchers().put(Field.INCOMPLETE_UNSETTLED, m);
- return this;
- }
-
- public AttachMatcher withInitialDeliveryCount(Matcher<?> m)
- {
- getMatchers().put(Field.INITIAL_DELIVERY_COUNT, m);
- return this;
- }
-
- public AttachMatcher withMaxMessageSize(Matcher<?> m)
- {
- getMatchers().put(Field.MAX_MESSAGE_SIZE, m);
- return this;
- }
-
- public AttachMatcher withOfferedCapabilities(Matcher<?> m)
- {
- getMatchers().put(Field.OFFERED_CAPABILITIES, m);
- return this;
- }
-
- public AttachMatcher withDesiredCapabilities(Matcher<?> m)
- {
- getMatchers().put(Field.DESIRED_CAPABILITIES, m);
- return this;
- }
-
- public AttachMatcher withProperties(Matcher<?> m)
- {
- getMatchers().put(Field.PROPERTIES, m);
- return this;
- }
-
- public Object getReceivedName()
- {
- return getReceivedFields().get(Field.NAME);
- }
-
- public Object getReceivedHandle()
- {
- return getReceivedFields().get(Field.HANDLE);
- }
-
- public Object getReceivedRole()
- {
- return getReceivedFields().get(Field.ROLE);
- }
-
- public Object getReceivedSndSettleMode()
- {
- return getReceivedFields().get(Field.SND_SETTLE_MODE);
- }
-
- public Object getReceivedRcvSettleMode()
- {
- return getReceivedFields().get(Field.RCV_SETTLE_MODE);
- }
-
- public Object getReceivedSource()
- {
- return getReceivedFields().get(Field.SOURCE);
- }
-
- public Object getReceivedTarget()
- {
- return getReceivedFields().get(Field.TARGET);
- }
-
- public Object getReceivedUnsettled()
- {
- return getReceivedFields().get(Field.UNSETTLED);
- }
-
- public Object getReceivedIncompleteUnsettled()
- {
- return getReceivedFields().get(Field.INCOMPLETE_UNSETTLED);
- }
-
- public Object getReceivedInitialDeliveryCount()
- {
- return getReceivedFields().get(Field.INITIAL_DELIVERY_COUNT);
- }
-
- public Object getReceivedMaxMessageSize()
- {
- return getReceivedFields().get(Field.MAX_MESSAGE_SIZE);
- }
-
- public Object getReceivedOfferedCapabilities()
- {
- return getReceivedFields().get(Field.OFFERED_CAPABILITIES);
- }
-
- public Object getReceivedDesiredCapabilities()
- {
- return getReceivedFields().get(Field.DESIRED_CAPABILITIES);
- }
-
- public Object getReceivedProperties()
- {
- return getReceivedFields().get(Field.PROPERTIES);
- }
-
- @Override
- protected Enum<?> getField(int fieldIndex)
- {
- return Field.values()[fieldIndex];
- }
-}
-
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/BeginMatcher.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/BeginMatcher.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/BeginMatcher.java
deleted file mode 100644
index ede5a31..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/BeginMatcher.java
+++ /dev/null
@@ -1,159 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.jms.test.testpeer.matchers;
-
-import java.util.HashMap;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-import org.apache.qpid.jms.test.testpeer.FrameType;
-import org.apache.qpid.jms.test.testpeer.FrameWithNoPayloadMatchingHandler;
-import org.hamcrest.Matcher;
-
-/**
- * Generated by generate-matchers.xsl, which resides in this package.
- */
-public class BeginMatcher extends FrameWithNoPayloadMatchingHandler
-{
- /** Note that the ordinals of the Field enums match the order specified in the spec */
- public enum Field
- {
- REMOTE_CHANNEL,
- NEXT_OUTGOING_ID,
- INCOMING_WINDOW,
- OUTGOING_WINDOW,
- HANDLE_MAX,
- OFFERED_CAPABILITIES,
- DESIRED_CAPABILITIES,
- PROPERTIES,
- }
-
- public BeginMatcher()
- {
- super(FrameType.AMQP,
- ANY_CHANNEL,
- UnsignedLong.valueOf(0x0000000000000011L),
- Symbol.valueOf("amqp:begin:list"),
- new HashMap<Enum<?>, Matcher<?>>(),
- null);
- }
-
- @Override
- public BeginMatcher onSuccess(Runnable onSuccessAction)
- {
- super.onSuccess(onSuccessAction);
- return this;
- }
-
- public BeginMatcher withRemoteChannel(Matcher<?> m)
- {
- getMatchers().put(Field.REMOTE_CHANNEL, m);
- return this;
- }
-
- public BeginMatcher withNextOutgoingId(Matcher<?> m)
- {
- getMatchers().put(Field.NEXT_OUTGOING_ID, m);
- return this;
- }
-
- public BeginMatcher withIncomingWindow(Matcher<?> m)
- {
- getMatchers().put(Field.INCOMING_WINDOW, m);
- return this;
- }
-
- public BeginMatcher withOutgoingWindow(Matcher<?> m)
- {
- getMatchers().put(Field.OUTGOING_WINDOW, m);
- return this;
- }
-
- public BeginMatcher withHandleMax(Matcher<?> m)
- {
- getMatchers().put(Field.HANDLE_MAX, m);
- return this;
- }
-
- public BeginMatcher withOfferedCapabilities(Matcher<?> m)
- {
- getMatchers().put(Field.OFFERED_CAPABILITIES, m);
- return this;
- }
-
- public BeginMatcher withDesiredCapabilities(Matcher<?> m)
- {
- getMatchers().put(Field.DESIRED_CAPABILITIES, m);
- return this;
- }
-
- public BeginMatcher withProperties(Matcher<?> m)
- {
- getMatchers().put(Field.PROPERTIES, m);
- return this;
- }
-
- public Object getReceivedRemoteChannel()
- {
- return getReceivedFields().get(Field.REMOTE_CHANNEL);
- }
-
- public Object getReceivedNextOutgoingId()
- {
- return getReceivedFields().get(Field.NEXT_OUTGOING_ID);
- }
-
- public Object getReceivedIncomingWindow()
- {
- return getReceivedFields().get(Field.INCOMING_WINDOW);
- }
-
- public Object getReceivedOutgoingWindow()
- {
- return getReceivedFields().get(Field.OUTGOING_WINDOW);
- }
-
- public Object getReceivedHandleMax()
- {
- return getReceivedFields().get(Field.HANDLE_MAX);
- }
-
- public Object getReceivedOfferedCapabilities()
- {
- return getReceivedFields().get(Field.OFFERED_CAPABILITIES);
- }
-
- public Object getReceivedDesiredCapabilities()
- {
- return getReceivedFields().get(Field.DESIRED_CAPABILITIES);
- }
-
- public Object getReceivedProperties()
- {
- return getReceivedFields().get(Field.PROPERTIES);
- }
-
- @Override
- protected Enum<?> getField(int fieldIndex)
- {
- return Field.values()[fieldIndex];
- }
-}
-
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/CloseMatcher.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/CloseMatcher.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/CloseMatcher.java
deleted file mode 100644
index ac03a5c..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/CloseMatcher.java
+++ /dev/null
@@ -1,75 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.jms.test.testpeer.matchers;
-
-import java.util.HashMap;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-import org.apache.qpid.jms.test.testpeer.FrameType;
-import org.apache.qpid.jms.test.testpeer.FrameWithNoPayloadMatchingHandler;
-import org.hamcrest.Matcher;
-
-/**
- * Generated by generate-matchers.xsl, which resides in this package.
- */
-public class CloseMatcher extends FrameWithNoPayloadMatchingHandler
-{
- /** Note that the ordinals of the Field enums match the order specified in the spec */
- public enum Field
- {
- ERROR,
- }
-
- public CloseMatcher()
- {
- super(FrameType.AMQP,
- ANY_CHANNEL,
- UnsignedLong.valueOf(0x0000000000000018L),
- Symbol.valueOf("amqp:close:list"),
- new HashMap<Enum<?>, Matcher<?>>(),
- null);
- }
-
- @Override
- public CloseMatcher onSuccess(Runnable onSuccessAction)
- {
- super.onSuccess(onSuccessAction);
- return this;
- }
-
- public CloseMatcher withError(Matcher<?> m)
- {
- getMatchers().put(Field.ERROR, m);
- return this;
- }
-
- public Object getReceivedError()
- {
- return getReceivedFields().get(Field.ERROR);
- }
-
- @Override
- protected Enum<?> getField(int fieldIndex)
- {
- return Field.values()[fieldIndex];
- }
-}
-
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/DetachMatcher.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/DetachMatcher.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/DetachMatcher.java
deleted file mode 100644
index dc5d2f1..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/DetachMatcher.java
+++ /dev/null
@@ -1,99 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.jms.test.testpeer.matchers;
-
-import java.util.HashMap;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-import org.apache.qpid.jms.test.testpeer.FrameType;
-import org.apache.qpid.jms.test.testpeer.FrameWithNoPayloadMatchingHandler;
-import org.hamcrest.Matcher;
-
-/**
- * Generated by generate-matchers.xsl, which resides in this package.
- */
-public class DetachMatcher extends FrameWithNoPayloadMatchingHandler
-{
- /** Note that the ordinals of the Field enums match the order specified in the spec */
- public enum Field
- {
- HANDLE,
- CLOSED,
- ERROR,
- }
-
- public DetachMatcher()
- {
- super(FrameType.AMQP,
- ANY_CHANNEL,
- UnsignedLong.valueOf(0x0000000000000016L),
- Symbol.valueOf("amqp:detach:list"),
- new HashMap<Enum<?>, Matcher<?>>(),
- null);
- }
-
- @Override
- public DetachMatcher onSuccess(Runnable onSuccessAction)
- {
- super.onSuccess(onSuccessAction);
- return this;
- }
-
- public DetachMatcher withHandle(Matcher<?> m)
- {
- getMatchers().put(Field.HANDLE, m);
- return this;
- }
-
- public DetachMatcher withClosed(Matcher<?> m)
- {
- getMatchers().put(Field.CLOSED, m);
- return this;
- }
-
- public DetachMatcher withError(Matcher<?> m)
- {
- getMatchers().put(Field.ERROR, m);
- return this;
- }
-
- public Object getReceivedHandle()
- {
- return getReceivedFields().get(Field.HANDLE);
- }
-
- public Object getReceivedClosed()
- {
- return getReceivedFields().get(Field.CLOSED);
- }
-
- public Object getReceivedError()
- {
- return getReceivedFields().get(Field.ERROR);
- }
-
- @Override
- protected Enum<?> getField(int fieldIndex)
- {
- return Field.values()[fieldIndex];
- }
-}
-
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/DispositionMatcher.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/DispositionMatcher.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/DispositionMatcher.java
deleted file mode 100644
index 3d41fee..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/DispositionMatcher.java
+++ /dev/null
@@ -1,135 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.jms.test.testpeer.matchers;
-
-import java.util.HashMap;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-import org.apache.qpid.jms.test.testpeer.FrameType;
-import org.apache.qpid.jms.test.testpeer.FrameWithNoPayloadMatchingHandler;
-import org.hamcrest.Matcher;
-
-/**
- * Generated by generate-matchers.xsl, which resides in this package.
- */
-public class DispositionMatcher extends FrameWithNoPayloadMatchingHandler
-{
- /** Note that the ordinals of the Field enums match the order specified in the spec */
- public enum Field
- {
- ROLE,
- FIRST,
- LAST,
- SETTLED,
- STATE,
- BATCHABLE,
- }
-
- public DispositionMatcher()
- {
- super(FrameType.AMQP,
- ANY_CHANNEL,
- UnsignedLong.valueOf(0x0000000000000015L),
- Symbol.valueOf("amqp:disposition:list"),
- new HashMap<Enum<?>, Matcher<?>>(),
- null);
- }
-
- @Override
- public DispositionMatcher onSuccess(Runnable onSuccessAction)
- {
- super.onSuccess(onSuccessAction);
- return this;
- }
-
- public DispositionMatcher withRole(Matcher<?> m)
- {
- getMatchers().put(Field.ROLE, m);
- return this;
- }
-
- public DispositionMatcher withFirst(Matcher<?> m)
- {
- getMatchers().put(Field.FIRST, m);
- return this;
- }
-
- public DispositionMatcher withLast(Matcher<?> m)
- {
- getMatchers().put(Field.LAST, m);
- return this;
- }
-
- public DispositionMatcher withSettled(Matcher<?> m)
- {
- getMatchers().put(Field.SETTLED, m);
- return this;
- }
-
- public DispositionMatcher withState(Matcher<?> m)
- {
- getMatchers().put(Field.STATE, m);
- return this;
- }
-
- public DispositionMatcher withBatchable(Matcher<?> m)
- {
- getMatchers().put(Field.BATCHABLE, m);
- return this;
- }
-
- public Object getReceivedRole()
- {
- return getReceivedFields().get(Field.ROLE);
- }
-
- public Object getReceivedFirst()
- {
- return getReceivedFields().get(Field.FIRST);
- }
-
- public Object getReceivedLast()
- {
- return getReceivedFields().get(Field.LAST);
- }
-
- public Object getReceivedSettled()
- {
- return getReceivedFields().get(Field.SETTLED);
- }
-
- public Object getReceivedState()
- {
- return getReceivedFields().get(Field.STATE);
- }
-
- public Object getReceivedBatchable()
- {
- return getReceivedFields().get(Field.BATCHABLE);
- }
-
- @Override
- protected Enum<?> getField(int fieldIndex)
- {
- return Field.values()[fieldIndex];
- }
-}
-
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/EndMatcher.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/EndMatcher.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/EndMatcher.java
deleted file mode 100644
index 460bbaa..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/EndMatcher.java
+++ /dev/null
@@ -1,75 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.jms.test.testpeer.matchers;
-
-import java.util.HashMap;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-import org.apache.qpid.jms.test.testpeer.FrameType;
-import org.apache.qpid.jms.test.testpeer.FrameWithNoPayloadMatchingHandler;
-import org.hamcrest.Matcher;
-
-/**
- * Generated by generate-matchers.xsl, which resides in this package.
- */
-public class EndMatcher extends FrameWithNoPayloadMatchingHandler
-{
- /** Note that the ordinals of the Field enums match the order specified in the spec */
- public enum Field
- {
- ERROR,
- }
-
- public EndMatcher()
- {
- super(FrameType.AMQP,
- ANY_CHANNEL,
- UnsignedLong.valueOf(0x0000000000000017L),
- Symbol.valueOf("amqp:end:list"),
- new HashMap<Enum<?>, Matcher<?>>(),
- null);
- }
-
- @Override
- public EndMatcher onSuccess(Runnable onSuccessAction)
- {
- super.onSuccess(onSuccessAction);
- return this;
- }
-
- public EndMatcher withError(Matcher<?> m)
- {
- getMatchers().put(Field.ERROR, m);
- return this;
- }
-
- public Object getReceivedError()
- {
- return getReceivedFields().get(Field.ERROR);
- }
-
- @Override
- protected Enum<?> getField(int fieldIndex)
- {
- return Field.values()[fieldIndex];
- }
-}
-
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/FlowMatcher.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/FlowMatcher.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/FlowMatcher.java
deleted file mode 100644
index 9f6f74b..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/FlowMatcher.java
+++ /dev/null
@@ -1,195 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.jms.test.testpeer.matchers;
-
-import java.util.HashMap;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-import org.apache.qpid.jms.test.testpeer.FrameType;
-import org.apache.qpid.jms.test.testpeer.FrameWithNoPayloadMatchingHandler;
-import org.hamcrest.Matcher;
-
-/**
- * Generated by generate-matchers.xsl, which resides in this package.
- */
-public class FlowMatcher extends FrameWithNoPayloadMatchingHandler
-{
- /** Note that the ordinals of the Field enums match the order specified in the spec */
- public enum Field
- {
- NEXT_INCOMING_ID,
- INCOMING_WINDOW,
- NEXT_OUTGOING_ID,
- OUTGOING_WINDOW,
- HANDLE,
- DELIVERY_COUNT,
- LINK_CREDIT,
- AVAILABLE,
- DRAIN,
- ECHO,
- PROPERTIES,
- }
-
- public FlowMatcher()
- {
- super(FrameType.AMQP,
- ANY_CHANNEL,
- UnsignedLong.valueOf(0x0000000000000013L),
- Symbol.valueOf("amqp:flow:list"),
- new HashMap<Enum<?>, Matcher<?>>(),
- null);
- }
-
- @Override
- public FlowMatcher onSuccess(Runnable onSuccessAction)
- {
- super.onSuccess(onSuccessAction);
- return this;
- }
-
- public FlowMatcher withNextIncomingId(Matcher<?> m)
- {
- getMatchers().put(Field.NEXT_INCOMING_ID, m);
- return this;
- }
-
- public FlowMatcher withIncomingWindow(Matcher<?> m)
- {
- getMatchers().put(Field.INCOMING_WINDOW, m);
- return this;
- }
-
- public FlowMatcher withNextOutgoingId(Matcher<?> m)
- {
- getMatchers().put(Field.NEXT_OUTGOING_ID, m);
- return this;
- }
-
- public FlowMatcher withOutgoingWindow(Matcher<?> m)
- {
- getMatchers().put(Field.OUTGOING_WINDOW, m);
- return this;
- }
-
- public FlowMatcher withHandle(Matcher<?> m)
- {
- getMatchers().put(Field.HANDLE, m);
- return this;
- }
-
- public FlowMatcher withDeliveryCount(Matcher<?> m)
- {
- getMatchers().put(Field.DELIVERY_COUNT, m);
- return this;
- }
-
- public FlowMatcher withLinkCredit(Matcher<?> m)
- {
- getMatchers().put(Field.LINK_CREDIT, m);
- return this;
- }
-
- public FlowMatcher withAvailable(Matcher<?> m)
- {
- getMatchers().put(Field.AVAILABLE, m);
- return this;
- }
-
- public FlowMatcher withDrain(Matcher<?> m)
- {
- getMatchers().put(Field.DRAIN, m);
- return this;
- }
-
- public FlowMatcher withEcho(Matcher<?> m)
- {
- getMatchers().put(Field.ECHO, m);
- return this;
- }
-
- public FlowMatcher withProperties(Matcher<?> m)
- {
- getMatchers().put(Field.PROPERTIES, m);
- return this;
- }
-
- public Object getReceivedNextIncomingId()
- {
- return getReceivedFields().get(Field.NEXT_INCOMING_ID);
- }
-
- public Object getReceivedIncomingWindow()
- {
- return getReceivedFields().get(Field.INCOMING_WINDOW);
- }
-
- public Object getReceivedNextOutgoingId()
- {
- return getReceivedFields().get(Field.NEXT_OUTGOING_ID);
- }
-
- public Object getReceivedOutgoingWindow()
- {
- return getReceivedFields().get(Field.OUTGOING_WINDOW);
- }
-
- public Object getReceivedHandle()
- {
- return getReceivedFields().get(Field.HANDLE);
- }
-
- public Object getReceivedDeliveryCount()
- {
- return getReceivedFields().get(Field.DELIVERY_COUNT);
- }
-
- public Object getReceivedLinkCredit()
- {
- return getReceivedFields().get(Field.LINK_CREDIT);
- }
-
- public Object getReceivedAvailable()
- {
- return getReceivedFields().get(Field.AVAILABLE);
- }
-
- public Object getReceivedDrain()
- {
- return getReceivedFields().get(Field.DRAIN);
- }
-
- public Object getReceivedEcho()
- {
- return getReceivedFields().get(Field.ECHO);
- }
-
- public Object getReceivedProperties()
- {
- return getReceivedFields().get(Field.PROPERTIES);
- }
-
- @Override
- protected Enum<?> getField(int fieldIndex)
- {
- return Field.values()[fieldIndex];
- }
-}
-
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/OpenMatcher.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/OpenMatcher.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/OpenMatcher.java
deleted file mode 100644
index fd0bf61..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/OpenMatcher.java
+++ /dev/null
@@ -1,183 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.jms.test.testpeer.matchers;
-
-import java.util.HashMap;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-import org.apache.qpid.jms.test.testpeer.FrameType;
-import org.apache.qpid.jms.test.testpeer.FrameWithNoPayloadMatchingHandler;
-import org.hamcrest.Matcher;
-
-/**
- * Generated by generate-matchers.xsl, which resides in this package.
- */
-public class OpenMatcher extends FrameWithNoPayloadMatchingHandler
-{
- /** Note that the ordinals of the Field enums match the order specified in the spec */
- public enum Field
- {
- CONTAINER_ID,
- HOSTNAME,
- MAX_FRAME_SIZE,
- CHANNEL_MAX,
- IDLE_TIME_OUT,
- OUTGOING_LOCALES,
- INCOMING_LOCALES,
- OFFERED_CAPABILITIES,
- DESIRED_CAPABILITIES,
- PROPERTIES,
- }
-
- public OpenMatcher()
- {
- super(FrameType.AMQP,
- ANY_CHANNEL,
- UnsignedLong.valueOf(0x0000000000000010L),
- Symbol.valueOf("amqp:open:list"),
- new HashMap<Enum<?>, Matcher<?>>(),
- null);
- }
-
- @Override
- public OpenMatcher onSuccess(Runnable onSuccessAction)
- {
- super.onSuccess(onSuccessAction);
- return this;
- }
-
- public OpenMatcher withContainerId(Matcher<?> m)
- {
- getMatchers().put(Field.CONTAINER_ID, m);
- return this;
- }
-
- public OpenMatcher withHostname(Matcher<?> m)
- {
- getMatchers().put(Field.HOSTNAME, m);
- return this;
- }
-
- public OpenMatcher withMaxFrameSize(Matcher<?> m)
- {
- getMatchers().put(Field.MAX_FRAME_SIZE, m);
- return this;
- }
-
- public OpenMatcher withChannelMax(Matcher<?> m)
- {
- getMatchers().put(Field.CHANNEL_MAX, m);
- return this;
- }
-
- public OpenMatcher withIdleTimeOut(Matcher<?> m)
- {
- getMatchers().put(Field.IDLE_TIME_OUT, m);
- return this;
- }
-
- public OpenMatcher withOutgoingLocales(Matcher<?> m)
- {
- getMatchers().put(Field.OUTGOING_LOCALES, m);
- return this;
- }
-
- public OpenMatcher withIncomingLocales(Matcher<?> m)
- {
- getMatchers().put(Field.INCOMING_LOCALES, m);
- return this;
- }
-
- public OpenMatcher withOfferedCapabilities(Matcher<?> m)
- {
- getMatchers().put(Field.OFFERED_CAPABILITIES, m);
- return this;
- }
-
- public OpenMatcher withDesiredCapabilities(Matcher<?> m)
- {
- getMatchers().put(Field.DESIRED_CAPABILITIES, m);
- return this;
- }
-
- public OpenMatcher withProperties(Matcher<?> m)
- {
- getMatchers().put(Field.PROPERTIES, m);
- return this;
- }
-
- public Object getReceivedContainerId()
- {
- return getReceivedFields().get(Field.CONTAINER_ID);
- }
-
- public Object getReceivedHostname()
- {
- return getReceivedFields().get(Field.HOSTNAME);
- }
-
- public Object getReceivedMaxFrameSize()
- {
- return getReceivedFields().get(Field.MAX_FRAME_SIZE);
- }
-
- public Object getReceivedChannelMax()
- {
- return getReceivedFields().get(Field.CHANNEL_MAX);
- }
-
- public Object getReceivedIdleTimeOut()
- {
- return getReceivedFields().get(Field.IDLE_TIME_OUT);
- }
-
- public Object getReceivedOutgoingLocales()
- {
- return getReceivedFields().get(Field.OUTGOING_LOCALES);
- }
-
- public Object getReceivedIncomingLocales()
- {
- return getReceivedFields().get(Field.INCOMING_LOCALES);
- }
-
- public Object getReceivedOfferedCapabilities()
- {
- return getReceivedFields().get(Field.OFFERED_CAPABILITIES);
- }
-
- public Object getReceivedDesiredCapabilities()
- {
- return getReceivedFields().get(Field.DESIRED_CAPABILITIES);
- }
-
- public Object getReceivedProperties()
- {
- return getReceivedFields().get(Field.PROPERTIES);
- }
-
- @Override
- protected Enum<?> getField(int fieldIndex)
- {
- return Field.values()[fieldIndex];
- }
-}
-
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslChallengeMatcher.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslChallengeMatcher.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslChallengeMatcher.java
deleted file mode 100644
index 08b0bc7..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslChallengeMatcher.java
+++ /dev/null
@@ -1,75 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.jms.test.testpeer.matchers;
-
-import java.util.HashMap;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-import org.apache.qpid.jms.test.testpeer.FrameType;
-import org.apache.qpid.jms.test.testpeer.FrameWithNoPayloadMatchingHandler;
-import org.hamcrest.Matcher;
-
-/**
- * Generated by generate-matchers.xsl, which resides in this package.
- */
-public class SaslChallengeMatcher extends FrameWithNoPayloadMatchingHandler
-{
- /** Note that the ordinals of the Field enums match the order specified in the spec */
- public enum Field
- {
- CHALLENGE,
- }
-
- public SaslChallengeMatcher()
- {
- super(FrameType.SASL,
- ANY_CHANNEL,
- UnsignedLong.valueOf(0x0000000000000042L),
- Symbol.valueOf("amqp:sasl-challenge:list"),
- new HashMap<Enum<?>, Matcher<?>>(),
- null);
- }
-
- @Override
- public SaslChallengeMatcher onSuccess(Runnable onSuccessAction)
- {
- super.onSuccess(onSuccessAction);
- return this;
- }
-
- public SaslChallengeMatcher withChallenge(Matcher<?> m)
- {
- getMatchers().put(Field.CHALLENGE, m);
- return this;
- }
-
- public Object getReceivedChallenge()
- {
- return getReceivedFields().get(Field.CHALLENGE);
- }
-
- @Override
- protected Enum<?> getField(int fieldIndex)
- {
- return Field.values()[fieldIndex];
- }
-}
-
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslInitMatcher.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslInitMatcher.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslInitMatcher.java
deleted file mode 100644
index 7284edb..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslInitMatcher.java
+++ /dev/null
@@ -1,99 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.jms.test.testpeer.matchers;
-
-import java.util.HashMap;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-import org.apache.qpid.jms.test.testpeer.FrameType;
-import org.apache.qpid.jms.test.testpeer.FrameWithNoPayloadMatchingHandler;
-import org.hamcrest.Matcher;
-
-/**
- * Generated by generate-matchers.xsl, which resides in this package.
- */
-public class SaslInitMatcher extends FrameWithNoPayloadMatchingHandler
-{
- /** Note that the ordinals of the Field enums match the order specified in the spec */
- public enum Field
- {
- MECHANISM,
- INITIAL_RESPONSE,
- HOSTNAME,
- }
-
- public SaslInitMatcher()
- {
- super(FrameType.SASL,
- ANY_CHANNEL,
- UnsignedLong.valueOf(0x0000000000000041L),
- Symbol.valueOf("amqp:sasl-init:list"),
- new HashMap<Enum<?>, Matcher<?>>(),
- null);
- }
-
- @Override
- public SaslInitMatcher onSuccess(Runnable onSuccessAction)
- {
- super.onSuccess(onSuccessAction);
- return this;
- }
-
- public SaslInitMatcher withMechanism(Matcher<?> m)
- {
- getMatchers().put(Field.MECHANISM, m);
- return this;
- }
-
- public SaslInitMatcher withInitialResponse(Matcher<?> m)
- {
- getMatchers().put(Field.INITIAL_RESPONSE, m);
- return this;
- }
-
- public SaslInitMatcher withHostname(Matcher<?> m)
- {
- getMatchers().put(Field.HOSTNAME, m);
- return this;
- }
-
- public Object getReceivedMechanism()
- {
- return getReceivedFields().get(Field.MECHANISM);
- }
-
- public Object getReceivedInitialResponse()
- {
- return getReceivedFields().get(Field.INITIAL_RESPONSE);
- }
-
- public Object getReceivedHostname()
- {
- return getReceivedFields().get(Field.HOSTNAME);
- }
-
- @Override
- protected Enum<?> getField(int fieldIndex)
- {
- return Field.values()[fieldIndex];
- }
-}
-
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslMechanismsMatcher.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslMechanismsMatcher.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslMechanismsMatcher.java
deleted file mode 100644
index 63fd913..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslMechanismsMatcher.java
+++ /dev/null
@@ -1,75 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.jms.test.testpeer.matchers;
-
-import java.util.HashMap;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-import org.apache.qpid.jms.test.testpeer.FrameType;
-import org.apache.qpid.jms.test.testpeer.FrameWithNoPayloadMatchingHandler;
-import org.hamcrest.Matcher;
-
-/**
- * Generated by generate-matchers.xsl, which resides in this package.
- */
-public class SaslMechanismsMatcher extends FrameWithNoPayloadMatchingHandler
-{
- /** Note that the ordinals of the Field enums match the order specified in the spec */
- public enum Field
- {
- SASL_SERVER_MECHANISMS,
- }
-
- public SaslMechanismsMatcher()
- {
- super(FrameType.SASL,
- ANY_CHANNEL,
- UnsignedLong.valueOf(0x0000000000000040L),
- Symbol.valueOf("amqp:sasl-mechanisms:list"),
- new HashMap<Enum<?>, Matcher<?>>(),
- null);
- }
-
- @Override
- public SaslMechanismsMatcher onSuccess(Runnable onSuccessAction)
- {
- super.onSuccess(onSuccessAction);
- return this;
- }
-
- public SaslMechanismsMatcher withSaslServerMechanisms(Matcher<?> m)
- {
- getMatchers().put(Field.SASL_SERVER_MECHANISMS, m);
- return this;
- }
-
- public Object getReceivedSaslServerMechanisms()
- {
- return getReceivedFields().get(Field.SASL_SERVER_MECHANISMS);
- }
-
- @Override
- protected Enum<?> getField(int fieldIndex)
- {
- return Field.values()[fieldIndex];
- }
-}
-
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslOutcomeMatcher.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslOutcomeMatcher.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslOutcomeMatcher.java
deleted file mode 100644
index 22355d1..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslOutcomeMatcher.java
+++ /dev/null
@@ -1,87 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.jms.test.testpeer.matchers;
-
-import java.util.HashMap;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-import org.apache.qpid.jms.test.testpeer.FrameType;
-import org.apache.qpid.jms.test.testpeer.FrameWithNoPayloadMatchingHandler;
-import org.hamcrest.Matcher;
-
-/**
- * Generated by generate-matchers.xsl, which resides in this package.
- */
-public class SaslOutcomeMatcher extends FrameWithNoPayloadMatchingHandler
-{
- /** Note that the ordinals of the Field enums match the order specified in the spec */
- public enum Field
- {
- CODE,
- ADDITIONAL_DATA,
- }
-
- public SaslOutcomeMatcher()
- {
- super(FrameType.SASL,
- ANY_CHANNEL,
- UnsignedLong.valueOf(0x0000000000000044L),
- Symbol.valueOf("amqp:sasl-outcome:list"),
- new HashMap<Enum<?>, Matcher<?>>(),
- null);
- }
-
- @Override
- public SaslOutcomeMatcher onSuccess(Runnable onSuccessAction)
- {
- super.onSuccess(onSuccessAction);
- return this;
- }
-
- public SaslOutcomeMatcher withCode(Matcher<?> m)
- {
- getMatchers().put(Field.CODE, m);
- return this;
- }
-
- public SaslOutcomeMatcher withAdditionalData(Matcher<?> m)
- {
- getMatchers().put(Field.ADDITIONAL_DATA, m);
- return this;
- }
-
- public Object getReceivedCode()
- {
- return getReceivedFields().get(Field.CODE);
- }
-
- public Object getReceivedAdditionalData()
- {
- return getReceivedFields().get(Field.ADDITIONAL_DATA);
- }
-
- @Override
- protected Enum<?> getField(int fieldIndex)
- {
- return Field.values()[fieldIndex];
- }
-}
-
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslResponseMatcher.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslResponseMatcher.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslResponseMatcher.java
deleted file mode 100644
index c5fb865..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/SaslResponseMatcher.java
+++ /dev/null
@@ -1,75 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.jms.test.testpeer.matchers;
-
-import java.util.HashMap;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-import org.apache.qpid.jms.test.testpeer.FrameType;
-import org.apache.qpid.jms.test.testpeer.FrameWithNoPayloadMatchingHandler;
-import org.hamcrest.Matcher;
-
-/**
- * Generated by generate-matchers.xsl, which resides in this package.
- */
-public class SaslResponseMatcher extends FrameWithNoPayloadMatchingHandler
-{
- /** Note that the ordinals of the Field enums match the order specified in the spec */
- public enum Field
- {
- RESPONSE,
- }
-
- public SaslResponseMatcher()
- {
- super(FrameType.SASL,
- ANY_CHANNEL,
- UnsignedLong.valueOf(0x0000000000000043L),
- Symbol.valueOf("amqp:sasl-response:list"),
- new HashMap<Enum<?>, Matcher<?>>(),
- null);
- }
-
- @Override
- public SaslResponseMatcher onSuccess(Runnable onSuccessAction)
- {
- super.onSuccess(onSuccessAction);
- return this;
- }
-
- public SaslResponseMatcher withResponse(Matcher<?> m)
- {
- getMatchers().put(Field.RESPONSE, m);
- return this;
- }
-
- public Object getReceivedResponse()
- {
- return getReceivedFields().get(Field.RESPONSE);
- }
-
- @Override
- protected Enum<?> getField(int fieldIndex)
- {
- return Field.values()[fieldIndex];
- }
-}
-
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6f106f64/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/TransferMatcher.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/TransferMatcher.java b/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/TransferMatcher.java
deleted file mode 100644
index d7274a1..0000000
--- a/qpid-jms-client-tmp/src/test/java/org/apache/qpid/jms/test/testpeer/matchers/TransferMatcher.java
+++ /dev/null
@@ -1,195 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.jms.test.testpeer.matchers;
-
-import java.util.HashMap;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.UnsignedLong;
-import org.apache.qpid.jms.test.testpeer.FrameType;
-import org.apache.qpid.jms.test.testpeer.FrameWithPayloadMatchingHandler;
-import org.hamcrest.Matcher;
-
-/**
- * Generated by generate-matchers.xsl, which resides in this package.
- */
-public class TransferMatcher extends FrameWithPayloadMatchingHandler
-{
- /** Note that the ordinals of the Field enums match the order specified in the spec */
- public enum Field
- {
- HANDLE,
- DELIVERY_ID,
- DELIVERY_TAG,
- MESSAGE_FORMAT,
- SETTLED,
- MORE,
- RCV_SETTLE_MODE,
- STATE,
- RESUME,
- ABORTED,
- BATCHABLE,
- }
-
- public TransferMatcher()
- {
- super(FrameType.AMQP,
- ANY_CHANNEL,
- UnsignedLong.valueOf(0x0000000000000014L),
- Symbol.valueOf("amqp:transfer:list"),
- new HashMap<Enum<?>, Matcher<?>>(),
- null);
- }
-
- @Override
- public TransferMatcher onSuccess(Runnable onSuccessAction)
- {
- super.onSuccess(onSuccessAction);
- return this;
- }
-
- public TransferMatcher withHandle(Matcher<?> m)
- {
- getMatchers().put(Field.HANDLE, m);
- return this;
- }
-
- public TransferMatcher withDeliveryId(Matcher<?> m)
- {
- getMatchers().put(Field.DELIVERY_ID, m);
- return this;
- }
-
- public TransferMatcher withDeliveryTag(Matcher<?> m)
- {
- getMatchers().put(Field.DELIVERY_TAG, m);
- return this;
- }
-
- public TransferMatcher withMessageFormat(Matcher<?> m)
- {
- getMatchers().put(Field.MESSAGE_FORMAT, m);
- return this;
- }
-
- public TransferMatcher withSettled(Matcher<?> m)
- {
- getMatchers().put(Field.SETTLED, m);
- return this;
- }
-
- public TransferMatcher withMore(Matcher<?> m)
- {
- getMatchers().put(Field.MORE, m);
- return this;
- }
-
- public TransferMatcher withRcvSettleMode(Matcher<?> m)
- {
- getMatchers().put(Field.RCV_SETTLE_MODE, m);
- return this;
- }
-
- public TransferMatcher withState(Matcher<?> m)
- {
- getMatchers().put(Field.STATE, m);
- return this;
- }
-
- public TransferMatcher withResume(Matcher<?> m)
- {
- getMatchers().put(Field.RESUME, m);
- return this;
- }
-
- public TransferMatcher withAborted(Matcher<?> m)
- {
- getMatchers().put(Field.ABORTED, m);
- return this;
- }
-
- public TransferMatcher withBatchable(Matcher<?> m)
- {
- getMatchers().put(Field.BATCHABLE, m);
- return this;
- }
-
- public Object getReceivedHandle()
- {
- return getReceivedFields().get(Field.HANDLE);
- }
-
- public Object getReceivedDeliveryId()
- {
- return getReceivedFields().get(Field.DELIVERY_ID);
- }
-
- public Object getReceivedDeliveryTag()
- {
- return getReceivedFields().get(Field.DELIVERY_TAG);
- }
-
- public Object getReceivedMessageFormat()
- {
- return getReceivedFields().get(Field.MESSAGE_FORMAT);
- }
-
- public Object getReceivedSettled()
- {
- return getReceivedFields().get(Field.SETTLED);
- }
-
- public Object getReceivedMore()
- {
- return getReceivedFields().get(Field.MORE);
- }
-
- public Object getReceivedRcvSettleMode()
- {
- return getReceivedFields().get(Field.RCV_SETTLE_MODE);
- }
-
- public Object getReceivedState()
- {
- return getReceivedFields().get(Field.STATE);
- }
-
- public Object getReceivedResume()
- {
- return getReceivedFields().get(Field.RESUME);
- }
-
- public Object getReceivedAborted()
- {
- return getReceivedFields().get(Field.ABORTED);
- }
-
- public Object getReceivedBatchable()
- {
- return getReceivedFields().get(Field.BATCHABLE);
- }
-
- @Override
- protected Enum<?> getField(int fieldIndex)
- {
- return Field.values()[fieldIndex];
- }
-}
-
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org