ElasticMQ是一个使用Scala编写的简单消息队列系统。当前使用嵌入式数据库H2来存储消息。ElasticMQ实现了SQSREST接口的子集,提供一个SQS的可选方案。
ElasticMQ使用Squeryl来访问数据库。
示例代码:
//FirstweneedtocreateaNodevalnode=NodeBuilder.createNode//ThenwecanexposethenativeclientusingtheSQSRESTinterfacevalserver=SQSRestServerFactory.start(node.nativeClient,8888,"https://localhost:8888")//...use...//Finallyweneedtostoptheserverandthenodeserver.stop()node.shutdown()
评论