                 INTERNAL_XID BIGINT NOT NULL,
                 MESSAGE_ID BIGINT NOT NULL,
                 QUEUE_NAME VARCHAR NOT NULL,
-                MESSAGE_METADATA BINARY NOT NULL,
+                MESSAGE_METADATA BINARY(1000) NOT NULL,
                 PRIMARY KEY (MESSAGE_ID),
                 FOREIGN KEY (INTERNAL_XID) REFERENCES MB_DTX_XID (INTERNAL_XID)
                 ON DELETE CASCADE

CREATE TABLE IF NOT EXISTS MB_CONTENT (
                MESSAGE_ID BIGINT,
                CONTENT_OFFSET INT,
                MESSAGE_CONTENT BINARY NOT NULL,
                PRIMARY KEY (MESSAGE_ID,CONTENT_OFFSET),
                FOREIGN KEY (MESSAGE_ID) REFERENCES MB_METADATA (MESSAGE_ID)
                ON DELETE CASCADE

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