Log warning if the broker is not RabbitMQ

Author: acogoluegnes

src/main/java/com/rabbitmq/client/amqp/impl/AmqpConnection.java

@@ -270,6 +270,7 @@ private NativeConnectionWrapper connect(
       LOGGER.debug("Created native connection instance for '{}'", this.name());
       ExceptionUtils.wrapGet(connection.openFuture());
       LOGGER.debug("Connection attempt '{}' succeeded", this.name());
+      checkBroker(connection);
       checkBrokerVersion(connection);
       return new NativeConnectionWrapper(connection, extractNode(connection), address);
     } catch (ClientException e) {
@@ -285,6 +286,13 @@ private void sync(NativeConnectionWrapper wrapper) {
     this.nativeConnection = wrapper.connection();
   }
 
+  private static void checkBroker(org.apache.qpid.protonj2.client.Connection connection) throws ClientException {
+    String broker = (String) connection.properties().get("product");
+    if (!"rabbitmq".equalsIgnoreCase(broker)) {
+      LOGGER.warn("Connected to another broker than RabbitMQ ('{}'), the library may not behave as expected", broker);
+    }
+  }
+
   private static void checkBrokerVersion(org.apache.qpid.protonj2.client.Connection connection)
       throws ClientException {
     String version = (String) connection.properties().get("version");