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 [23/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/apa...
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxCommitBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxCommitBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxCommitBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxCommitBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,100 @@
+/*
+ *
+ * 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:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class TxCommitBodyImpl extends AMQMethodBody_8_0 implements TxCommitBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new TxCommitBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 90;
+ public static final int METHOD_ID = 20;
+
+ // Fields declared in specification
+
+ // Constructor
+ public TxCommitBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ }
+
+ public TxCommitBodyImpl(
+ )
+ {
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+
+ protected int getBodySize()
+ {
+ int size = 0;
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchTxCommit(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[TxCommitBodyImpl: ");
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxCommitOkBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxCommitOkBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxCommitOkBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxCommitOkBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,100 @@
+/*
+ *
+ * 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:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class TxCommitOkBodyImpl extends AMQMethodBody_8_0 implements TxCommitOkBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new TxCommitOkBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 90;
+ public static final int METHOD_ID = 21;
+
+ // Fields declared in specification
+
+ // Constructor
+ public TxCommitOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ }
+
+ public TxCommitOkBodyImpl(
+ )
+ {
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+
+ protected int getBodySize()
+ {
+ int size = 0;
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchTxCommitOk(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[TxCommitOkBodyImpl: ");
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxRollbackBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxRollbackBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxRollbackBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxRollbackBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,100 @@
+/*
+ *
+ * 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:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class TxRollbackBodyImpl extends AMQMethodBody_8_0 implements TxRollbackBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new TxRollbackBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 90;
+ public static final int METHOD_ID = 30;
+
+ // Fields declared in specification
+
+ // Constructor
+ public TxRollbackBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ }
+
+ public TxRollbackBodyImpl(
+ )
+ {
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+
+ protected int getBodySize()
+ {
+ int size = 0;
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchTxRollback(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[TxRollbackBodyImpl: ");
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxRollbackOkBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxRollbackOkBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxRollbackOkBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxRollbackOkBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,100 @@
+/*
+ *
+ * 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:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class TxRollbackOkBodyImpl extends AMQMethodBody_8_0 implements TxRollbackOkBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new TxRollbackOkBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 90;
+ public static final int METHOD_ID = 31;
+
+ // Fields declared in specification
+
+ // Constructor
+ public TxRollbackOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ }
+
+ public TxRollbackOkBodyImpl(
+ )
+ {
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+
+ protected int getBodySize()
+ {
+ int size = 0;
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchTxRollbackOk(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[TxRollbackOkBodyImpl: ");
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxSelectBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxSelectBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxSelectBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxSelectBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,100 @@
+/*
+ *
+ * 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:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class TxSelectBodyImpl extends AMQMethodBody_8_0 implements TxSelectBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new TxSelectBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 90;
+ public static final int METHOD_ID = 10;
+
+ // Fields declared in specification
+
+ // Constructor
+ public TxSelectBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ }
+
+ public TxSelectBodyImpl(
+ )
+ {
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+
+ protected int getBodySize()
+ {
+ int size = 0;
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchTxSelect(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[TxSelectBodyImpl: ");
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxSelectOkBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxSelectOkBodyImpl.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxSelectOkBodyImpl.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxSelectOkBodyImpl.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,100 @@
+/*
+ *
+ * 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:
+ * 8-0
+ */
+
+package org.apache.qpid.framing.amqp_8_0;
+
+import org.apache.qpid.codec.MarkableDataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.qpid.framing.*;
+import org.apache.qpid.AMQException;
+
+public class TxSelectOkBodyImpl extends AMQMethodBody_8_0 implements TxSelectOkBody
+{
+ private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory()
+ {
+ public AMQMethodBody newInstance(MarkableDataInput in, long size) throws AMQFrameDecodingException, IOException
+ {
+ return new TxSelectOkBodyImpl(in);
+ }
+ };
+
+ public static AMQMethodBodyInstanceFactory getFactory()
+ {
+ return FACTORY_INSTANCE;
+ }
+
+ public static final int CLASS_ID = 90;
+ public static final int METHOD_ID = 11;
+
+ // Fields declared in specification
+
+ // Constructor
+ public TxSelectOkBodyImpl(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException
+ {
+ }
+
+ public TxSelectOkBodyImpl(
+ )
+ {
+ }
+
+ public int getClazz()
+ {
+ return CLASS_ID;
+ }
+
+ public int getMethod()
+ {
+ return METHOD_ID;
+ }
+
+
+ protected int getBodySize()
+ {
+ int size = 0;
+ return size;
+ }
+
+ public void writeMethodPayload(DataOutput buffer) throws IOException
+ {
+ }
+
+ public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException
+ {
+ return ((MethodDispatcher_8_0)dispatcher).dispatchTxSelectOk(this, channelId);
+ }
+
+ public String toString()
+ {
+ StringBuilder buf = new StringBuilder("[TxSelectOkBodyImpl: ");
+ buf.append("]");
+ return buf.toString();
+ }
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/Acquired.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/Acquired.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/Acquired.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/Acquired.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,141 @@
+package org.apache.qpid.transport;
+/*
+ *
+ * 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.
+ *
+ */
+
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import org.apache.qpid.transport.codec.Decoder;
+import org.apache.qpid.transport.codec.Encoder;
+
+
+
+public final class Acquired extends Struct {
+
+ public static final int TYPE = 1028;
+
+ public final int getStructType() {
+ return TYPE;
+ }
+
+ public final int getSizeWidth() {
+ return 4;
+ }
+
+ public final int getPackWidth() {
+ return 2;
+ }
+
+ public final boolean hasPayload() {
+ return false;
+ }
+
+ public final byte getEncodedTrack() {
+ return -1;
+ }
+
+ public final boolean isConnectionControl()
+ {
+ return false;
+ }
+
+ private short packing_flags = 0;
+ private RangeSet transfers;
+
+
+ public Acquired() {}
+
+
+ public Acquired(RangeSet transfers) {
+ if(transfers != null) {
+ setTransfers(transfers);
+ }
+
+ }
+
+
+
+
+ public final boolean hasTransfers() {
+ return (packing_flags & 256) != 0;
+ }
+
+ public final Acquired clearTransfers() {
+ packing_flags &= ~256;
+ this.transfers = null;
+ setDirty(true);
+ return this;
+ }
+
+ public final RangeSet getTransfers() {
+ return transfers;
+ }
+
+ public final Acquired setTransfers(RangeSet value) {
+ this.transfers = value;
+ packing_flags |= 256;
+ setDirty(true);
+ return this;
+ }
+
+ public final Acquired transfers(RangeSet value) {
+ return setTransfers(value);
+ }
+
+
+
+
+ public void write(Encoder enc)
+ {
+ enc.writeUint16(packing_flags);
+ if ((packing_flags & 256) != 0)
+ {
+ enc.writeSequenceSet(this.transfers);
+ }
+
+ }
+
+ public void read(Decoder dec)
+ {
+ packing_flags = (short) dec.readUint16();
+ if ((packing_flags & 256) != 0)
+ {
+ this.transfers = dec.readSequenceSet();
+ }
+
+ }
+
+ public Map<String,Object> getFields()
+ {
+ Map<String,Object> result = new LinkedHashMap<String,Object>();
+
+ if ((packing_flags & 256) != 0)
+ {
+ result.put("transfers", getTransfers());
+ }
+
+
+ return result;
+ }
+
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionClose.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionClose.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionClose.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionClose.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,196 @@
+package org.apache.qpid.transport;
+/*
+ *
+ * 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.
+ *
+ */
+
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import org.apache.qpid.transport.codec.Decoder;
+import org.apache.qpid.transport.codec.Encoder;
+
+import org.apache.qpid.transport.network.Frame;
+
+
+public final class ConnectionClose extends Method {
+
+ public static final int TYPE = 267;
+
+ public final int getStructType() {
+ return TYPE;
+ }
+
+ public final int getSizeWidth() {
+ return 0;
+ }
+
+ public final int getPackWidth() {
+ return 2;
+ }
+
+ public final boolean hasPayload() {
+ return false;
+ }
+
+ public final byte getEncodedTrack() {
+ return Frame.L1;
+ }
+
+ public final boolean isConnectionControl()
+ {
+ return true;
+ }
+
+ private short packing_flags = 0;
+ private ConnectionCloseCode replyCode;
+ private String replyText;
+
+
+ public ConnectionClose() {}
+
+
+ public ConnectionClose(ConnectionCloseCode replyCode, String replyText, Option ... _options) {
+ if(replyCode != null) {
+ setReplyCode(replyCode);
+ }
+ if(replyText != null) {
+ setReplyText(replyText);
+ }
+
+ for (int i=0; i < _options.length; i++) {
+ switch (_options[i]) {
+ case SYNC: this.setSync(true); break;
+ case BATCH: this.setBatch(true); break;
+ case UNRELIABLE: this.setUnreliable(true); break;
+ case NONE: break;
+ default: throw new IllegalArgumentException("invalid option: " + _options[i]);
+ }
+ }
+
+ }
+
+ public <C> void dispatch(C context, MethodDelegate<C> delegate) {
+ delegate.connectionClose(context, this);
+ }
+
+
+ public final boolean hasReplyCode() {
+ return (packing_flags & 256) != 0;
+ }
+
+ public final ConnectionClose clearReplyCode() {
+ packing_flags &= ~256;
+ this.replyCode = null;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionCloseCode getReplyCode() {
+ return replyCode;
+ }
+
+ public final ConnectionClose setReplyCode(ConnectionCloseCode value) {
+ this.replyCode = value;
+ packing_flags |= 256;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionClose replyCode(ConnectionCloseCode value) {
+ return setReplyCode(value);
+ }
+
+ public final boolean hasReplyText() {
+ return (packing_flags & 512) != 0;
+ }
+
+ public final ConnectionClose clearReplyText() {
+ packing_flags &= ~512;
+ this.replyText = null;
+ setDirty(true);
+ return this;
+ }
+
+ public final String getReplyText() {
+ return replyText;
+ }
+
+ public final ConnectionClose setReplyText(String value) {
+ this.replyText = value;
+ packing_flags |= 512;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionClose replyText(String value) {
+ return setReplyText(value);
+ }
+
+
+
+
+ public void write(Encoder enc)
+ {
+ enc.writeUint16(packing_flags);
+ if ((packing_flags & 256) != 0)
+ {
+ enc.writeUint16(this.replyCode.getValue());
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ enc.writeStr8(this.replyText);
+ }
+
+ }
+
+ public void read(Decoder dec)
+ {
+ packing_flags = (short) dec.readUint16();
+ if ((packing_flags & 256) != 0)
+ {
+ this.replyCode = ConnectionCloseCode.get(dec.readUint16());
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ this.replyText = dec.readStr8();
+ }
+
+ }
+
+ public Map<String,Object> getFields()
+ {
+ Map<String,Object> result = new LinkedHashMap<String,Object>();
+
+ if ((packing_flags & 256) != 0)
+ {
+ result.put("replyCode", getReplyCode());
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ result.put("replyText", getReplyText());
+ }
+
+
+ return result;
+ }
+
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionCloseCode.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionCloseCode.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionCloseCode.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionCloseCode.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,54 @@
+package org.apache.qpid.transport;
+/*
+ *
+ * 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.
+ *
+ */
+
+
+public enum ConnectionCloseCode {
+
+ NORMAL((int) 200),
+ CONNECTION_FORCED((int) 320),
+ INVALID_PATH((int) 402),
+ FRAMING_ERROR((int) 501);
+
+ private final int value;
+
+ ConnectionCloseCode(int value)
+ {
+ this.value = value;
+ }
+
+ public int getValue()
+ {
+ return value;
+ }
+
+ public static ConnectionCloseCode get(int value)
+ {
+ switch (value)
+ {
+ case (int) 200: return NORMAL;
+ case (int) 320: return CONNECTION_FORCED;
+ case (int) 402: return INVALID_PATH;
+ case (int) 501: return FRAMING_ERROR;
+ default: throw new IllegalArgumentException("no such value: " + value);
+ }
+ }
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionCloseOk.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionCloseOk.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionCloseOk.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionCloseOk.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,111 @@
+package org.apache.qpid.transport;
+/*
+ *
+ * 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.
+ *
+ */
+
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import org.apache.qpid.transport.codec.Decoder;
+import org.apache.qpid.transport.codec.Encoder;
+
+import org.apache.qpid.transport.network.Frame;
+
+
+public final class ConnectionCloseOk extends Method {
+
+ public static final int TYPE = 268;
+
+ public final int getStructType() {
+ return TYPE;
+ }
+
+ public final int getSizeWidth() {
+ return 0;
+ }
+
+ public final int getPackWidth() {
+ return 2;
+ }
+
+ public final boolean hasPayload() {
+ return false;
+ }
+
+ public final byte getEncodedTrack() {
+ return Frame.L1;
+ }
+
+ public final boolean isConnectionControl()
+ {
+ return true;
+ }
+
+ private short packing_flags = 0;
+
+
+
+
+ public ConnectionCloseOk(Option ... _options) {
+
+ for (int i=0; i < _options.length; i++) {
+ switch (_options[i]) {
+ case SYNC: this.setSync(true); break;
+ case BATCH: this.setBatch(true); break;
+ case UNRELIABLE: this.setUnreliable(true); break;
+ case NONE: break;
+ default: throw new IllegalArgumentException("invalid option: " + _options[i]);
+ }
+ }
+
+ }
+
+ public <C> void dispatch(C context, MethodDelegate<C> delegate) {
+ delegate.connectionCloseOk(context, this);
+ }
+
+
+
+
+
+ public void write(Encoder enc)
+ {
+ enc.writeUint16(packing_flags);
+
+ }
+
+ public void read(Decoder dec)
+ {
+ packing_flags = (short) dec.readUint16();
+
+ }
+
+ public Map<String,Object> getFields()
+ {
+ Map<String,Object> result = new LinkedHashMap<String,Object>();
+
+
+
+ return result;
+ }
+
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionHeartbeat.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionHeartbeat.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionHeartbeat.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionHeartbeat.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,111 @@
+package org.apache.qpid.transport;
+/*
+ *
+ * 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.
+ *
+ */
+
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import org.apache.qpid.transport.codec.Decoder;
+import org.apache.qpid.transport.codec.Encoder;
+
+import org.apache.qpid.transport.network.Frame;
+
+
+public final class ConnectionHeartbeat extends Method {
+
+ public static final int TYPE = 266;
+
+ public final int getStructType() {
+ return TYPE;
+ }
+
+ public final int getSizeWidth() {
+ return 0;
+ }
+
+ public final int getPackWidth() {
+ return 2;
+ }
+
+ public final boolean hasPayload() {
+ return false;
+ }
+
+ public final byte getEncodedTrack() {
+ return Frame.L1;
+ }
+
+ public final boolean isConnectionControl()
+ {
+ return true;
+ }
+
+ private short packing_flags = 0;
+
+
+
+
+ public ConnectionHeartbeat(Option ... _options) {
+
+ for (int i=0; i < _options.length; i++) {
+ switch (_options[i]) {
+ case SYNC: this.setSync(true); break;
+ case BATCH: this.setBatch(true); break;
+ case UNRELIABLE: this.setUnreliable(true); break;
+ case NONE: break;
+ default: throw new IllegalArgumentException("invalid option: " + _options[i]);
+ }
+ }
+
+ }
+
+ public <C> void dispatch(C context, MethodDelegate<C> delegate) {
+ delegate.connectionHeartbeat(context, this);
+ }
+
+
+
+
+
+ public void write(Encoder enc)
+ {
+ enc.writeUint16(packing_flags);
+
+ }
+
+ public void read(Decoder dec)
+ {
+ packing_flags = (short) dec.readUint16();
+
+ }
+
+ public Map<String,Object> getFields()
+ {
+ Map<String,Object> result = new LinkedHashMap<String,Object>();
+
+
+
+ return result;
+ }
+
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionInvoker.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionInvoker.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionInvoker.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionInvoker.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,78 @@
+package org.apache.qpid.transport;
+/*
+ *
+ * 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.
+ *
+ */
+
+
+import java.util.Map;
+
+public abstract class ConnectionInvoker {
+
+ final void connectionStart(Map<String,Object> serverProperties, java.util.List<Object> mechanisms, java.util.List<Object> locales, Option ... _options) {
+ invoke(new ConnectionStart(serverProperties, mechanisms, locales, _options));
+ }
+
+ final void connectionStartOk(Map<String,Object> clientProperties, String mechanism, byte[] response, String locale, Option ... _options) {
+ invoke(new ConnectionStartOk(clientProperties, mechanism, response, locale, _options));
+ }
+
+ final void connectionSecure(byte[] challenge, Option ... _options) {
+ invoke(new ConnectionSecure(challenge, _options));
+ }
+
+ final void connectionSecureOk(byte[] response, Option ... _options) {
+ invoke(new ConnectionSecureOk(response, _options));
+ }
+
+ final void connectionTune(int channelMax, int maxFrameSize, int heartbeatMin, int heartbeatMax, Option ... _options) {
+ invoke(new ConnectionTune(channelMax, maxFrameSize, heartbeatMin, heartbeatMax, _options));
+ }
+
+ final void connectionTuneOk(int channelMax, int maxFrameSize, int heartbeat, Option ... _options) {
+ invoke(new ConnectionTuneOk(channelMax, maxFrameSize, heartbeat, _options));
+ }
+
+ final void connectionOpen(String virtualHost, java.util.List<Object> capabilities, Option ... _options) {
+ invoke(new ConnectionOpen(virtualHost, capabilities, _options));
+ }
+
+ final void connectionOpenOk(java.util.List<Object> knownHosts, Option ... _options) {
+ invoke(new ConnectionOpenOk(knownHosts, _options));
+ }
+
+ final void connectionRedirect(String host, java.util.List<Object> knownHosts, Option ... _options) {
+ invoke(new ConnectionRedirect(host, knownHosts, _options));
+ }
+
+ final void connectionHeartbeat(Option ... _options) {
+ invoke(new ConnectionHeartbeat(_options));
+ }
+
+ final void connectionClose(ConnectionCloseCode replyCode, String replyText, Option ... _options) {
+ invoke(new ConnectionClose(replyCode, replyText, _options));
+ }
+
+ final void connectionCloseOk(Option ... _options) {
+ invoke(new ConnectionCloseOk(_options));
+ }
+
+ protected abstract void invoke(Method method);
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionOpen.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionOpen.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionOpen.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionOpen.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,235 @@
+package org.apache.qpid.transport;
+/*
+ *
+ * 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.
+ *
+ */
+
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import org.apache.qpid.transport.codec.Decoder;
+import org.apache.qpid.transport.codec.Encoder;
+
+import org.apache.qpid.transport.network.Frame;
+
+
+public final class ConnectionOpen extends Method {
+
+ public static final int TYPE = 263;
+
+ public final int getStructType() {
+ return TYPE;
+ }
+
+ public final int getSizeWidth() {
+ return 0;
+ }
+
+ public final int getPackWidth() {
+ return 2;
+ }
+
+ public final boolean hasPayload() {
+ return false;
+ }
+
+ public final byte getEncodedTrack() {
+ return Frame.L1;
+ }
+
+ public final boolean isConnectionControl()
+ {
+ return true;
+ }
+
+ private short packing_flags = 0;
+ private String virtualHost;
+ private java.util.List<Object> capabilities;
+
+
+ public ConnectionOpen() {}
+
+
+ public ConnectionOpen(String virtualHost, java.util.List<Object> capabilities, Option ... _options) {
+ if(virtualHost != null) {
+ setVirtualHost(virtualHost);
+ }
+ if(capabilities != null) {
+ setCapabilities(capabilities);
+ }
+
+ for (int i=0; i < _options.length; i++) {
+ switch (_options[i]) {
+ case INSIST: packing_flags |= 1024; break;
+ case SYNC: this.setSync(true); break;
+ case BATCH: this.setBatch(true); break;
+ case UNRELIABLE: this.setUnreliable(true); break;
+ case NONE: break;
+ default: throw new IllegalArgumentException("invalid option: " + _options[i]);
+ }
+ }
+
+ }
+
+ public <C> void dispatch(C context, MethodDelegate<C> delegate) {
+ delegate.connectionOpen(context, this);
+ }
+
+
+ public final boolean hasVirtualHost() {
+ return (packing_flags & 256) != 0;
+ }
+
+ public final ConnectionOpen clearVirtualHost() {
+ packing_flags &= ~256;
+ this.virtualHost = null;
+ setDirty(true);
+ return this;
+ }
+
+ public final String getVirtualHost() {
+ return virtualHost;
+ }
+
+ public final ConnectionOpen setVirtualHost(String value) {
+ this.virtualHost = value;
+ packing_flags |= 256;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionOpen virtualHost(String value) {
+ return setVirtualHost(value);
+ }
+
+ public final boolean hasCapabilities() {
+ return (packing_flags & 512) != 0;
+ }
+
+ public final ConnectionOpen clearCapabilities() {
+ packing_flags &= ~512;
+ this.capabilities = null;
+ setDirty(true);
+ return this;
+ }
+
+ public final java.util.List<Object> getCapabilities() {
+ return capabilities;
+ }
+
+ public final ConnectionOpen setCapabilities(java.util.List<Object> value) {
+ this.capabilities = value;
+ packing_flags |= 512;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionOpen capabilities(java.util.List<Object> value) {
+ return setCapabilities(value);
+ }
+
+ public final boolean hasInsist() {
+ return (packing_flags & 1024) != 0;
+ }
+
+ public final ConnectionOpen clearInsist() {
+ packing_flags &= ~1024;
+
+ setDirty(true);
+ return this;
+ }
+
+ public final boolean getInsist() {
+ return hasInsist();
+ }
+
+ public final ConnectionOpen setInsist(boolean value) {
+
+ if (value)
+ {
+ packing_flags |= 1024;
+ }
+ else
+ {
+ packing_flags &= ~1024;
+ }
+
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionOpen insist(boolean value) {
+ return setInsist(value);
+ }
+
+
+
+
+ public void write(Encoder enc)
+ {
+ enc.writeUint16(packing_flags);
+ if ((packing_flags & 256) != 0)
+ {
+ enc.writeStr8(this.virtualHost);
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ enc.writeArray(this.capabilities);
+ }
+
+ }
+
+ public void read(Decoder dec)
+ {
+ packing_flags = (short) dec.readUint16();
+ if ((packing_flags & 256) != 0)
+ {
+ this.virtualHost = dec.readStr8();
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ this.capabilities = dec.readArray();
+ }
+
+ }
+
+ public Map<String,Object> getFields()
+ {
+ Map<String,Object> result = new LinkedHashMap<String,Object>();
+
+ if ((packing_flags & 256) != 0)
+ {
+ result.put("virtualHost", getVirtualHost());
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ result.put("capabilities", getCapabilities());
+ }
+ if ((packing_flags & 1024) != 0)
+ {
+ result.put("insist", getInsist());
+ }
+
+
+ return result;
+ }
+
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionOpenOk.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionOpenOk.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionOpenOk.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionOpenOk.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,154 @@
+package org.apache.qpid.transport;
+/*
+ *
+ * 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.
+ *
+ */
+
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import org.apache.qpid.transport.codec.Decoder;
+import org.apache.qpid.transport.codec.Encoder;
+
+import org.apache.qpid.transport.network.Frame;
+
+
+public final class ConnectionOpenOk extends Method {
+
+ public static final int TYPE = 264;
+
+ public final int getStructType() {
+ return TYPE;
+ }
+
+ public final int getSizeWidth() {
+ return 0;
+ }
+
+ public final int getPackWidth() {
+ return 2;
+ }
+
+ public final boolean hasPayload() {
+ return false;
+ }
+
+ public final byte getEncodedTrack() {
+ return Frame.L1;
+ }
+
+ public final boolean isConnectionControl()
+ {
+ return true;
+ }
+
+ private short packing_flags = 0;
+ private java.util.List<Object> knownHosts;
+
+
+ public ConnectionOpenOk() {}
+
+
+ public ConnectionOpenOk(java.util.List<Object> knownHosts, Option ... _options) {
+ if(knownHosts != null) {
+ setKnownHosts(knownHosts);
+ }
+
+ for (int i=0; i < _options.length; i++) {
+ switch (_options[i]) {
+ case SYNC: this.setSync(true); break;
+ case BATCH: this.setBatch(true); break;
+ case UNRELIABLE: this.setUnreliable(true); break;
+ case NONE: break;
+ default: throw new IllegalArgumentException("invalid option: " + _options[i]);
+ }
+ }
+
+ }
+
+ public <C> void dispatch(C context, MethodDelegate<C> delegate) {
+ delegate.connectionOpenOk(context, this);
+ }
+
+
+ public final boolean hasKnownHosts() {
+ return (packing_flags & 256) != 0;
+ }
+
+ public final ConnectionOpenOk clearKnownHosts() {
+ packing_flags &= ~256;
+ this.knownHosts = null;
+ setDirty(true);
+ return this;
+ }
+
+ public final java.util.List<Object> getKnownHosts() {
+ return knownHosts;
+ }
+
+ public final ConnectionOpenOk setKnownHosts(java.util.List<Object> value) {
+ this.knownHosts = value;
+ packing_flags |= 256;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionOpenOk knownHosts(java.util.List<Object> value) {
+ return setKnownHosts(value);
+ }
+
+
+
+
+ public void write(Encoder enc)
+ {
+ enc.writeUint16(packing_flags);
+ if ((packing_flags & 256) != 0)
+ {
+ enc.writeArray(this.knownHosts);
+ }
+
+ }
+
+ public void read(Decoder dec)
+ {
+ packing_flags = (short) dec.readUint16();
+ if ((packing_flags & 256) != 0)
+ {
+ this.knownHosts = dec.readArray();
+ }
+
+ }
+
+ public Map<String,Object> getFields()
+ {
+ Map<String,Object> result = new LinkedHashMap<String,Object>();
+
+ if ((packing_flags & 256) != 0)
+ {
+ result.put("knownHosts", getKnownHosts());
+ }
+
+
+ return result;
+ }
+
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionRedirect.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionRedirect.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionRedirect.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionRedirect.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,196 @@
+package org.apache.qpid.transport;
+/*
+ *
+ * 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.
+ *
+ */
+
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import org.apache.qpid.transport.codec.Decoder;
+import org.apache.qpid.transport.codec.Encoder;
+
+import org.apache.qpid.transport.network.Frame;
+
+
+public final class ConnectionRedirect extends Method {
+
+ public static final int TYPE = 265;
+
+ public final int getStructType() {
+ return TYPE;
+ }
+
+ public final int getSizeWidth() {
+ return 0;
+ }
+
+ public final int getPackWidth() {
+ return 2;
+ }
+
+ public final boolean hasPayload() {
+ return false;
+ }
+
+ public final byte getEncodedTrack() {
+ return Frame.L1;
+ }
+
+ public final boolean isConnectionControl()
+ {
+ return true;
+ }
+
+ private short packing_flags = 0;
+ private String host;
+ private java.util.List<Object> knownHosts;
+
+
+ public ConnectionRedirect() {}
+
+
+ public ConnectionRedirect(String host, java.util.List<Object> knownHosts, Option ... _options) {
+ if(host != null) {
+ setHost(host);
+ }
+ if(knownHosts != null) {
+ setKnownHosts(knownHosts);
+ }
+
+ for (int i=0; i < _options.length; i++) {
+ switch (_options[i]) {
+ case SYNC: this.setSync(true); break;
+ case BATCH: this.setBatch(true); break;
+ case UNRELIABLE: this.setUnreliable(true); break;
+ case NONE: break;
+ default: throw new IllegalArgumentException("invalid option: " + _options[i]);
+ }
+ }
+
+ }
+
+ public <C> void dispatch(C context, MethodDelegate<C> delegate) {
+ delegate.connectionRedirect(context, this);
+ }
+
+
+ public final boolean hasHost() {
+ return (packing_flags & 256) != 0;
+ }
+
+ public final ConnectionRedirect clearHost() {
+ packing_flags &= ~256;
+ this.host = null;
+ setDirty(true);
+ return this;
+ }
+
+ public final String getHost() {
+ return host;
+ }
+
+ public final ConnectionRedirect setHost(String value) {
+ this.host = value;
+ packing_flags |= 256;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionRedirect host(String value) {
+ return setHost(value);
+ }
+
+ public final boolean hasKnownHosts() {
+ return (packing_flags & 512) != 0;
+ }
+
+ public final ConnectionRedirect clearKnownHosts() {
+ packing_flags &= ~512;
+ this.knownHosts = null;
+ setDirty(true);
+ return this;
+ }
+
+ public final java.util.List<Object> getKnownHosts() {
+ return knownHosts;
+ }
+
+ public final ConnectionRedirect setKnownHosts(java.util.List<Object> value) {
+ this.knownHosts = value;
+ packing_flags |= 512;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionRedirect knownHosts(java.util.List<Object> value) {
+ return setKnownHosts(value);
+ }
+
+
+
+
+ public void write(Encoder enc)
+ {
+ enc.writeUint16(packing_flags);
+ if ((packing_flags & 256) != 0)
+ {
+ enc.writeStr16(this.host);
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ enc.writeArray(this.knownHosts);
+ }
+
+ }
+
+ public void read(Decoder dec)
+ {
+ packing_flags = (short) dec.readUint16();
+ if ((packing_flags & 256) != 0)
+ {
+ this.host = dec.readStr16();
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ this.knownHosts = dec.readArray();
+ }
+
+ }
+
+ public Map<String,Object> getFields()
+ {
+ Map<String,Object> result = new LinkedHashMap<String,Object>();
+
+ if ((packing_flags & 256) != 0)
+ {
+ result.put("host", getHost());
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ result.put("knownHosts", getKnownHosts());
+ }
+
+
+ return result;
+ }
+
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionSecure.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionSecure.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionSecure.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionSecure.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,154 @@
+package org.apache.qpid.transport;
+/*
+ *
+ * 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.
+ *
+ */
+
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import org.apache.qpid.transport.codec.Decoder;
+import org.apache.qpid.transport.codec.Encoder;
+
+import org.apache.qpid.transport.network.Frame;
+
+
+public final class ConnectionSecure extends Method {
+
+ public static final int TYPE = 259;
+
+ public final int getStructType() {
+ return TYPE;
+ }
+
+ public final int getSizeWidth() {
+ return 0;
+ }
+
+ public final int getPackWidth() {
+ return 2;
+ }
+
+ public final boolean hasPayload() {
+ return false;
+ }
+
+ public final byte getEncodedTrack() {
+ return Frame.L1;
+ }
+
+ public final boolean isConnectionControl()
+ {
+ return true;
+ }
+
+ private short packing_flags = 0;
+ private byte[] challenge;
+
+
+ public ConnectionSecure() {}
+
+
+ public ConnectionSecure(byte[] challenge, Option ... _options) {
+ if(challenge != null) {
+ setChallenge(challenge);
+ }
+
+ for (int i=0; i < _options.length; i++) {
+ switch (_options[i]) {
+ case SYNC: this.setSync(true); break;
+ case BATCH: this.setBatch(true); break;
+ case UNRELIABLE: this.setUnreliable(true); break;
+ case NONE: break;
+ default: throw new IllegalArgumentException("invalid option: " + _options[i]);
+ }
+ }
+
+ }
+
+ public <C> void dispatch(C context, MethodDelegate<C> delegate) {
+ delegate.connectionSecure(context, this);
+ }
+
+
+ public final boolean hasChallenge() {
+ return (packing_flags & 256) != 0;
+ }
+
+ public final ConnectionSecure clearChallenge() {
+ packing_flags &= ~256;
+ this.challenge = null;
+ setDirty(true);
+ return this;
+ }
+
+ public final byte[] getChallenge() {
+ return challenge;
+ }
+
+ public final ConnectionSecure setChallenge(byte[] value) {
+ this.challenge = value;
+ packing_flags |= 256;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionSecure challenge(byte[] value) {
+ return setChallenge(value);
+ }
+
+
+
+
+ public void write(Encoder enc)
+ {
+ enc.writeUint16(packing_flags);
+ if ((packing_flags & 256) != 0)
+ {
+ enc.writeVbin32(this.challenge);
+ }
+
+ }
+
+ public void read(Decoder dec)
+ {
+ packing_flags = (short) dec.readUint16();
+ if ((packing_flags & 256) != 0)
+ {
+ this.challenge = dec.readVbin32();
+ }
+
+ }
+
+ public Map<String,Object> getFields()
+ {
+ Map<String,Object> result = new LinkedHashMap<String,Object>();
+
+ if ((packing_flags & 256) != 0)
+ {
+ result.put("challenge", getChallenge());
+ }
+
+
+ return result;
+ }
+
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionSecureOk.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionSecureOk.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionSecureOk.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionSecureOk.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,154 @@
+package org.apache.qpid.transport;
+/*
+ *
+ * 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.
+ *
+ */
+
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import org.apache.qpid.transport.codec.Decoder;
+import org.apache.qpid.transport.codec.Encoder;
+
+import org.apache.qpid.transport.network.Frame;
+
+
+public final class ConnectionSecureOk extends Method {
+
+ public static final int TYPE = 260;
+
+ public final int getStructType() {
+ return TYPE;
+ }
+
+ public final int getSizeWidth() {
+ return 0;
+ }
+
+ public final int getPackWidth() {
+ return 2;
+ }
+
+ public final boolean hasPayload() {
+ return false;
+ }
+
+ public final byte getEncodedTrack() {
+ return Frame.L1;
+ }
+
+ public final boolean isConnectionControl()
+ {
+ return true;
+ }
+
+ private short packing_flags = 0;
+ private byte[] response;
+
+
+ public ConnectionSecureOk() {}
+
+
+ public ConnectionSecureOk(byte[] response, Option ... _options) {
+ if(response != null) {
+ setResponse(response);
+ }
+
+ for (int i=0; i < _options.length; i++) {
+ switch (_options[i]) {
+ case SYNC: this.setSync(true); break;
+ case BATCH: this.setBatch(true); break;
+ case UNRELIABLE: this.setUnreliable(true); break;
+ case NONE: break;
+ default: throw new IllegalArgumentException("invalid option: " + _options[i]);
+ }
+ }
+
+ }
+
+ public <C> void dispatch(C context, MethodDelegate<C> delegate) {
+ delegate.connectionSecureOk(context, this);
+ }
+
+
+ public final boolean hasResponse() {
+ return (packing_flags & 256) != 0;
+ }
+
+ public final ConnectionSecureOk clearResponse() {
+ packing_flags &= ~256;
+ this.response = null;
+ setDirty(true);
+ return this;
+ }
+
+ public final byte[] getResponse() {
+ return response;
+ }
+
+ public final ConnectionSecureOk setResponse(byte[] value) {
+ this.response = value;
+ packing_flags |= 256;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionSecureOk response(byte[] value) {
+ return setResponse(value);
+ }
+
+
+
+
+ public void write(Encoder enc)
+ {
+ enc.writeUint16(packing_flags);
+ if ((packing_flags & 256) != 0)
+ {
+ enc.writeVbin32(this.response);
+ }
+
+ }
+
+ public void read(Decoder dec)
+ {
+ packing_flags = (short) dec.readUint16();
+ if ((packing_flags & 256) != 0)
+ {
+ this.response = dec.readVbin32();
+ }
+
+ }
+
+ public Map<String,Object> getFields()
+ {
+ Map<String,Object> result = new LinkedHashMap<String,Object>();
+
+ if ((packing_flags & 256) != 0)
+ {
+ result.put("response", getResponse());
+ }
+
+
+ return result;
+ }
+
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionStart.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionStart.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionStart.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionStart.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,238 @@
+package org.apache.qpid.transport;
+/*
+ *
+ * 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.
+ *
+ */
+
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import org.apache.qpid.transport.codec.Decoder;
+import org.apache.qpid.transport.codec.Encoder;
+
+import org.apache.qpid.transport.network.Frame;
+
+
+public final class ConnectionStart extends Method {
+
+ public static final int TYPE = 257;
+
+ public final int getStructType() {
+ return TYPE;
+ }
+
+ public final int getSizeWidth() {
+ return 0;
+ }
+
+ public final int getPackWidth() {
+ return 2;
+ }
+
+ public final boolean hasPayload() {
+ return false;
+ }
+
+ public final byte getEncodedTrack() {
+ return Frame.L1;
+ }
+
+ public final boolean isConnectionControl()
+ {
+ return true;
+ }
+
+ private short packing_flags = 0;
+ private Map<String,Object> serverProperties;
+ private java.util.List<Object> mechanisms;
+ private java.util.List<Object> locales;
+
+
+ public ConnectionStart() {}
+
+
+ public ConnectionStart(Map<String,Object> serverProperties, java.util.List<Object> mechanisms, java.util.List<Object> locales, Option ... _options) {
+ if(serverProperties != null) {
+ setServerProperties(serverProperties);
+ }
+ if(mechanisms != null) {
+ setMechanisms(mechanisms);
+ }
+ if(locales != null) {
+ setLocales(locales);
+ }
+
+ for (int i=0; i < _options.length; i++) {
+ switch (_options[i]) {
+ case SYNC: this.setSync(true); break;
+ case BATCH: this.setBatch(true); break;
+ case UNRELIABLE: this.setUnreliable(true); break;
+ case NONE: break;
+ default: throw new IllegalArgumentException("invalid option: " + _options[i]);
+ }
+ }
+
+ }
+
+ public <C> void dispatch(C context, MethodDelegate<C> delegate) {
+ delegate.connectionStart(context, this);
+ }
+
+
+ public final boolean hasServerProperties() {
+ return (packing_flags & 256) != 0;
+ }
+
+ public final ConnectionStart clearServerProperties() {
+ packing_flags &= ~256;
+ this.serverProperties = null;
+ setDirty(true);
+ return this;
+ }
+
+ public final Map<String,Object> getServerProperties() {
+ return serverProperties;
+ }
+
+ public final ConnectionStart setServerProperties(Map<String,Object> value) {
+ this.serverProperties = value;
+ packing_flags |= 256;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionStart serverProperties(Map<String,Object> value) {
+ return setServerProperties(value);
+ }
+
+ public final boolean hasMechanisms() {
+ return (packing_flags & 512) != 0;
+ }
+
+ public final ConnectionStart clearMechanisms() {
+ packing_flags &= ~512;
+ this.mechanisms = null;
+ setDirty(true);
+ return this;
+ }
+
+ public final java.util.List<Object> getMechanisms() {
+ return mechanisms;
+ }
+
+ public final ConnectionStart setMechanisms(java.util.List<Object> value) {
+ this.mechanisms = value;
+ packing_flags |= 512;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionStart mechanisms(java.util.List<Object> value) {
+ return setMechanisms(value);
+ }
+
+ public final boolean hasLocales() {
+ return (packing_flags & 1024) != 0;
+ }
+
+ public final ConnectionStart clearLocales() {
+ packing_flags &= ~1024;
+ this.locales = null;
+ setDirty(true);
+ return this;
+ }
+
+ public final java.util.List<Object> getLocales() {
+ return locales;
+ }
+
+ public final ConnectionStart setLocales(java.util.List<Object> value) {
+ this.locales = value;
+ packing_flags |= 1024;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionStart locales(java.util.List<Object> value) {
+ return setLocales(value);
+ }
+
+
+
+
+ public void write(Encoder enc)
+ {
+ enc.writeUint16(packing_flags);
+ if ((packing_flags & 256) != 0)
+ {
+ enc.writeMap(this.serverProperties);
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ enc.writeArray(this.mechanisms);
+ }
+ if ((packing_flags & 1024) != 0)
+ {
+ enc.writeArray(this.locales);
+ }
+
+ }
+
+ public void read(Decoder dec)
+ {
+ packing_flags = (short) dec.readUint16();
+ if ((packing_flags & 256) != 0)
+ {
+ this.serverProperties = dec.readMap();
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ this.mechanisms = dec.readArray();
+ }
+ if ((packing_flags & 1024) != 0)
+ {
+ this.locales = dec.readArray();
+ }
+
+ }
+
+ public Map<String,Object> getFields()
+ {
+ Map<String,Object> result = new LinkedHashMap<String,Object>();
+
+ if ((packing_flags & 256) != 0)
+ {
+ result.put("serverProperties", getServerProperties());
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ result.put("mechanisms", getMechanisms());
+ }
+ if ((packing_flags & 1024) != 0)
+ {
+ result.put("locales", getLocales());
+ }
+
+
+ return result;
+ }
+
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionStartOk.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionStartOk.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionStartOk.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionStartOk.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,280 @@
+package org.apache.qpid.transport;
+/*
+ *
+ * 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.
+ *
+ */
+
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import org.apache.qpid.transport.codec.Decoder;
+import org.apache.qpid.transport.codec.Encoder;
+
+import org.apache.qpid.transport.network.Frame;
+
+
+public final class ConnectionStartOk extends Method {
+
+ public static final int TYPE = 258;
+
+ public final int getStructType() {
+ return TYPE;
+ }
+
+ public final int getSizeWidth() {
+ return 0;
+ }
+
+ public final int getPackWidth() {
+ return 2;
+ }
+
+ public final boolean hasPayload() {
+ return false;
+ }
+
+ public final byte getEncodedTrack() {
+ return Frame.L1;
+ }
+
+ public final boolean isConnectionControl()
+ {
+ return true;
+ }
+
+ private short packing_flags = 0;
+ private Map<String,Object> clientProperties;
+ private String mechanism;
+ private byte[] response;
+ private String locale;
+
+
+ public ConnectionStartOk() {}
+
+
+ public ConnectionStartOk(Map<String,Object> clientProperties, String mechanism, byte[] response, String locale, Option ... _options) {
+ if(clientProperties != null) {
+ setClientProperties(clientProperties);
+ }
+ if(mechanism != null) {
+ setMechanism(mechanism);
+ }
+ if(response != null) {
+ setResponse(response);
+ }
+ if(locale != null) {
+ setLocale(locale);
+ }
+
+ for (int i=0; i < _options.length; i++) {
+ switch (_options[i]) {
+ case SYNC: this.setSync(true); break;
+ case BATCH: this.setBatch(true); break;
+ case UNRELIABLE: this.setUnreliable(true); break;
+ case NONE: break;
+ default: throw new IllegalArgumentException("invalid option: " + _options[i]);
+ }
+ }
+
+ }
+
+ public <C> void dispatch(C context, MethodDelegate<C> delegate) {
+ delegate.connectionStartOk(context, this);
+ }
+
+
+ public final boolean hasClientProperties() {
+ return (packing_flags & 256) != 0;
+ }
+
+ public final ConnectionStartOk clearClientProperties() {
+ packing_flags &= ~256;
+ this.clientProperties = null;
+ setDirty(true);
+ return this;
+ }
+
+ public final Map<String,Object> getClientProperties() {
+ return clientProperties;
+ }
+
+ public final ConnectionStartOk setClientProperties(Map<String,Object> value) {
+ this.clientProperties = value;
+ packing_flags |= 256;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionStartOk clientProperties(Map<String,Object> value) {
+ return setClientProperties(value);
+ }
+
+ public final boolean hasMechanism() {
+ return (packing_flags & 512) != 0;
+ }
+
+ public final ConnectionStartOk clearMechanism() {
+ packing_flags &= ~512;
+ this.mechanism = null;
+ setDirty(true);
+ return this;
+ }
+
+ public final String getMechanism() {
+ return mechanism;
+ }
+
+ public final ConnectionStartOk setMechanism(String value) {
+ this.mechanism = value;
+ packing_flags |= 512;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionStartOk mechanism(String value) {
+ return setMechanism(value);
+ }
+
+ public final boolean hasResponse() {
+ return (packing_flags & 1024) != 0;
+ }
+
+ public final ConnectionStartOk clearResponse() {
+ packing_flags &= ~1024;
+ this.response = null;
+ setDirty(true);
+ return this;
+ }
+
+ public final byte[] getResponse() {
+ return response;
+ }
+
+ public final ConnectionStartOk setResponse(byte[] value) {
+ this.response = value;
+ packing_flags |= 1024;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionStartOk response(byte[] value) {
+ return setResponse(value);
+ }
+
+ public final boolean hasLocale() {
+ return (packing_flags & 2048) != 0;
+ }
+
+ public final ConnectionStartOk clearLocale() {
+ packing_flags &= ~2048;
+ this.locale = null;
+ setDirty(true);
+ return this;
+ }
+
+ public final String getLocale() {
+ return locale;
+ }
+
+ public final ConnectionStartOk setLocale(String value) {
+ this.locale = value;
+ packing_flags |= 2048;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionStartOk locale(String value) {
+ return setLocale(value);
+ }
+
+
+
+
+ public void write(Encoder enc)
+ {
+ enc.writeUint16(packing_flags);
+ if ((packing_flags & 256) != 0)
+ {
+ enc.writeMap(this.clientProperties);
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ enc.writeStr8(this.mechanism);
+ }
+ if ((packing_flags & 1024) != 0)
+ {
+ enc.writeVbin32(this.response);
+ }
+ if ((packing_flags & 2048) != 0)
+ {
+ enc.writeStr8(this.locale);
+ }
+
+ }
+
+ public void read(Decoder dec)
+ {
+ packing_flags = (short) dec.readUint16();
+ if ((packing_flags & 256) != 0)
+ {
+ this.clientProperties = dec.readMap();
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ this.mechanism = dec.readStr8();
+ }
+ if ((packing_flags & 1024) != 0)
+ {
+ this.response = dec.readVbin32();
+ }
+ if ((packing_flags & 2048) != 0)
+ {
+ this.locale = dec.readStr8();
+ }
+
+ }
+
+ public Map<String,Object> getFields()
+ {
+ Map<String,Object> result = new LinkedHashMap<String,Object>();
+
+ if ((packing_flags & 256) != 0)
+ {
+ result.put("clientProperties", getClientProperties());
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ result.put("mechanism", getMechanism());
+ }
+ if ((packing_flags & 1024) != 0)
+ {
+ result.put("response", getResponse());
+ }
+ if ((packing_flags & 2048) != 0)
+ {
+ result.put("locale", getLocale());
+ }
+
+
+ return result;
+ }
+
+
+}
Added: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionTune.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionTune.java?rev=1527366&view=auto
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionTune.java (added)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionTune.java Sun Sep 29 17:45:16 2013
@@ -0,0 +1,272 @@
+package org.apache.qpid.transport;
+/*
+ *
+ * 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.
+ *
+ */
+
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import org.apache.qpid.transport.codec.Decoder;
+import org.apache.qpid.transport.codec.Encoder;
+
+import org.apache.qpid.transport.network.Frame;
+
+
+public final class ConnectionTune extends Method {
+
+ public static final int TYPE = 261;
+
+ public final int getStructType() {
+ return TYPE;
+ }
+
+ public final int getSizeWidth() {
+ return 0;
+ }
+
+ public final int getPackWidth() {
+ return 2;
+ }
+
+ public final boolean hasPayload() {
+ return false;
+ }
+
+ public final byte getEncodedTrack() {
+ return Frame.L1;
+ }
+
+ public final boolean isConnectionControl()
+ {
+ return true;
+ }
+
+ private short packing_flags = 0;
+ private int channelMax;
+ private int maxFrameSize;
+ private int heartbeatMin;
+ private int heartbeatMax;
+
+
+ public ConnectionTune() {}
+
+
+ public ConnectionTune(int channelMax, int maxFrameSize, int heartbeatMin, int heartbeatMax, Option ... _options) {
+ setChannelMax(channelMax);
+ setMaxFrameSize(maxFrameSize);
+ setHeartbeatMin(heartbeatMin);
+ setHeartbeatMax(heartbeatMax);
+
+ for (int i=0; i < _options.length; i++) {
+ switch (_options[i]) {
+ case SYNC: this.setSync(true); break;
+ case BATCH: this.setBatch(true); break;
+ case UNRELIABLE: this.setUnreliable(true); break;
+ case NONE: break;
+ default: throw new IllegalArgumentException("invalid option: " + _options[i]);
+ }
+ }
+
+ }
+
+ public <C> void dispatch(C context, MethodDelegate<C> delegate) {
+ delegate.connectionTune(context, this);
+ }
+
+
+ public final boolean hasChannelMax() {
+ return (packing_flags & 256) != 0;
+ }
+
+ public final ConnectionTune clearChannelMax() {
+ packing_flags &= ~256;
+ this.channelMax = 0;
+ setDirty(true);
+ return this;
+ }
+
+ public final int getChannelMax() {
+ return channelMax;
+ }
+
+ public final ConnectionTune setChannelMax(int value) {
+ this.channelMax = value;
+ packing_flags |= 256;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionTune channelMax(int value) {
+ return setChannelMax(value);
+ }
+
+ public final boolean hasMaxFrameSize() {
+ return (packing_flags & 512) != 0;
+ }
+
+ public final ConnectionTune clearMaxFrameSize() {
+ packing_flags &= ~512;
+ this.maxFrameSize = 0;
+ setDirty(true);
+ return this;
+ }
+
+ public final int getMaxFrameSize() {
+ return maxFrameSize;
+ }
+
+ public final ConnectionTune setMaxFrameSize(int value) {
+ this.maxFrameSize = value;
+ packing_flags |= 512;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionTune maxFrameSize(int value) {
+ return setMaxFrameSize(value);
+ }
+
+ public final boolean hasHeartbeatMin() {
+ return (packing_flags & 1024) != 0;
+ }
+
+ public final ConnectionTune clearHeartbeatMin() {
+ packing_flags &= ~1024;
+ this.heartbeatMin = 0;
+ setDirty(true);
+ return this;
+ }
+
+ public final int getHeartbeatMin() {
+ return heartbeatMin;
+ }
+
+ public final ConnectionTune setHeartbeatMin(int value) {
+ this.heartbeatMin = value;
+ packing_flags |= 1024;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionTune heartbeatMin(int value) {
+ return setHeartbeatMin(value);
+ }
+
+ public final boolean hasHeartbeatMax() {
+ return (packing_flags & 2048) != 0;
+ }
+
+ public final ConnectionTune clearHeartbeatMax() {
+ packing_flags &= ~2048;
+ this.heartbeatMax = 0;
+ setDirty(true);
+ return this;
+ }
+
+ public final int getHeartbeatMax() {
+ return heartbeatMax;
+ }
+
+ public final ConnectionTune setHeartbeatMax(int value) {
+ this.heartbeatMax = value;
+ packing_flags |= 2048;
+ setDirty(true);
+ return this;
+ }
+
+ public final ConnectionTune heartbeatMax(int value) {
+ return setHeartbeatMax(value);
+ }
+
+
+
+
+ public void write(Encoder enc)
+ {
+ enc.writeUint16(packing_flags);
+ if ((packing_flags & 256) != 0)
+ {
+ enc.writeUint16(this.channelMax);
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ enc.writeUint16(this.maxFrameSize);
+ }
+ if ((packing_flags & 1024) != 0)
+ {
+ enc.writeUint16(this.heartbeatMin);
+ }
+ if ((packing_flags & 2048) != 0)
+ {
+ enc.writeUint16(this.heartbeatMax);
+ }
+
+ }
+
+ public void read(Decoder dec)
+ {
+ packing_flags = (short) dec.readUint16();
+ if ((packing_flags & 256) != 0)
+ {
+ this.channelMax = dec.readUint16();
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ this.maxFrameSize = dec.readUint16();
+ }
+ if ((packing_flags & 1024) != 0)
+ {
+ this.heartbeatMin = dec.readUint16();
+ }
+ if ((packing_flags & 2048) != 0)
+ {
+ this.heartbeatMax = dec.readUint16();
+ }
+
+ }
+
+ public Map<String,Object> getFields()
+ {
+ Map<String,Object> result = new LinkedHashMap<String,Object>();
+
+ if ((packing_flags & 256) != 0)
+ {
+ result.put("channelMax", getChannelMax());
+ }
+ if ((packing_flags & 512) != 0)
+ {
+ result.put("maxFrameSize", getMaxFrameSize());
+ }
+ if ((packing_flags & 1024) != 0)
+ {
+ result.put("heartbeatMin", getHeartbeatMin());
+ }
+ if ((packing_flags & 2048) != 0)
+ {
+ result.put("heartbeatMax", getHeartbeatMax());
+ }
+
+
+ return result;
+ }
+
+
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org