开源软件名称：

medispatcher

开源软件地址：

https://gitee.com/chaos.su/medispatcher

开源软件介绍：

#MEDISPATCHER message/event dispatchermedispatcher is the core component of message/event center. It dispatches the messages from the main incoming queue to topic channels, pushes messages from channels to subscribers.

About "DATA" log

data logs may hold very important data:

RECOVFAILBACK messages popped from recover list(redis list), failed being pushed to queue server and failed being pushed back to recover list.
REDISTFAIL messages popped from the main incoming queue on the queue server, but failed being redistributed to the sub queue (channel) for the subscriber, and they are not stored in queue anymore, should be recovered from logs.
RECOVFAILDECODE messages popped from recover list(redis list), failed being decoded.
RECOVFAILASSERT message popped from recover list(redis list), decoded, but its type it not correct.
RESENT not so important. message re-sent (to subscriber) logs.
SENT not so important. message sent (to subscriber for the first time) logs.

Releases

2.0.0

First release of v2.

Features

Multi-channel, parallel message push by channels. Push of subscriptions will no longer be blocked by other slow message receivers/consumers.

2.1.0

2.1.0 released(refers to the git tag).

Performance parameters can be controlled as to each subscription on the backend control panel.
parameters are:

 count of concurrent push routines for the subscription.     count of concurrent retry-push routines for the subscription.      minimum interval between pushes.     message process timeout.      message process uri.

Above parameters take effects instantly. Do not requires dispatcher service restarting or reloading.

2.2.0

2.2.0 release(refers to the git tag).

Alerts when message processing failures reaches certain thresholds.
Customizable config file
e.g. medispatcher /path/to/config/file
Multiple message processing worker url support. The urls can be multi-lined, each line represents a separate worker url. This achieves a soft load balance.

Milestone

2.1.0

####Features

Performance parameters can be controlled as to each subscription on the backend control panel.
parameters are: count of concurrent push routines for the subscription, count of concurrent retry-push routines for the subscription, minimum interval between pushes.

2.2.0

####Features

Alerts when message processing failures reaches certain thresholds.
Customizable config file
e.g. medispatcher /path/to/config/file
Multiple message processing worker url support. The urls can be multi-lined, each line represents a separate worker url. This achieves a soft load balance.