                 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

                INTERNAL_XID BIGINT NOT NULL UNIQUE,
                NODE_ID VARCHAR(512) NOT NULL,
                FORMAT_CODE BIGINT NOT NULL,
                GLOBAL_ID BINARY NOT NULL,
                BRANCH_ID BINARY NOT NULL,
                PRIMARY KEY (INTERNAL_XID, NODE_ID)
);

CREATE TABLE IF NOT EXISTS MB_DTX_ENQUEUE_RECORD (
                INTERNAL_XID BIGINT NOT NULL,
                MESSAGE_ID BIGINT NOT NULL,
                MESSAGE_METADATA BINARY 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_RETAINED_CONTENT (
                MESSAGE_ID BIGINT,
                CONTENT_OFFSET INT,
                MESSAGE_CONTENT BINARY(1000) NOT NULL,
                PRIMARY KEY (MESSAGE_ID,CONTENT_OFFSET)
);

