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 2013/09/29 19:45:25 UTC
svn commit: r1527366 [6/29] - in /qpid/trunk/qpid/java:
broker-core/src/main/java/org/apache/qpid/server/logging/messages/
common/src/main/java/org/apache/qpid/filter/selector/
common/src/main/java/org/apache/qpid/framing/
common/src/main/java/org/apac...
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageCancelBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageCancelBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageCancelBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageCancelBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,36 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface MessageCancelBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public AMQShortString getDestination();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageCheckpointBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageCheckpointBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageCheckpointBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageCheckpointBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,38 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface MessageCheckpointBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public AMQShortString getIdentifier();
+
+ public byte[] getReference();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageCloseBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageCloseBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageCloseBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageCloseBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,36 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface MessageCloseBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public byte[] getReference();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageConsumeBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageConsumeBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageConsumeBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageConsumeBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,48 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface MessageConsumeBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public AMQShortString getDestination();
+
+ public boolean getExclusive();
+
+ public FieldTable getFilter();
+
+ public boolean getNoAck();
+
+ public boolean getNoLocal();
+
+ public AMQShortString getQueue();
+
+ public int getTicket();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageEmptyBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageEmptyBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageEmptyBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageEmptyBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,34 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface MessageEmptyBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageGetBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageGetBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageGetBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageGetBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,42 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface MessageGetBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public AMQShortString getDestination();
+
+ public boolean getNoAck();
+
+ public AMQShortString getQueue();
+
+ public int getTicket();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageOffsetBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageOffsetBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageOffsetBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageOffsetBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,36 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface MessageOffsetBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public long getValue();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageOkBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageOkBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageOkBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageOkBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,34 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface MessageOkBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageOpenBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageOpenBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageOpenBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageOpenBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,36 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface MessageOpenBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public byte[] getReference();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageQosBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageQosBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageQosBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageQosBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,40 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface MessageQosBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public boolean getGlobal();
+
+ public int getPrefetchCount();
+
+ public long getPrefetchSize();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageRecoverBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageRecoverBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageRecoverBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageRecoverBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,36 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface MessageRecoverBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public boolean getRequeue();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageRejectBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageRejectBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageRejectBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageRejectBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,38 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface MessageRejectBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public int getCode();
+
+ public AMQShortString getText();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageResumeBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageResumeBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageResumeBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageResumeBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,38 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface MessageResumeBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public AMQShortString getIdentifier();
+
+ public byte[] getReference();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageTransferBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageTransferBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageTransferBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MessageTransferBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,78 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface MessageTransferBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public AMQShortString getAppId();
+
+ public FieldTable getApplicationHeaders();
+
+ public Content getBody();
+
+ public AMQShortString getContentEncoding();
+
+ public AMQShortString getContentType();
+
+ public AMQShortString getCorrelationId();
+
+ public short getDeliveryMode();
+
+ public AMQShortString getDestination();
+
+ public AMQShortString getExchange();
+
+ public long getExpiration();
+
+ public boolean getImmediate();
+
+ public AMQShortString getMessageId();
+
+ public short getPriority();
+
+ public boolean getRedelivered();
+
+ public AMQShortString getReplyTo();
+
+ public AMQShortString getRoutingKey();
+
+ public byte[] getSecurityToken();
+
+ public int getTicket();
+
+ public long getTimestamp();
+
+ public AMQShortString getTransactionId();
+
+ public long getTtl();
+
+ public AMQShortString getUserId();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MethodDispatcher.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MethodDispatcher.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MethodDispatcher.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MethodDispatcher.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,35 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface MethodDispatcher extends
+ ClientMethodDispatcher, ServerMethodDispatcher
+{
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MethodRegistry.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MethodRegistry.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MethodRegistry.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/MethodRegistry.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,358 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+import java.io.IOException;
+
+import org.apache.qpid.framing.abstraction.ProtocolVersionMethodConverter;
+import org.apache.qpid.codec.MarkableDataInput;
+
+import java.util.Map;
+import java.util.HashMap;
+
+
+public abstract class MethodRegistry
+{
+ private static final Map<ProtocolVersion, MethodRegistry> _registries =
+ new HashMap<ProtocolVersion, MethodRegistry>();
+
+
+ public static final MethodRegistry registry_0_9 =
+ new org.apache.qpid.framing.amqp_0_9.MethodRegistry_0_9();
+
+ public static final MethodRegistry registry_0_91 =
+ new org.apache.qpid.framing.amqp_0_91.MethodRegistry_0_91();
+
+ public static final MethodRegistry registry_8_0 =
+ new org.apache.qpid.framing.amqp_8_0.MethodRegistry_8_0();
+
+ public abstract AMQMethodBody convertToBody(MarkableDataInput in, long size)
+ throws AMQFrameDecodingException, IOException;
+
+ public abstract int getMaxClassId();
+
+ public abstract int getMaxMethodId(int classId);
+
+ protected MethodRegistry(ProtocolVersion pv)
+ {
+ _registries.put(pv, this);
+ }
+
+ public static MethodRegistry getMethodRegistry(ProtocolVersion pv)
+ {
+ return _registries.get(pv);
+ }
+
+
+
+
+ public abstract BasicAckBody createBasicAckBody(
+ final long deliveryTag,
+ final boolean multiple
+ );
+
+ public abstract BasicCancelBody createBasicCancelBody(
+ final AMQShortString consumerTag,
+ final boolean nowait
+ );
+
+ public abstract BasicCancelOkBody createBasicCancelOkBody(
+ final AMQShortString consumerTag
+ );
+
+ public abstract BasicConsumeBody createBasicConsumeBody(
+ final int ticket,
+ final AMQShortString queue,
+ final AMQShortString consumerTag,
+ final boolean noLocal,
+ final boolean noAck,
+ final boolean exclusive,
+ final boolean nowait,
+ final FieldTable arguments
+ );
+
+ public abstract BasicConsumeOkBody createBasicConsumeOkBody(
+ final AMQShortString consumerTag
+ );
+
+ public abstract BasicDeliverBody createBasicDeliverBody(
+ final AMQShortString consumerTag,
+ final long deliveryTag,
+ final boolean redelivered,
+ final AMQShortString exchange,
+ final AMQShortString routingKey
+ );
+
+ public abstract BasicGetBody createBasicGetBody(
+ final int ticket,
+ final AMQShortString queue,
+ final boolean noAck
+ );
+
+ public abstract BasicGetEmptyBody createBasicGetEmptyBody(
+ final AMQShortString clusterId
+ );
+
+ public abstract BasicGetOkBody createBasicGetOkBody(
+ final long deliveryTag,
+ final boolean redelivered,
+ final AMQShortString exchange,
+ final AMQShortString routingKey,
+ final long messageCount
+ );
+
+ public abstract BasicPublishBody createBasicPublishBody(
+ final int ticket,
+ final AMQShortString exchange,
+ final AMQShortString routingKey,
+ final boolean mandatory,
+ final boolean immediate
+ );
+
+ public abstract BasicQosBody createBasicQosBody(
+ final long prefetchSize,
+ final int prefetchCount,
+ final boolean global
+ );
+
+ public abstract BasicQosOkBody createBasicQosOkBody(
+ );
+
+ public abstract BasicRecoverBody createBasicRecoverBody(
+ final boolean requeue
+ );
+
+ public abstract BasicRejectBody createBasicRejectBody(
+ final long deliveryTag,
+ final boolean requeue
+ );
+
+ public abstract BasicReturnBody createBasicReturnBody(
+ final int replyCode,
+ final AMQShortString replyText,
+ final AMQShortString exchange,
+ final AMQShortString routingKey
+ );
+
+
+ public abstract ChannelCloseBody createChannelCloseBody(
+ final int replyCode,
+ final AMQShortString replyText,
+ final int classId,
+ final int methodId
+ );
+
+ public abstract ChannelCloseOkBody createChannelCloseOkBody(
+ );
+
+ public abstract ChannelFlowBody createChannelFlowBody(
+ final boolean active
+ );
+
+ public abstract ChannelFlowOkBody createChannelFlowOkBody(
+ final boolean active
+ );
+
+ public abstract ChannelOpenBody createChannelOpenBody(
+ final AMQShortString outOfBand
+ );
+
+
+ public abstract ConnectionCloseBody createConnectionCloseBody(
+ final int replyCode,
+ final AMQShortString replyText,
+ final int classId,
+ final int methodId
+ );
+
+ public abstract ConnectionCloseOkBody createConnectionCloseOkBody(
+ );
+
+ public abstract ConnectionOpenBody createConnectionOpenBody(
+ final AMQShortString virtualHost,
+ final AMQShortString capabilities,
+ final boolean insist
+ );
+
+ public abstract ConnectionOpenOkBody createConnectionOpenOkBody(
+ final AMQShortString knownHosts
+ );
+
+ public abstract ConnectionSecureBody createConnectionSecureBody(
+ final byte[] challenge
+ );
+
+ public abstract ConnectionSecureOkBody createConnectionSecureOkBody(
+ final byte[] response
+ );
+
+ public abstract ConnectionStartBody createConnectionStartBody(
+ final short versionMajor,
+ final short versionMinor,
+ final FieldTable serverProperties,
+ final byte[] mechanisms,
+ final byte[] locales
+ );
+
+ public abstract ConnectionStartOkBody createConnectionStartOkBody(
+ final FieldTable clientProperties,
+ final AMQShortString mechanism,
+ final byte[] response,
+ final AMQShortString locale
+ );
+
+ public abstract ConnectionTuneBody createConnectionTuneBody(
+ final int channelMax,
+ final long frameMax,
+ final int heartbeat
+ );
+
+ public abstract ConnectionTuneOkBody createConnectionTuneOkBody(
+ final int channelMax,
+ final long frameMax,
+ final int heartbeat
+ );
+
+
+
+ public abstract ExchangeBoundBody createExchangeBoundBody(
+ final AMQShortString exchange,
+ final AMQShortString routingKey,
+ final AMQShortString queue
+ );
+
+ public abstract ExchangeBoundOkBody createExchangeBoundOkBody(
+ final int replyCode,
+ final AMQShortString replyText
+ );
+
+ public abstract ExchangeDeclareBody createExchangeDeclareBody(
+ final int ticket,
+ final AMQShortString exchange,
+ final AMQShortString type,
+ final boolean passive,
+ final boolean durable,
+ final boolean autoDelete,
+ final boolean internal,
+ final boolean nowait,
+ final FieldTable arguments
+ );
+
+ public abstract ExchangeDeclareOkBody createExchangeDeclareOkBody(
+ );
+
+ public abstract ExchangeDeleteBody createExchangeDeleteBody(
+ final int ticket,
+ final AMQShortString exchange,
+ final boolean ifUnused,
+ final boolean nowait
+ );
+
+ public abstract ExchangeDeleteOkBody createExchangeDeleteOkBody(
+ );
+
+
+
+
+ public abstract QueueBindBody createQueueBindBody(
+ final int ticket,
+ final AMQShortString queue,
+ final AMQShortString exchange,
+ final AMQShortString routingKey,
+ final boolean nowait,
+ final FieldTable arguments
+ );
+
+ public abstract QueueBindOkBody createQueueBindOkBody(
+ );
+
+ public abstract QueueDeclareBody createQueueDeclareBody(
+ final int ticket,
+ final AMQShortString queue,
+ final boolean passive,
+ final boolean durable,
+ final boolean exclusive,
+ final boolean autoDelete,
+ final boolean nowait,
+ final FieldTable arguments
+ );
+
+ public abstract QueueDeclareOkBody createQueueDeclareOkBody(
+ final AMQShortString queue,
+ final long messageCount,
+ final long consumerCount
+ );
+
+ public abstract QueueDeleteBody createQueueDeleteBody(
+ final int ticket,
+ final AMQShortString queue,
+ final boolean ifUnused,
+ final boolean ifEmpty,
+ final boolean nowait
+ );
+
+ public abstract QueueDeleteOkBody createQueueDeleteOkBody(
+ final long messageCount
+ );
+
+ public abstract QueuePurgeBody createQueuePurgeBody(
+ final int ticket,
+ final AMQShortString queue,
+ final boolean nowait
+ );
+
+ public abstract QueuePurgeOkBody createQueuePurgeOkBody(
+ final long messageCount
+ );
+
+
+
+
+
+ public abstract TxCommitBody createTxCommitBody(
+ );
+
+ public abstract TxCommitOkBody createTxCommitOkBody(
+ );
+
+ public abstract TxRollbackBody createTxRollbackBody(
+ );
+
+ public abstract TxRollbackOkBody createTxRollbackOkBody(
+ );
+
+ public abstract TxSelectBody createTxSelectBody(
+ );
+
+ public abstract TxSelectOkBody createTxSelectOkBody(
+ );
+
+ public abstract ProtocolVersionMethodConverter getProtocolVersionMethodConverter();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/ProtocolVersion.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/ProtocolVersion.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/ProtocolVersion.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/ProtocolVersion.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,188 @@
+/*
+*
+* 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.
+*
+*/
+
+/*
+* This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+* Supported AMQP versions:
+* 0-9
+* 0-91
+* 8-0
+*/
+
+package org.apache.qpid.framing;
+
+import java.util.SortedSet;
+import java.util.Collections;
+import java.util.TreeSet;
+import java.util.Map;
+import java.util.HashMap;
+
+public class ProtocolVersion implements Comparable
+{
+ private final byte _majorVersion;
+ private final byte _minorVersion;
+ private final String _stringFormat;
+
+ public ProtocolVersion(byte majorVersion, byte minorVersion)
+ {
+ _majorVersion = majorVersion;
+ _minorVersion = minorVersion;
+ _stringFormat = _majorVersion+"-"+_minorVersion;
+ }
+
+ public byte getMajorVersion()
+ {
+ return _majorVersion;
+ }
+
+ public byte getMinorVersion()
+ {
+ return _minorVersion;
+ }
+
+ public byte getActualMinorVersion()
+ {
+ return _minorVersion > 90 ? (byte) (_minorVersion / 10) : _minorVersion;
+ }
+
+ public byte getRevisionVersion()
+ {
+ return _minorVersion > 90 ? (byte) (_minorVersion % 10) : (byte) 0;
+ }
+
+ public String toString()
+ {
+ return _stringFormat;
+ }
+
+ public int compareTo(Object o)
+ {
+ ProtocolVersion pv = (ProtocolVersion) o;
+
+ /*
+ * 0-8 has it's major and minor numbers the wrong way round (it's actually 8-0)...
+ * so we need to deal with that case specially
+ */
+
+ if((_majorVersion == (byte) 8) && (_minorVersion == (byte) 0))
+ {
+ ProtocolVersion fixedThis = new ProtocolVersion(_minorVersion, _majorVersion);
+ return fixedThis.compareTo(pv);
+ }
+
+ if((pv.getMajorVersion() == (byte) 8) && (pv.getMinorVersion() == (byte) 0))
+ {
+ ProtocolVersion fixedOther = new ProtocolVersion(pv.getMinorVersion(), pv.getMajorVersion());
+ return this.compareTo(fixedOther);
+ }
+
+ if(_majorVersion > pv.getMajorVersion())
+ {
+ return 1;
+ }
+ else if(_majorVersion < pv.getMajorVersion())
+ {
+ return -1;
+ }
+ else if(_minorVersion > pv.getMinorVersion())
+ {
+ return 1;
+ }
+ else if(getMinorVersion() < pv.getMinorVersion())
+ {
+ return -1;
+ }
+ else
+ {
+ return 0;
+ }
+
+ }
+
+ public boolean equals(Object o)
+ {
+ return o != null && (o == this || (compareTo(o) == 0));
+ }
+
+ public int hashCode()
+ {
+ return (0xFF & (int)_minorVersion) | ((0xFF & (int)_majorVersion) << 8);
+ }
+
+ public boolean isSupported()
+ {
+ return _supportedVersions.contains(this);
+ }
+
+ public static ProtocolVersion getLatestSupportedVersion()
+ {
+ return _supportedVersions.last();
+ }
+
+ private static final SortedSet<ProtocolVersion> _supportedVersions;
+ private static final Map<String, ProtocolVersion> _nameToVersionMap =
+ new HashMap<String, ProtocolVersion>();
+ private static final ProtocolVersion _defaultVersion;
+
+ public static final ProtocolVersion v0_10 = new ProtocolVersion((byte)0,(byte)10);
+
+ public static final ProtocolVersion v0_9 = new ProtocolVersion((byte)0,(byte)9);
+ public static final ProtocolVersion v0_91 = new ProtocolVersion((byte)0,(byte)91);
+ public static final ProtocolVersion v8_0 = new ProtocolVersion((byte)8,(byte)0);
+
+ static
+ {
+ SortedSet<ProtocolVersion> versions = new TreeSet<ProtocolVersion>();
+
+ versions.add(v0_10);
+ _nameToVersionMap.put("0-10", v0_10);
+ versions.add(v0_9);
+ _nameToVersionMap.put("0-9", v0_9);
+ versions.add(v0_91);
+ _nameToVersionMap.put("0-91", v0_91);
+ versions.add(v8_0);
+ _nameToVersionMap.put("8-0", v8_0);
+ _supportedVersions = Collections.unmodifiableSortedSet(versions);
+
+ ProtocolVersion systemDefinedVersion =
+ _nameToVersionMap.get(System.getProperty("org.apache.qpid.amqp_version"));
+
+ _defaultVersion = (systemDefinedVersion == null)
+ ? getLatestSupportedVersion()
+ : systemDefinedVersion;
+ }
+
+ public static SortedSet<ProtocolVersion> getSupportedProtocolVersions()
+ {
+ return _supportedVersions;
+ }
+
+ public static ProtocolVersion parse(String name)
+ {
+ return _nameToVersionMap.get(name);
+ }
+
+ public static ProtocolVersion defaultProtocolVersion()
+ {
+ return _defaultVersion;
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueBindBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueBindBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueBindBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueBindBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,46 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface QueueBindBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public FieldTable getArguments();
+
+ public AMQShortString getExchange();
+
+ public boolean getNowait();
+
+ public AMQShortString getQueue();
+
+ public AMQShortString getRoutingKey();
+
+ public int getTicket();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueBindOkBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueBindOkBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueBindOkBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueBindOkBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,34 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface QueueBindOkBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,50 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface QueueDeclareBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public FieldTable getArguments();
+
+ public boolean getAutoDelete();
+
+ public boolean getDurable();
+
+ public boolean getExclusive();
+
+ public boolean getNowait();
+
+ public boolean getPassive();
+
+ public AMQShortString getQueue();
+
+ public int getTicket();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,40 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface QueueDeclareOkBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public long getConsumerCount();
+
+ public long getMessageCount();
+
+ public AMQShortString getQueue();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,44 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface QueueDeleteBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public boolean getIfEmpty();
+
+ public boolean getIfUnused();
+
+ public boolean getNowait();
+
+ public AMQShortString getQueue();
+
+ public int getTicket();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteOkBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteOkBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteOkBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteOkBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,36 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface QueueDeleteOkBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public long getMessageCount();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,40 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface QueuePurgeBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public boolean getNowait();
+
+ public AMQShortString getQueue();
+
+ public int getTicket();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeOkBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeOkBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeOkBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeOkBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,36 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface QueuePurgeOkBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public long getMessageCount();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueUnbindBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueUnbindBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueUnbindBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueUnbindBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,44 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface QueueUnbindBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public FieldTable getArguments();
+
+ public AMQShortString getExchange();
+
+ public AMQShortString getQueue();
+
+ public AMQShortString getRoutingKey();
+
+ public int getTicket();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueUnbindOkBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueUnbindOkBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueUnbindOkBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/QueueUnbindOkBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,34 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface QueueUnbindOkBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/ServerMethodDispatcher.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/ServerMethodDispatcher.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/ServerMethodDispatcher.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/ServerMethodDispatcher.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,67 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+import org.apache.qpid.AMQException;
+
+public interface ServerMethodDispatcher
+{
+
+ public boolean dispatchBasicAck(BasicAckBody body, int channelId) throws AMQException;
+ public boolean dispatchBasicCancel(BasicCancelBody body, int channelId) throws AMQException;
+ public boolean dispatchBasicConsume(BasicConsumeBody body, int channelId) throws AMQException;
+ public boolean dispatchBasicGet(BasicGetBody body, int channelId) throws AMQException;
+ public boolean dispatchBasicPublish(BasicPublishBody body, int channelId) throws AMQException;
+ public boolean dispatchBasicQos(BasicQosBody body, int channelId) throws AMQException;
+ public boolean dispatchBasicRecover(BasicRecoverBody body, int channelId) throws AMQException;
+ public boolean dispatchBasicReject(BasicRejectBody body, int channelId) throws AMQException;
+ public boolean dispatchChannelClose(ChannelCloseBody body, int channelId) throws AMQException;
+ public boolean dispatchChannelCloseOk(ChannelCloseOkBody body, int channelId) throws AMQException;
+ public boolean dispatchChannelFlow(ChannelFlowBody body, int channelId) throws AMQException;
+ public boolean dispatchChannelFlowOk(ChannelFlowOkBody body, int channelId) throws AMQException;
+ public boolean dispatchChannelOpen(ChannelOpenBody body, int channelId) throws AMQException;
+ public boolean dispatchConnectionClose(ConnectionCloseBody body, int channelId) throws AMQException;
+ public boolean dispatchConnectionCloseOk(ConnectionCloseOkBody body, int channelId) throws AMQException;
+ public boolean dispatchConnectionOpen(ConnectionOpenBody body, int channelId) throws AMQException;
+ public boolean dispatchConnectionSecureOk(ConnectionSecureOkBody body, int channelId) throws AMQException;
+ public boolean dispatchConnectionStartOk(ConnectionStartOkBody body, int channelId) throws AMQException;
+ public boolean dispatchConnectionTuneOk(ConnectionTuneOkBody body, int channelId) throws AMQException;
+ public boolean dispatchExchangeBound(ExchangeBoundBody body, int channelId) throws AMQException;
+ public boolean dispatchExchangeDeclare(ExchangeDeclareBody body, int channelId) throws AMQException;
+ public boolean dispatchExchangeDelete(ExchangeDeleteBody body, int channelId) throws AMQException;
+ public boolean dispatchQueueBind(QueueBindBody body, int channelId) throws AMQException;
+ public boolean dispatchQueueDeclare(QueueDeclareBody body, int channelId) throws AMQException;
+ public boolean dispatchQueueDelete(QueueDeleteBody body, int channelId) throws AMQException;
+ public boolean dispatchQueuePurge(QueuePurgeBody body, int channelId) throws AMQException;
+ public boolean dispatchTxCommit(TxCommitBody body, int channelId) throws AMQException;
+ public boolean dispatchTxRollback(TxRollbackBody body, int channelId) throws AMQException;
+ public boolean dispatchTxSelect(TxSelectBody body, int channelId) throws AMQException;
+
+}
\ No newline at end of file
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamCancelBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamCancelBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamCancelBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamCancelBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,38 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface StreamCancelBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public AMQShortString getConsumerTag();
+
+ public boolean getNowait();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamCancelOkBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamCancelOkBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamCancelOkBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamCancelOkBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,36 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface StreamCancelOkBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public AMQShortString getConsumerTag();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamConsumeBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamConsumeBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamConsumeBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamConsumeBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,47 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface StreamConsumeBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public AMQShortString getConsumerTag();
+
+ public boolean getExclusive();
+
+
+ public boolean getNoLocal();
+
+ public boolean getNowait();
+
+ public AMQShortString getQueue();
+
+ public int getTicket();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamConsumeOkBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamConsumeOkBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamConsumeOkBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamConsumeOkBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,36 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface StreamConsumeOkBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public AMQShortString getConsumerTag();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamDeliverBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamDeliverBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamDeliverBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamDeliverBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,42 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface StreamDeliverBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public AMQShortString getConsumerTag();
+
+ public long getDeliveryTag();
+
+ public AMQShortString getExchange();
+
+ public AMQShortString getQueue();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamPublishBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamPublishBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamPublishBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamPublishBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,44 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface StreamPublishBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public AMQShortString getExchange();
+
+ public boolean getImmediate();
+
+ public boolean getMandatory();
+
+ public AMQShortString getRoutingKey();
+
+ public int getTicket();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamQosBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamQosBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamQosBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamQosBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,42 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface StreamQosBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public long getConsumeRate();
+
+ public boolean getGlobal();
+
+ public int getPrefetchCount();
+
+ public long getPrefetchSize();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamQosOkBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamQosOkBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamQosOkBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamQosOkBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,34 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface StreamQosOkBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamReturnBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamReturnBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamReturnBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/StreamReturnBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,42 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface StreamReturnBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public AMQShortString getExchange();
+
+ public int getReplyCode();
+
+ public AMQShortString getReplyText();
+
+ public AMQShortString getRoutingKey();
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/TestContentBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/TestContentBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/TestContentBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/TestContentBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,34 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface TestContentBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/TestContentOkBody.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/TestContentOkBody.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/TestContentOkBody.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/TestContentOkBody.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,36 @@
+/*
+ *
+ * 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.
+ *
+ */
+
+/*
+ * This file is auto-generated by Qpid Gentools v.0.1 - do not modify.
+ * Supported AMQP version:
+ * 0-9
+ * 0-91
+ * 8-0
+ */
+
+package org.apache.qpid.framing;
+
+public interface TestContentOkBody extends EncodableAMQDataBlock, AMQMethodBody
+{
+
+ public long getContentChecksum();
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org