bubdm / dmps

用于分布式管理系统， 包括日志收集，消息订阅，SOA,集群管理，性能数据监控

DMPS

分布式管理系统， 包括日志收集，消息订阅，SOA,集群管理，性能数据监控 配置文件 Event.Bindings.config

<eventProvider>
	<queues>
		<queue id="DMPHubEvent" class="DMPSystem.Core.EventBus.Utilities.QueueContext,DMPSystem.Core.EventBus">
			<property name="appRuleFile" ref="rule"/>
			<property name="dataContextPool" value="event_sample">
				<map name="RabbitMq">
					<property value="guest:[email protected]::test"/>
				</map>
				<map name="MsMq"></map>
				<map name="PushEvent"></map>
			</property>
			<property name="connectTimeout" value="120"/>
			<property name="CunsumerNum" value="5"/>
			<property name="UseRetryNum" value="5"/>
		</queue>
	</queues>
</eventProvider>

push publisher:

EventContainer.GetInstances<IEventPublisher>("PushEvent").Publish(new ChanageStateEvent() { UserID = manager.UserID });

rabbitmq publisher:

EventContainer.GetInstances<IEventPublisher>("DMPHubEvent.RabbitMq").Publish(new ChanageStateEvent() { UserID = manager.UserID });

UseRateLimit 每分钟消息消费数限定在多少之内
UseRetryNum 消息消费失败后重试次数，每次间隔1分钟
增加注册消费者模块注册的方法，这样就不需要依赖Autofac
EventContainer.RegisterConsumeModule(params Type[] types)