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

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


                INTERNAL_XID BIGINT NOT NULL,
                MESSAGE_ID BIGINT NOT NULL,
                QUEUE_NAME VARCHAR 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
