/\\\       
            \/\\\        
             \/\\\    
 /\\\\\\\\\\\ \/\\\         /\\\    /\\\  /\\\\\\\\\\     
 \///////\\\/  \/\\\\\\\\\  \/\\\   \/\\\ \/\\\//////     
       /\\\/    \/\\\////\\\ \/\\\   \/\\\ \/\\\\\\\\\\    
      /\\\/      \/\\\  \/\\\ \/\\\   \/\\\ \////////\\\  
     /\\\\\\\\\\\ \/\\\\\\\\\  \//\\\\\\\\\   /\\\\\\\\\\  
     \///////////  \/////////    \/////////   \//////////       QQ Group: 467741880

<dependency>
	<groupId>io.zbus</groupId>
	<artifactId>zbus</artifactId>
	<version>1.0.0-SNAPSHOT</version>
</dependency>

{
	cmd:       pub|sub|create|remove|query|ping //Request required,
	status:    200|400|404|403|500 ...          //Response required,
	body:      <data>,

	id:        <message_id>,
	apiKey:    <apid_key>,
	signature: <signature>
} 

1) sort key ascending in request (recursively on both key and value), and generate json string
2) Init HmacSHA256 with secretKey, do encrypt on 1)'s json string to generate bytes
3) signature = Hex format in upper case on the 2)'s bytes

{
	cmd:         pub,         //required
	mq:          <mq_name>,   //required 
	body:        <business data> 
}

{
	status:      200|400|403|500,    
	body:        <string_response> 
}

{
	cmd:         sub,           //required
	mq:          <mq_name>,     //required  
	channel:     <channel_name> //required
	window:      <window_size>
}

First message: indicates subscribe success or failure
{
	status:      200|400|403|500,    
	body:        <string_response> 
}

Following messages:
{
	mq:          <mq_name>,     //required  
	channel:     <channel_name> //required
	sender:      <message from>
	id:          <message id>
	body:        <business_data>
}

{
	cmd:         take,          //required
	mq:          <mq_name>,     //required 
	channel:     <channel_name> //required
	window:      <batch_size>
}

{
	status:      200|400|403|500|604, //604 stands for NO data   
	body:        <data> 
}

{
	cmd:         create,         //required
	mq:          <mq_name>,      //required

	mqType:      memory|disk|db, //default to memory
	mqMask:      <mask_integer>,
	channel:     <channel_name>,
	channelMask: <mask_integer>,
	offset:      <channel_offset>,
	checksum:    <offset_checksum>
	topic:       <channel_topic>, 
}

{
	status:      200|400|403|500,    
	body:        <message_response> 
}

{
	cmd:         remove,         //required
	mq:          <mq_name>,      //required 
	channel:     <channel_name> 
}

{
	status:      200|400|403|500,    
	body:        <message_response> 
}

{
	cmd:         query,          //required
	mq:          <mq_name>,      //required 
	channel:     <channel_name> 
}

{
	status:      200|400|403|500,    
	body:        <mq_channel_info> 
}

Example
{
	body: {
		channels: [ ],
		mask: 0,
		name: "DiskQ",
		size: 200000,
		type: "disk"
	},
	status: 200
}

{ 
	method:     <method_name>, //required 
	params:     [param_array],
	module:     <module_name>,

	id:        <message_id>,
	apiKey:    <apid_key>,
	signature: <signature>
}

{
	status:      200|400|403|500|604   //required
	body:        <data_or_exception>,
	id:          <message_id>
}

Create MQ: http://localhost:15555?cmd=create&mq=MyMQ&mqType=disk

Produce 
ab -k -c 32 -n 1000000 http://localhost:15555/?cmd=pub&mq=MyMQ

Create MQ: http://localhost:15555?cmd=create&mq=MyMQ&channel=MyChannel
Consume 
ab -k -c 32 -n 1000000 http://localhost:15555?cmd=take&mq=MyMQ&channel=MyChannel

Single Mac i7 box with SSD 
Produce:  ~80,000/s
Consume:  ~90,000/s