   MESSAGE_ID VARCHAR(120),
   PRIMARY KEY(CONSUMER_ID, MESSAGE_ID)
 );
+

DROP table IF EXISTS TODO;
DROP table IF EXISTS message;
DROP table IF EXISTS received_messages;

CREATE  TABLE TODO (
  ID varchar(255) PRIMARY KEY,

  ORDER_ID INTEGER,
  ACTIVE_FLG varchar(1) DEFAULT 'Y'
);

CREATE TABLE message (
  ID VARCHAR(120) PRIMARY KEY,
