diff --git a/contracts/mainnet/connectors/steth-queue/events.sol b/contracts/mainnet/connectors/steth-queue/events.sol
new file mode 100644
index 0000000..31e569e
--- /dev/null
+++ b/contracts/mainnet/connectors/steth-queue/events.sol
@@ -0,0 +1,21 @@
+//SPDX-License-Identifier: MIT
+pragma solidity ^0.8.2;
+
+contract Events {
+    event LogQueueSteth(
+        uint256 stETHAmount,
+        uint256 ethBorrowAmount,
+        uint256 requestIdFrom,
+        uint256 getId,
+        uint256 setId
+    );
+
+    event LogClaimSteth(
+        uint256 nftId,
+        uint256 claimedAmount,
+        uint256 repayAmount,
+        uint256 getId,
+        uint256 setIdClaimedAmt,
+        uint256 setIdRepayAmt
+    );
+}
diff --git a/contracts/mainnet/connectors/steth-queue/interfaces.sol b/contracts/mainnet/connectors/steth-queue/interfaces.sol
new file mode 100644
index 0000000..c808892
--- /dev/null
+++ b/contracts/mainnet/connectors/steth-queue/interfaces.sol
@@ -0,0 +1,16 @@
+//SPDX-License-Identifier: MIT
+pragma solidity ^0.8.2;
+
+interface IFluidStETHQueue {
+    function queue(
+        uint256 ethBorrowAmount_,
+        uint256 stETHAmount_,
+        address borrowTo_,
+        address claimTo_
+    ) external returns (uint256 requestIdFrom_);
+
+    function claim(
+        address claimTo_,
+        uint256 requestIdFrom_
+    ) external returns (uint256 claimedAmount_, uint256 repayAmount_);
+}
diff --git a/contracts/mainnet/connectors/steth-queue/main.sol b/contracts/mainnet/connectors/steth-queue/main.sol
new file mode 100644
index 0000000..26bdf29
--- /dev/null
+++ b/contracts/mainnet/connectors/steth-queue/main.sol
@@ -0,0 +1,88 @@
+//SPDX-License-Identifier: MIT
+pragma solidity ^0.8.2;
+
+import {TokenInterface} from "../../common/interfaces.sol";
+import {Events} from "./events.sol";
+import {IFluidStETHQueue} from "./interfaces.sol";
+import {Basic} from "../../common/basic.sol";
+
+abstract contract StethQueueConnector is Events, Basic {
+    address public constant FLUID_STETH_QUEUE =
+        0xEb6643733c5E7CaB6B27D98C8CFDc647f8112a96;
+    address public constant STETH = 0xae7ab96520DE3A18E5e111B5EaAb095312D7fE84;
+
+    function queueSteth(
+        uint256 stETHAmount_,
+        uint256 ethBorrowAmount_,
+        uint256 getId_,
+        uint256 setId_
+    )
+        external
+        payable
+        returns (string memory _eventName, bytes memory _eventParam)
+    {
+        uint256 stETHAmt_ = getUint(getId_, stETHAmount_);
+
+        IFluidStETHQueue fluidStethContract_ = IFluidStETHQueue(
+            FLUID_STETH_QUEUE
+        );
+
+        stETHAmt_ = stETHAmt_ == type(uint256).max
+            ? TokenInterface(STETH).balanceOf(address(this))
+            : stETHAmt_;
+
+        approve(TokenInterface(address(FLUID_STETH_QUEUE)), STETH, stETHAmt_);
+        uint256 requestIdFrom_ = fluidStethContract_.queue(
+            ethBorrowAmount_,
+            stETHAmount_,
+            address(this),
+            address(this)
+        ); // todo: confirm
+
+        setUint(setId_, requestIdFrom_);
+        _eventName = "LogQueueSteth(uint256,uint256,uint256,uint256,uint256)";
+        _eventParam = abi.encode(
+            stETHAmount_,
+            ethBorrowAmount_,
+            requestIdFrom_,
+            getId_,
+            setId_
+        );
+    }
+
+    function claimSteth(
+        uint256 nftId_,
+        uint256 getId_,
+        uint256 setIdClaimedAmt_,
+        uint256 setIdRepayAmt_
+    )
+        external
+        payable
+        returns (string memory _eventName, bytes memory _eventParam)
+    {
+        uint256 nftIdNum_ = getUint(getId_, nftId_);
+
+        IFluidStETHQueue fluidStethContract_ = IFluidStETHQueue(
+            FLUID_STETH_QUEUE
+        );
+
+        (uint256 claimedAmount_, uint256 repayAmount_) = fluidStethContract_
+            .claim(address(this), nftIdNum_);
+
+        setUint(setIdClaimedAmt_, claimedAmount_);
+        setUint(setIdRepayAmt_, repayAmount_);
+        _eventName = "LogClaimSteth(uint256,uint256,uint256,uint256,uint256,uint256)";
+        _eventParam = abi.encode(
+            nftId_,
+            claimedAmount_,
+            repayAmount_,
+            getId_,
+            setIdClaimedAmt_,
+            setIdRepayAmt_
+        );
+    }
+}
+
+contract ConnectV2StethQueueFluid is StethQueueConnector {
+    string public constant name = "Steth-Queue-Fluid-v1.0";
+}