diff --git a/src/wsConnectionManager.ts b/src/wsConnectionManager.ts
index 510869d..7ea8ae2 100644
--- a/src/wsConnectionManager.ts
+++ b/src/wsConnectionManager.ts
@@ -98,6 +98,12 @@ const getRedisChannelFromMessage = (message: any): string => {
 		case 'trades':
 			return `trades_${marketType}_${marketIndex}`;
 		case 'orderbook':
+			if (
+				message.grouping &&
+				GROUPING_OPTIONS.includes(parseInt(message.grouping))
+			) {
+				return `orderbook_${marketType}_${marketIndex}_grouped_${message.grouping}`;
+			}
 			return `orderbook_${marketType}_${marketIndex}`;
 		case 'orderbook_indicative': {
 			if (