我们仍然需要找到一种方式实现写内存的操作.RabbitMQ不同于其他队列排队系统的一个重要的方面,是强烈的订阅者和消费者分离的考量.在RabbitMQ体系结构中,这点是通过队列和订阅者交换的介绍来实现的.订阅者不知道消息的最终目的地,他们只知道一个交换的名字和路由关键字,这个关键字可以看作是发送消息的地址.
针对不同的交换类型,RabbitMQ支持不同的语义,这将影响一个带有地址的消息匹配一个交换的方式.它将传递到实际的信箱(队列),消费者将从这里接收消息.
在我们的例子中，写方法的第一个参数是队列名称。 队列名称也是工作者预测下一个内存中待处理的任务时使用的参数。
Palermo中该方法下一个参数是一种直接交换类型。 在这种交换类型中，路由关键字必须和传输消息的队列名称匹配。
如果一条消息被发往 RabbitMQ 进行交换，并且没有队列连接到交换，那么这条消息会被丢弃或者被发往相关的备用交换。 为了避免这种情况， Palermo中一个发布者每次把一个新的任务加入到队列中时，在发送任务的数据之前，发布者会声明匹配路由关键字的队列。 通过这种方式，我们可以确定当没有工作者在等待处理任务时消息也不会被丢弃。 在 RabbitMQ中，使用相同的参数重新声明一个已存在的队列是一个合法的操作，且没有任何影响。
使用之前为RabbitMQ所描述的设置，我们可以建立工作处理系统的核心。然而，某些特性，像失败事务的管理或者消息的序列化，它们不能被编址放到RabbitMQ的特性中。在Palermo中，这个特性已经被实现，并被作为一个附加的应用软件层，这个层可以被分配作为一个Java库。
首要的问题是如何处理失败的事务。我们来看它是怎么（工作的），过去我们使用显式的人工确认，在人工处理或超时时，RabbitMQ将会处理致命的错误。这套机制也可以用于处理在事务处理逻辑中（产生的）任何类型的异常条件，除了我们期望的功能需求外，失败信息必定会发送给一个特别的失败事务队列，他们可以被查阅，移除和重入队。这个功能已经在Palermo中被完成，被包装为一个通用的Java事务用来处理try/catch块，并通过管道将失败信息添加到队列中，并添加一些关于事务的错误信息，（例如）重试次数和在消息元数据的头中的原始队列一并发送消息给RabbitMQ。
序列化的问题,已经通过定义一个作业消息来陈述了,这个消息包含作业Java类的头信息,作业序列化参数和序列化类型.有关参数形象化的一小部分内容,通过一个人眼可识别的字符串,也随消息一起发送了. Palermo已经通过支持插件和去插件的方式,对系统进行不同的序列化,同时,包含一个基于JSON的序列化转换器.但是,默认的序列化技术是使用JBoss Serialization.只有作业的参数被序列化,并发送给工作者,作业类的字节码必须在工作者的class path中可用,以便正确执行作业.
Palermo工作者只是执行实际作业逻辑的一种通用方式,其中作业逻辑是封装在作业类的定义之中.
Palermo的整个逻辑已经在Clojure编程语言中实现,但是,多亏Clojure Java inter-op特性,它可以在java代码或其他任意基于JVM的语言中使用.由于Palermo工作者线程在JVM中运行,它们从底层的操作系统中被隔离出来.像Resque工作者那样,集成在OS之中,很难实现,但是某种程度的集成,在可能的情况下,已经尝试过,如,为关联到Palermo工作者的RabbitMQ消费者的身份标识,使用进程标识符.一个命令行的接口也已经实现了,所以,新的工作者,通过脚本和使用者,可以很简单的启动.
解决方案的最后一个组件是Palermo 系统中运行的一个web接口。 这只是一个使用了Palermo 类库自检特性的简单的web应用，它让人们更容易理解Palermo 系统的运行机制。 这个接口是Resque web接口的复制，在管理交换、队列、工作者方面，它可以作为RabbitMQ 通用接口的替代者。
通过Palermo 类库，web接口提供的所有功能可以在任意java代码中进行使用。
