 CREATE TABLE IF NOT EXISTS MB_RETAINED_CONTENT (
                 MESSAGE_ID BIGINT,
                 CONTENT_OFFSET INT,
-                MESSAGE_CONTENT BINARY NOT NULL,
+                MESSAGE_CONTENT BINARY(1000) NOT NULL,
                 PRIMARY KEY (MESSAGE_ID,CONTENT_OFFSET)
 );
 

                INTERNAL_XID BIGINT NOT NULL,
                MESSAGE_ID BIGINT,
                CONTENT_OFFSET INT,
                MESSAGE_CONTENT BINARY NOT NULL,
                PRIMARY KEY (MESSAGE_ID, CONTENT_OFFSET),
                FOREIGN KEY (MESSAGE_ID) REFERENCES MB_DTX_DEQUEUE_RECORD (MESSAGE_ID)
                ON DELETE CASCADE

                MESSAGE_ID BIGINT UNIQUE,
                QUEUE_ID INT,
                DLC_QUEUE_ID INT NOT NULL,
                MESSAGE_METADATA BINARY(1000),
                PRIMARY KEY (MESSAGE_ID, QUEUE_ID),
                FOREIGN KEY (QUEUE_ID) REFERENCES MB_QUEUE_MAPPING (QUEUE_ID)
);
