Add support for connection properties exchange.

Introduced the ability to set and retrieve properties in OpenFrame exchanges between local and remote endpoints. This change ensures flexible configuration and access to remote properties post-connection establishment.

Author: iitsoftware

src/main/java/com/swiftmq/amqp/v100/client/Connection.java

@@ -25,6 +25,7 @@
 import com.swiftmq.amqp.v100.client.po.POOpen;
 import com.swiftmq.amqp.v100.client.po.POProtocolRequest;
 import com.swiftmq.amqp.v100.client.po.POSendClose;
+import com.swiftmq.amqp.v100.generated.transport.definitions.Fields;
 import com.swiftmq.amqp.v100.transport.AMQPFrame;
 import com.swiftmq.amqp.v100.types.AMQPString;
 import com.swiftmq.amqp.v100.types.AMQPSymbol;
@@ -92,6 +93,7 @@ public class Connection implements ExceptionHandler {
     int outputBufferExtendSize = 65536;
     SocketFactory socketFactory = new PlainSocketFactory();
     ExceptionListener exceptionListener = null;
+    Fields properties = null;
 
     /**
      * Creates a Connection and uses SASL for authentication.
@@ -223,6 +225,23 @@ public void setOpenHostname(String openHostname) {
         this.openHostname = openHostname;
     }
 
+    /**
+     * Sets the of the OpenFrame to be sent to the remote endpoint
+     *
+     * @param properties Fields for the OpenFrame
+     */
+    public void setProperties(Fields properties) {
+        this.properties = properties;
+    }
+
+    /**
+     * Retrieves the properties of the OpenFrame from the remote endpoint. Available after connect
+     *
+     * @return Fields object representing the remote properties, or null if not available
+     */
+    public Fields getRemoteProperties() {
+        return connectionDispatcher.getRemoteProperties();
+    }
     /**
      * Sets the idle timeout. Default is Long.MAX_VALUE.
      * <p/>
@@ -365,6 +384,8 @@ protected ProtocolInputHandler createInputHandler() {
                 return connectionDispatcher.getProtocolHandler();
             }
         };
+        if (properties != null)
+            connectionDispatcher.setProperties(properties);
         connectionDispatcher.setMyConnection(this);
         networkConnection.start();
         dos = new DataStreamOutputStream(networkConnection.getOutputStream());

src/main/java/com/swiftmq/amqp/v100/client/ConnectionDispatcher.java

@@ -26,6 +26,7 @@
 import com.swiftmq.amqp.v100.generated.security.sasl.*;
 import com.swiftmq.amqp.v100.generated.transport.definitions.ConnectionError;
 import com.swiftmq.amqp.v100.generated.transport.definitions.ErrorConditionFactory;
+import com.swiftmq.amqp.v100.generated.transport.definitions.Fields;
 import com.swiftmq.amqp.v100.generated.transport.definitions.Milliseconds;
 import com.swiftmq.amqp.v100.generated.transport.performatives.*;
 import com.swiftmq.amqp.v100.transport.AMQPFrame;
@@ -76,7 +77,7 @@ public class ConnectionDispatcher
     POProtocolRequest protPO = null;
     POAuthenticate authPO = null;
     POOpen openPO = null;
-    OpenFrame remoteOpen = null;
+    volatile OpenFrame remoteOpen = null;
     POSendClose closePO = null;
     CloseFrame remoteClose = null;
     SaslMechanismsFrame saslMechanisms = null;
@@ -89,6 +90,7 @@ public class ConnectionDispatcher
     long idleTimeoutDelay = 0;
     SaslClient saslClient = null;
     volatile boolean connectionDisabled = false;
+    Fields properties = null;
 
     int maxLocalFrameSize = Integer.MAX_VALUE;
     int maxRemoteFrameSize = Integer.MAX_VALUE;
@@ -133,6 +135,16 @@ public int getMaxFrameSize() {
         return Math.max(512, Math.min(maxLocalFrameSize, maxRemoteFrameSize));
     }
 
+    public void setProperties(Fields properties) {
+        this.properties = properties;
+    }
+
+    public Fields getRemoteProperties() {
+        if (remoteOpen != null)
+            return remoteOpen.getProperties();
+        return null;
+    }
+
     public void setSaslActive(boolean saslActive) {
         this.saslActive = saslActive;
     }
@@ -317,6 +329,8 @@ public void visit(POOpen po) {
             OpenFrame openFrame = new OpenFrame(0);
             openFrame.setContainerId(new AMQPString(po.getContainerId()));
             openFrame.setChannelMax(new AMQPUnsignedShort(po.getMaxChannel()));
+            if (properties != null)
+                openFrame.setProperties(properties);
             if (myConnection.getOpenHostname() == null)
                 openFrame.setHostname(new AMQPString(remoteHostname));
             else